I try to create a durable JMS topic subscription to a RabbitMQ V3.5 server using Qpid-client V0.32 library. On my client side I receive an exception:
17:04:42 INFO Connection exception caught therefore going to attempt failover: java.net.SocketException: Connection reset
java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:196)
at java.net.SocketInputStream.read(SocketInputStream.java:122)
at org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:156)
at java.lang.Thread.run(Thread.java:745)
17:04:42 INFO No Waiters for error. Saving as last error:Exception thrown against AMQConnection:
Host: functional
Port: 5672
Virtual Host:
Client ID: KaiH.sqr2eqa
Active session count: 1: org.apache.qpid.AMQDisconnectedException: Server closed connection and reconnection not permitted.
=CRASH REPORT==== 18-Jun-2015::17:04:20 ===
crasher:
initial call: rabbit_reader:init/2
pid: <0.1739.7>
registered_name: []
exception exit: {unknown_method_id,{40,22}}
in function rabbit_framing_amqp_0_9_1:lookup_method_name/1
in call from rabbit_command_assembler:analyze_frame/3
in call from rabbit_reader:handle_frame/4
in call from rabbit_reader:handle_input/3
in call from rabbit_reader:recvloop/4
in call from rabbit_reader:run/1
in call from rabbit_reader:start_connection/5
ancestors: [<0.1737.7>,rabbit_tcp_client_sup,rabbit_sup,<0.146.0>]
messages: [{'EXIT',#Port<0.116904>,normal}]
links: [<0.1737.7>]
dictionary: [{{channel,1},
{<0.1747.7>,{method,rabbit_framing_amqp_0_9_1}}},
{process_name,
{rabbit_reader,
{{ch_pid,<0.1747.7>},{1,#Ref<0.0.15.8937>}}]
trap_exit: true
status: running
heap_size: 2586
stack_size: 27
reductions: 3724
neighbours:
Or do you know a workaround to get a durable topic subscription endpoint in camel with RabbitMQ?