[rabbitmq-discuss] Consistent hashing exchange
Vikram Viswanathan
vikram.vis at gmail.com
Thu Jan 23 18:43:02 GMT 2014
Is Consistent hashing exchange supported by RabbitMq java Client API ? I
tried with Java Client 3.2.2/server 3.2.2 and I get this error
Caused by: com.rabbitmq.client.ShutdownSignalException: connection
error; reason: {#method<connection.close>(reply-code=503,
reply-text=COMMAND_INVALID - unknown exchange type 'x-consistent-hash',
class-id=40, method-id=10), null, ""}
at
com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
at
com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
at
com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
at
com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
... 5 more
API used,
channel1.exchangeDeclare("masterExcg", "x-consistent-hash", false);
The server has been enabled with "rabbitmq_consistent_hash_exchange"
plugin.
Thanks in advance,
-Vikram
More information about the rabbitmq-discuss
mailing list