Skip to content

Commit c662357

Browse files
author
Alexandru Scvortov
committed
remove Channel.confirmSelect(multiple, noWait) because noWait doesn't work
1 parent c5be9d2 commit c662357

File tree

2 files changed

+2
-19
lines changed

2 files changed

+2
-19
lines changed

src/com/rabbitmq/client/Channel.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -607,17 +607,6 @@ Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, b
607607
*/
608608
Confirm.SelectOk confirmSelect(boolean multiple) throws IOException;
609609

610-
/**
611-
* Enables publisher acknowledgements on this channel.
612-
* @param many determines whether the broker can acknowledge
613-
* multiple messages at the same time
614-
* @param nowait whether to await completion of the request
615-
* @see com.rabbitmq.client.AMQP.Confirm.Select
616-
* @throws java.io.IOException if an error is encountered
617-
*/
618-
Confirm.SelectOk confirmSelect(boolean multiple, boolean nowait)
619-
throws IOException;
620-
621610
/**
622611
* Returns the number of messages published since the channel was
623612
* put in confirm mode.

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

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -823,20 +823,14 @@ public Tx.RollbackOk txRollback()
823823
/** Public API - {@inheritDoc} */
824824
public Confirm.SelectOk confirmSelect(boolean multiple)
825825
throws IOException
826-
{
827-
return confirmSelect(multiple, false);
828-
}
829-
830-
/** Public API - {@inheritDoc} */
831-
public Confirm.SelectOk confirmSelect(boolean multiple, boolean nowait)
832-
throws IOException
833826
{
834827
synchronized (_channelMutex) {
835828
if (publishedMessageCount == -1)
836829
publishedMessageCount = 0;
837830
}
838831
return (Confirm.SelectOk)
839-
exnWrappingRpc(new Confirm.Select(multiple, nowait)).getMethod();
832+
exnWrappingRpc(new Confirm.Select(multiple, false)).getMethod();
833+
840834
}
841835

842836
/** Public API - {@inheritDoc} */

0 commit comments

Comments
 (0)