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
