I tried to run RabbitMQ Java Client Tool PerfTest and publish to a durable exchange and got the errors below. Looks like the exchange has to be non-durable for running PerfTest tool? Please advice:
runjava com.rabbitmq.examples.PerfTest -z 25 -y 0 -x 1 -t topic -e topic
#0
exception: java.io.IOException
n
bitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
bitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
bitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)
bitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:693)
bitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:662)
bitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:717)
bitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:61)
bitmq.examples.perf.MulticastParams.configureQueue(MulticastParams.java:210)
bitmq.examples.perf.MulticastParams.createConsumer(MulticastParams.java:195)
bitmq.examples.perf.MulticastSet.run(MulticastSet.java:57)
bitmq.examples.PerfTest.main(PerfTest.java:117)
bitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAIL
arg 'durable' for exchange 'topic' in vhost '/': received 'false' but current is 'true', class-id=40, method-id=10)
bitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
bitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
bitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:348)
bitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:221)
bitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
bitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAIL
arg 'durable' for exchange 'topic' in vhost '/': received 'false' but current is 'true', class-id=40, method-id=10)
bitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:478)
bitmq.client.impl.ChannelN.processAsync(ChannelN.java:315)
bitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)
bitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)
bitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:552)
ng.Thread.run(Unknown Source)