Skip to content

Commit b8ddb13

Browse files
Merge pull request #140 from MikePlayle/master
Set the nowait flag in queueBindNoWait()
2 parents f3e43f8 + 0b40139 commit b8ddb13

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/java/com/rabbitmq/client/Channel.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -616,7 +616,7 @@ void queueDeclareNoWait(String queue, boolean durable, boolean exclusive, boolea
616616
Queue.BindOk queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
617617

618618
/**
619-
* Same as {@link Channel#queueDeclare(String, boolean, boolean, boolean, java.util.Map)} but sets nowait
619+
* Same as {@link Channel#queueBind(String, String, String, java.util.Map)} but sets nowait
620620
* parameter to true and returns void (as there will be no response
621621
* from the server).
622622
* @param queue the name of the queue

src/main/java/com/rabbitmq/client/impl/ChannelN.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -970,6 +970,7 @@ public void queueBindNoWait(String queue,
970970
.exchange(exchange)
971971
.routingKey(routingKey)
972972
.arguments(arguments)
973+
.nowait(true)
973974
.build()));
974975
}
975976

0 commit comments

Comments
 (0)