|
17 | 17 |
|
18 | 18 | package com.rabbitmq.client.impl; |
19 | 19 |
|
20 | | -import com.rabbitmq.client.ConfirmListener; |
21 | | -import com.rabbitmq.client.AMQP.BasicProperties; |
| 20 | +import java.io.IOException; |
| 21 | +import java.util.Collections; |
| 22 | +import java.util.HashMap; |
| 23 | +import java.util.Map; |
| 24 | +import java.util.concurrent.TimeoutException; |
| 25 | + |
22 | 26 | import com.rabbitmq.client.AMQP; |
23 | 27 | import com.rabbitmq.client.Command; |
| 28 | +import com.rabbitmq.client.ConfirmListener; |
24 | 29 | import com.rabbitmq.client.Connection; |
25 | 30 | import com.rabbitmq.client.Consumer; |
26 | | -import com.rabbitmq.client.ConsumerCancellationListener; |
27 | 31 | import com.rabbitmq.client.Envelope; |
28 | 32 | import com.rabbitmq.client.FlowListener; |
29 | 33 | import com.rabbitmq.client.GetResponse; |
30 | 34 | import com.rabbitmq.client.MessageProperties; |
31 | 35 | import com.rabbitmq.client.ReturnListener; |
32 | 36 | import com.rabbitmq.client.ShutdownSignalException; |
33 | 37 | import com.rabbitmq.client.UnexpectedMethodError; |
| 38 | +import com.rabbitmq.client.AMQP.BasicProperties; |
34 | 39 | import com.rabbitmq.client.impl.AMQImpl.Basic; |
35 | 40 | import com.rabbitmq.client.impl.AMQImpl.Channel; |
36 | 41 | import com.rabbitmq.client.impl.AMQImpl.Confirm; |
|
39 | 44 | import com.rabbitmq.client.impl.AMQImpl.Tx; |
40 | 45 | import com.rabbitmq.utility.Utility; |
41 | 46 |
|
42 | | -import java.io.IOException; |
43 | | -import java.util.Collections; |
44 | | -import java.util.HashMap; |
45 | | -import java.util.Map; |
46 | | -import java.util.concurrent.TimeoutException; |
47 | | - |
48 | 47 |
|
49 | 48 | /** |
50 | 49 | * Main interface to AMQP protocol functionality. Public API - |
|
0 commit comments