Hi Prasanna, Please update the thread with solution you found.
Thanks On Fri, Oct 17, 2014 at 10:30 PM, Udara Rathnayake <[email protected]> wrote: > Hi Prasanna, > > Seems there is AMQP version mismatch. ActiveMQ is AMQP 1.0 implementation. > But Im not sure about 1.0 support from RabbitMQ side. > > On Fri, Oct 17, 2014 at 6:13 AM, Prasanna Dangalla <[email protected]> > wrote: > >> Hi Waruna, >> >> In activemq 5.10.0 console log the error says as follows >> >> INFO | Listening for connections at >> ws://prasa-ubuntu:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600 >> INFO | Connector ws started >> INFO | Apache ActiveMQ 5.10.0 (localhost, >> ID:prasa-ubuntu-39398-1413539625377-0:1) started >> INFO | For help or more information please see: >> http://activemq.apache.org >> INFO | ActiveMQ WebConsole available at http://0.0.0.0:8161/ >> INFO | Initializing Spring FrameworkServlet 'dispatcher' >> INFO | jolokia-agent: No access restrictor found at >> classpath:/jolokia-access.xml, access to all MBeans is allowed >> org.apache.activemq.transport.amqp.AmqpProtocolException: Could not >> decode AMQP frame: hex: 414d515000000901 >> at >> org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:233) >> at >> org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:224) >> at >> org.apache.activemq.transport.amqp.AMQPProtocolDiscriminator.onAMQPData(AMQPProtocolDiscriminator.java:89) >> at >> org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:98) >> at >> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) >> at >> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) >> at >> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) >> at java.lang.Thread.run(Thread.java:662) >> Caused by: org.apache.qpid.proton.engine.TransportException: >> org.apache.qpid.proton.engine.TransportException: AMQP header mismatch >> value 0, expecting 1. In state: HEADER5 >> at >> org.apache.qpid.proton.engine.TransportResultFactory$TransportResultImpl.checkIsOk(TransportResultFactory.java:116) >> at >> org.apache.qpid.proton.engine.impl.TransportImpl.input(TransportImpl.java:220) >> at >> org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:230) >> ... 7 more >> Caused by: org.apache.qpid.proton.engine.TransportException: AMQP header >> mismatch value 0, expecting 1. In state: HEADER5 >> at >> org.apache.qpid.proton.engine.impl.FrameParser.input(FrameParser.java:202) >> at >> org.apache.qpid.proton.engine.impl.FrameParser.process(FrameParser.java:502) >> at >> org.apache.qpid.proton.engine.impl.TransportImpl.process(TransportImpl.java:1265) >> at >> org.apache.qpid.proton.engine.impl.TransportImpl.processInput(TransportImpl.java:1226) >> ... 9 more >> >> >> In client side the error says as follows >> >> Exception in thread "main" java.io.IOException >> at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) >> at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) >> at >> com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:346) >> at >> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:590) >> at >> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:612) >> at Cache.main(Cache.java:15) >> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >> at >> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) >> at java.lang.reflect.Method.invoke(Method.java:597) >> at >> com.intellij.rt.execution.application.AppMain.main(AppMain.java:120) >> Caused by: com.rabbitmq.client.ShutdownSignalException: connection error >> 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.AMQConnection.start(AMQConnection.java:292) >> ... 8 more >> Caused by: java.io.EOFException >> at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:273) >> at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) >> at >> com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139) >> at >> com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532) >> at java.lang.Thread.run(Thread.java:662) >> >> >> Thanks >> >> On Fri, Oct 17, 2014 at 3:02 PM, Waruna Perera <[email protected]> wrote: >> >>> Hi Prasanna, >>> >>> Please post the connection error trace. >>> >>> Thanks! >>> >>> On Fri, Oct 17, 2014 at 2:54 PM, Prasanna Dangalla <[email protected]> >>> wrote: >>> >>>> Hi Waruna >>>> >>>> Yes, I put the amqp-client-3.0.3.jar to repository/components/lib in >>>> greg to test it in greg and to test it in my sample client I put the maven >>>> dependency as follows in the pom file >>>> >>>> <dependency> >>>> <groupId>com.rabbitmq</groupId> >>>> <artifactId>amqp-client</artifactId> >>>> <version>3.3.5</version> >>>> </dependency> >>>> >>>> >>>> >>>> On Fri, Oct 17, 2014 at 2:48 PM, Waruna Perera <[email protected]> >>>> wrote: >>>> >>>>> Hi Prasanna, >>>>> >>>>> Did you put any client libraries of activemq server in side amqp >>>>> cleint class path? >>>>> >>>>> Thanks >>>>> >>>>> On Fri, Oct 17, 2014 at 2:45 PM, Prasanna Dangalla <[email protected]> >>>>> wrote: >>>>> >>>>>> Sorry the $subject should be as follows >>>>>> Amqp client not connecting to activemq server. >>>>>> >>>>>> >>>>>> On Fri, Oct 17, 2014 at 2:31 PM, Prasanna Dangalla <[email protected] >>>>>> > wrote: >>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> I'm trying connect from a amqp client to a aqtivemq server with >>>>>>> default settings to test cache Invalidation in greg. It always gives the >>>>>>> error message saying connection refused, I wrote a sample client using >>>>>>> the >>>>>>> rabbitmq client library. It to doesn't work with activemq server too. >>>>>>> But >>>>>>> it works in AmalG's lap. Both laps having the same ubuntu versions, >>>>>>> activemq server versions and rabbitmq client versions. Then I tried it >>>>>>> with >>>>>>> a rabbitmq server instead of a activemq server and it works fine. I >>>>>>> wonder >>>>>>> whether activemq needs a linux library to communicate. >>>>>>> >>>>>>> Activemq server versions used which does not connects: 5.4.2 / 5.10.0 >>>>>>> Rabitmq version used: 3.3.5 >>>>>>> >>>>>>> rabitmq sample client code >>>>>>> >>>>>>> import com.rabbitmq.client.ConnectionFactory; >>>>>>> import com.rabbitmq.client.Connection; >>>>>>> import com.rabbitmq.client.Channel; >>>>>>> >>>>>>> public class Cache { >>>>>>> private final static String QUEUE_NAME = "hello"; >>>>>>> >>>>>>> public static void main(String[] argv) >>>>>>> throws java.io.IOException { >>>>>>> >>>>>>> //creating the connection factory >>>>>>> ConnectionFactory factory = new ConnectionFactory(); >>>>>>> factory.setHost("localhost"); >>>>>>> >>>>>>> //Creating a connection to the server >>>>>>> Connection connection = factory.newConnection(); >>>>>>> Channel channel = connection.createChannel(); >>>>>>> >>>>>>> //declaring a queuw >>>>>>> channel.queueDeclare(QUEUE_NAME, false, false, false, null); >>>>>>> String message = "Hello World!"; >>>>>>> >>>>>>> //publishing the queue the queue >>>>>>> channel.basicPublish("", QUEUE_NAME, null, >>>>>>> message.getBytes()); >>>>>>> System.out.println(" [x] Sent '" + message + "'"); >>>>>>> >>>>>>> //closing the connection >>>>>>> channel.close(); >>>>>>> connection.close(); >>>>>>> } >>>>>>> } >>>>>>> >>>>>>> >>>>>>> Fails in the following line of code >>>>>>> //Creating a connection to the server >>>>>>> Connection connection = factory.newConnection(); >>>>>>> >>>>>>> Thanks >>>>>>> >>>>>>> Prasanna Dangalla >>>>>>> Software Engineer, WSO2, Inc.; http://wso2.com/ >>>>>>> lean.enterprise.middleware >>>>>>> >>>>>>> cell: +94 777 55 80 30 | +94 718 11 27 51 >>>>>>> twitter: @prasa77 >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Prasanna Dangalla >>>>>> Software Engineer, WSO2, Inc.; http://wso2.com/ >>>>>> lean.enterprise.middleware >>>>>> >>>>>> cell: +94 777 55 80 30 | +94 718 11 27 51 >>>>>> twitter: @prasa77 >>>>>> >>>>>> _______________________________________________ >>>>>> Dev mailing list >>>>>> [email protected] >>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>>> >>>>>> >>>>> >>>>> >>>>> -- >>>>> Waruna Perera >>>>> Senior Software Engineer - Test Automation >>>>> Mobile: +94 77 3867037 >>>>> WSO2, Inc.; http://wso2.com/ >>>>> lean . enterprise . middlewear. >>>>> >>>> >>>> >>>> >>>> -- >>>> Prasanna Dangalla >>>> Software Engineer, WSO2, Inc.; http://wso2.com/ >>>> lean.enterprise.middleware >>>> >>>> cell: +94 777 55 80 30 | +94 718 11 27 51 >>>> twitter: @prasa77 >>>> >>> >>> >>> >>> -- >>> Waruna Perera >>> Senior Software Engineer - Test Automation >>> Mobile: +94 77 3867037 >>> WSO2, Inc.; http://wso2.com/ >>> lean . enterprise . middlewear. >>> >> >> >> >> -- >> Prasanna Dangalla >> Software Engineer, WSO2, Inc.; http://wso2.com/ >> lean.enterprise.middleware >> >> cell: +94 777 55 80 30 | +94 718 11 27 51 >> twitter: @prasa77 >> >> _______________________________________________ >> Dev mailing list >> [email protected] >> http://wso2.org/cgi-bin/mailman/listinfo/dev >> >> > > > -- > *Udara Rathnayake* > Software Engineer > WSO2 Inc. : http://wso2.com > > Mobile : 1 4087864651 > Twitter : http://twitter.com/udarakr > Blog : http://udarakr.blogspot.com > > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > > -- Waruna Perera Senior Software Engineer - Test Automation Mobile: +94 77 3867037 WSO2, Inc.; http://wso2.com/ lean . enterprise . middlewear.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
