Skip to content

Commit 21acba9

Browse files
committed
Alter signatures to the latest 0-91 draft XML
1 parent df76b21 commit 21acba9

File tree

3 files changed

+10
-12
lines changed

3 files changed

+10
-12
lines changed

src/com/rabbitmq/client/Channel.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -320,31 +320,29 @@ Queue.DeclareOk queueDeclare(int ticket, String queue, boolean passive, boolean
320320
Queue.BindOk queueBind(int ticket, String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
321321

322322
/**
323-
* Uninds a queue from an exchange, with no extra arguments.
323+
* 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
327326
* @param queue the name of the queue
328327
* @param exchange the name of the exchange
329328
* @param routingKey the routine key to use for the binding
330329
* @return an unbinding-confirm method if the binding was successfully deleted
331330
* @throws java.io.IOException if an error is encountered
332331
*/
333-
Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey) throws IOException;
332+
Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey) throws IOException;
334333

335334
/**
336335
* Unbind a queue from an exchange.
337336
* @see com.rabbitmq.client.AMQP.Queue.Unbind
338337
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
339-
* @param ticket an access ticket for the appropriate realm
340338
* @param queue the name of the queue
341339
* @param exchange the name of the exchange
342340
* @param routingKey the routine key to use for the binding
343341
* @param arguments other properties (binding parameters)
344342
* @return an unbinding-confirm method if the binding was successfully deleted
345343
* @throws java.io.IOException if an error is encountered
346344
*/
347-
Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
345+
Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;
348346

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

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -540,13 +540,13 @@ public Queue.BindOk queueBind(int ticket, String queue, String exchange,
540540
* @see com.rabbitmq.client.AMQP.Queue.Unbind
541541
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
542542
*/
543-
public Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange,
544-
String routingKey, Map<String, Object> arguments)
543+
public Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey,
544+
Map<String, Object> arguments)
545545
throws IOException
546546
{
547547
return (Queue.UnbindOk)
548-
exnWrappingRpc(new Queue.Unbind(ticket, queue, exchange, routingKey,
549-
arguments)).getMethod();
548+
exnWrappingRpc(new Queue.Unbind(queue, exchange, routingKey,
549+
arguments, false)).getMethod();
550550
}
551551

552552
/**
@@ -565,10 +565,10 @@ public Queue.BindOk queueBind(int ticket, String queue, String exchange, String
565565
* @see com.rabbitmq.client.AMQP.Queue.Unbind
566566
* @see com.rabbitmq.client.AMQP.Queue.UnbindOk
567567
*/
568-
public Queue.UnbindOk queueUnbind(int ticket, String queue, String exchange, String routingKey)
568+
public Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey)
569569
throws IOException
570570
{
571-
return queueUnbind(ticket, queue, exchange, routingKey, null);
571+
return queueUnbind(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(ticket, queue, x, routingKey);
135+
channel.queueUnbind(queue, x, routingKey);
136136

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

0 commit comments

Comments
 (0)