We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3156fec commit 1c1885eCopy full SHA for 1c1885e
test/src/com/rabbitmq/examples/ProducerMain.java
@@ -153,6 +153,12 @@ private void runIt() throws IOException {
153
String queueName = "test queue";
154
String exchangeName = "test exchange";
155
156
+ String testQueueName = "test queue";
157
+ _channel.queueDeclare(testQueueName, true);
158
+
159
+ String testExchangeName = "test exchange";
160
+ _channel.exchangeDeclare(testExchangeName, "fanout", true);
161
162
if (shouldCommit()) {
163
_channel.txSelect();
164
}
0 commit comments