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
