[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