File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
src/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -107,8 +107,7 @@ public class ChannelN extends AMQChannel implements com.rabbitmq.client.Channel
107107 * @see Connection#createChannel
108108 * @param connection The connection associated with this channel
109109 * @param channelNumber The channel number to be associated with this channel
110- * @param workPool pool in which this channel's consumer work is stored
111- * @param executor service which executes the work in the workPool
110+ * @param workService service for managing this channel's consumer callbacks
112111 */
113112 public ChannelN (AMQConnection connection , int channelNumber ,
114113 ConsumerWorkService workService ) {
@@ -651,7 +650,7 @@ public Exchange.DeleteOk exchangeDelete(String exchange)
651650 public Exchange .BindOk exchangeBind (String destination , String source ,
652651 String routingKey , Map <String , Object > arguments )
653652 throws IOException {
654- return (Exchange .BindOk )
653+ return (Exchange .BindOk )
655654 exnWrappingRpc (new Exchange .Bind .Builder ()
656655 .destination (destination )
657656 .source (source )
You can’t perform that action at this time.
0 commit comments