Hello again, Last time I contacted the list I was having issues with the basic sending and receiving of AMQP messages to/from HornetQ. I have got quite a bit further by myself (+ docs & e.g.s) but am sorry to say that I am stumped again...
I have got HornetQ and the Qpid Proton examples configured and working with proton-api-0.4.jar, proton-j-impl-0.4.jar and proton-jms-0.4.jar. I have also set up a divert with a filter such that some messages are diverted from one queue to another. It all works fine... Unfortunately, the Qpid Proton library versions that I am using have a connection timeout hard-coded at 60 seconds (if I understand correctly). I believe this relates to https://developer.jboss.org/thread/233539?start=0&tstart=0 [How to set AMQP idle-timeout / ping frequency / TTL?] As I understand it, upgrading to proton-j-0.10.jar and proton-jms-0.10.jar should fix this issue by letting you specify the timeout. However, with the new jars, when trying to send/receive the message I am getting the error at the end of the message (below). I realise that this topic bridges Qpid and HornetQ (unfortunately). I can confirm that HornetQ does support SASL and my config should be sufficient (indeed, it worked before the upgrade). From the HornetQ manual: "The HornetQ Server accepts AMQP SASL Authentication and will use this to map onto the underlying session created for the connection so you can use the normal HornetQ security configuration." Does anyone have an idea what may be going on? I have tried reading the documentation, wiki, e.t.c. (have spent about a day on this so far). Thanks & regards, Matthew Oct 27, 2015 2:48:47 PM org.apache.qpid.proton.driver.impl.ConnectorImpl read SEVERE: ConnectorImpl [_channel=java.nio.channels.SocketChannel[connected local=/127.0.0.1:52583 remote=localhost/127.0.0.1:5672]] error processing input org.apache.qpid.proton.engine.TransportException: unknown frame type: 0 at org.apache.qpid.proton.engine.impl.SaslFrameParser.input(SaslFrameParser.java:183) at org.apache.qpid.proton.engine.impl.SaslImpl$SaslTransportWrapper.reallyProcessInput(SaslImpl.java:630) at org.apache.qpid.proton.engine.impl.SaslImpl$SaslTransportWrapper.process(SaslImpl.java:601) at org.apache.qpid.proton.engine.impl.HandshakeSniffingTransportWrapper.process(HandshakeSniffingTransportWrapper.java:101) at org.apache.qpid.proton.engine.impl.TransportImpl.process(TransportImpl.java:1415) at org.apache.qpid.proton.driver.impl.ConnectorImpl.read(ConnectorImpl.java:135) at org.apache.qpid.proton.driver.impl.ConnectorImpl.process(ConnectorImpl.java:94) at org.apache.qpid.proton.messenger.impl.MessengerImpl.processActive(MessengerImpl.java:738) at org.apache.qpid.proton.messenger.impl.MessengerImpl.waitUntil(MessengerImpl.java:890) at org.apache.qpid.proton.messenger.impl.MessengerImpl.waitUntil(MessengerImpl.java:839) at org.apache.qpid.proton.messenger.impl.MessengerImpl.send(MessengerImpl.java:417) at org.apache.qpid.proton.messenger.impl.MessengerImpl.send(MessengerImpl.java:394) at qpid.SendOld.run(SendOld.java:93) at qpid.SendOld.main(SendOld.java:56) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
