Hi Prasanna, Do you have any upgrade ? have you work with AmalG on this ?
Thanks ! On Thu, Oct 23, 2014 at 6:53 PM, Waruna Perera <[email protected]> wrote: > 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 > -- Sagara Gunathunga Senior Technical Lead; WSO2, Inc.; http://wso2.com V.P Apache Web Services; http://ws.apache.org/ Linkedin; http://www.linkedin.com/in/ssagara Blog ; http://ssagara.blogspot.com _______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
