|
29 | 29 | // Contributor(s): ______________________________________. |
30 | 30 | // |
31 | 31 |
|
32 | | -package com.rabbitmq.client.test.server; |
| 32 | +package com.rabbitmq.client.test.functional; |
33 | 33 |
|
34 | 34 | import java.io.IOException; |
35 | 35 |
|
36 | 36 | import com.rabbitmq.client.ShutdownSignalException; |
37 | 37 | import com.rabbitmq.client.test.BrokerTestCase; |
38 | 38 |
|
39 | 39 | public class ExchangeDeleteIfUnused extends BrokerTestCase { |
40 | | - private final static String ExchangeName = "xchg1"; |
41 | | - private final static String QueueName = "myQueue"; |
42 | | - private final static String RoutingKey = "something"; |
| 40 | + private final static String EXCHANGE_NAME = "xchg1"; |
| 41 | + private final static String ROUTING_KEY = "something"; |
43 | 42 |
|
44 | 43 | protected void createResources() |
45 | 44 | throws IOException |
46 | 45 | { |
47 | 46 | super.createResources(); |
48 | | - channel.exchangeDeclare(ExchangeName, "direct"); |
49 | | - channel.queueDeclare(QueueName); |
50 | | - channel.queueBind(QueueName, ExchangeName, RoutingKey); |
| 47 | + channel.exchangeDeclare(EXCHANGE_NAME, "direct"); |
| 48 | + String queueName = channel.queueDeclare().getQueue(); |
| 49 | + channel.queueBind(queueName, EXCHANGE_NAME, ROUTING_KEY); |
51 | 50 | } |
52 | 51 |
|
53 | 52 | protected void releaseResources() |
54 | 53 | throws IOException |
55 | 54 | { |
56 | | - channel.queueDelete(QueueName); |
57 | | - channel.exchangeDelete(ExchangeName); |
| 55 | + channel.exchangeDelete(EXCHANGE_NAME); |
58 | 56 | super.releaseResources(); |
59 | 57 | } |
60 | 58 |
|
61 | 59 | public void testExchangeDelete() { |
62 | 60 | try { |
63 | 61 | // exchange.delete(ifUnused = true) |
64 | 62 | // should throw a channel exception if the exchange is being used |
65 | | - channel.exchangeDelete(ExchangeName, true); |
| 63 | + channel.exchangeDelete(EXCHANGE_NAME, true); |
66 | 64 | fail("Exception expected if exchange in use"); |
67 | 65 | } catch (IOException e) { |
68 | 66 | Throwable t = e.getCause(); |
|
0 commit comments