Skip to content

Commit 6908989

Browse files
committed
Revert to 0-9 definition.
1 parent 48bc123 commit 6908989

File tree

3 files changed

+10
-8
lines changed

3 files changed

+10
-8
lines changed

src/com/rabbitmq/client/Channel.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -323,26 +323,28 @@ Queue.DeclareOk queueDeclare(int ticket, String queue, boolean passive, boolean
323323
* Unbinds a queue from an exchange, with no extra arguments.
324324
* @see com.rabbitmq.client.AMQP.Queue.Unbind
325325
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
326+
* @param ticket an access ticket for the appropriate realm
326327
* @param queue the name of the queue
327328
* @param exchange the name of the exchange
328329
* @param routingKey the routine key to use for the binding
329330
* @return an unbinding-confirm method if the binding was successfully deleted
330331
* @throws java.io.IOException if an error is encountered
331332
*/
332-
Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey) throws IOException;
333+
Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey) throws IOException;
333334

334335
/**
335336
* Unbind a queue from an exchange.
336337
* @see com.rabbitmq.client.AMQP.Queue.Unbind
337338
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
339+
* @param ticket an access ticket for the appropriate realm
338340
* @param queue the name of the queue
339341
* @param exchange the name of the exchange
340342
* @param routingKey the routine key to use for the binding
341343
* @param arguments other properties (binding parameters)
342344
* @return an unbinding-confirm method if the binding was successfully deleted
343345
* @throws java.io.IOException if an error is encountered
344346
*/
345-
Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
347+
Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
346348

347349
/**
348350
* Retrieve a message from a queue using {@link com.rabbitmq.client.AMQP.Basic.Get}

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -551,24 +551,24 @@ public Queue.BindOk queueBind(int ticket, String queue, String exchange, String
551551
* @see com.rabbitmq.client.AMQP.Queue.Unbind
552552
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
553553
*/
554-
public Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey,
554+
public Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey,
555555
Map<String, Object> arguments)
556556
throws IOException
557557
{
558558
return (Queue.UnbindOk)
559-
exnWrappingRpc(new Queue.Unbind(queue, exchange, routingKey,
560-
arguments, false)).getMethod();
559+
exnWrappingRpc(new Queue.Unbind(ticket, queue, exchange, routingKey,
560+
arguments)).getMethod();
561561
}
562562

563563
/**
564564
* Public API - Unbind a queue from an exchange, with no extra arguments.
565565
* @see com.rabbitmq.client.AMQP.Queue.Unbind
566566
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
567567
*/
568-
public Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey)
568+
public Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey)
569569
throws IOException
570570
{
571-
return queueUnbind(queue, exchange, routingKey, null);
571+
return queueUnbind(ticket, queue, exchange, routingKey, null);
572572
}
573573

574574
/**

test/src/com/rabbitmq/client/test/functional/Routing.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ public void testUnbind() throws Exception {
132132
channel.basicPublish(ticket, x, routingKey, null, "foobar".getBytes());
133133
checkGet(queue, true);
134134

135-
channel.queueUnbind(queue, x, routingKey);
135+
channel.queueUnbind(ticket, queue, x, routingKey);
136136

137137
channel.basicPublish(ticket, x, routingKey, null, "foobar".getBytes());
138138
checkGet(queue, false);

0 commit comments

Comments
 (0)