Hi All, I have integrate IBM MQ, Rabbit MQ with WSO2 ESB. Setup environment as below.
IBM MQ version 7.0 running on Windows 7 WSO2 ESB 4.8.0 running on Windows 7 Rabbit MQ version 3.3.4 running on Linux Message flow as below. Send SOAP message -> messageAcceptProxy -> IBM MQ (queue: ivtQ) -> AMQPProxy -> RabbitMQ (queue:queue2) Following exception occurred when message read from IBM MQ and send to the Rabbit MQ which exist in the Linux machine. NOTE: The above message flow work perfectly when Rabbit MQ in the same macine. (Windows 7) [2014-07-03 15:14:49,977] INFO - CarbonUIServiceComponent Mgt Console URL : ht tps://10.100.5.76:9443/carbon/ [2014-07-03 15:15:14,595] INFO - LogMediator STATE = message is sent to queue [2014-07-03 15:15:14,607] INFO - TimeoutHandler This engine will expire all cal lbacks after : 120 seconds, irrespective of the timeout action, after the specif ied or optional timeout [2014-07-03 15:15:14,816] INFO - LogMediator To: , WSAction: urn:mediate, SOAPA ction: urn:mediate, MessageID: ID:414d51204b50726f64514d67722020207500b553200147 02, Direction: request, Envelope: <?xml version="1.0" encoding="utf-8"?><soapenv :Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/ "><soapenv:Bod y><soapenv:Envelope xmlns:xsd="http://samples.esb.wso2.org/xsd"; xmlns:sam="http: //samples.esb.wso2.org"><soapenv:Body> <sam:credit> <sam:info> <xsd:amount>100</xsd:amount> <xsd:personInfo> <xsd:address>Colomobo</xsd:address> <xsd:id>1</xsd:id> <xsd:name>Indika Sampath</xsd:name> </xsd:personInfo> </sam:info> </sam:credit> </soapenv:Body></soapenv:Envelope></soapenv:Body></soapenv:Envelope> [2014-07-03 15:15:17,995] ERROR - RabbitMQMessageSender Error while creating con nection pool 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.AMQChannel.exnWrappingRpc(AMQChannel.java:12 4) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:374) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory .java:590) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory .java:624) at org.apache.axis2.transport.rabbitmq.ConnectionFactory.getConnectionPo ol(ConnectionFactory.java:93) at org.apache.axis2.transport.rabbitmq.RabbitMQMessageSender.<init>(Rabb itMQMessageSender.java:59) at org.apache.axis2.transport.rabbitmq.RabbitMQSender.sendMessage(Rabbit MQSender.java:71) at org.apache.axis2.transport.base.AbstractTransportSender.invoke(Abstra ctTransportSender.java:112) at org.apache.axis2.engine.AxisEngine$TransportNonBlockingInvocationWork er.run(AxisEngine.java:626) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:908) at java.lang.Thread.run(Thread.java:662) 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.AMQChannel.privateRpc(AMQChannel.java:216) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:11 8) ... 11 more Caused by: java.net.SocketException: Connection reset at java.net.SocketInputStream.read(SocketInputStream.java:168) at java.io.BufferedInputStream.fill(BufferedInputStream.java:218) at java.io.BufferedInputStream.read(BufferedInputStream.java:237) at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:271) at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHand ler.java:139) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.jav a:532) ... 1 more [2014-07-03 15:15:18,005] INFO - AxisEngine [MessageContext: logID=f12b7a2e7c2c 9fe17bd3652d34dcbf4c69cafb19d5e9ae47] Error while creating connection pool [2014-07-03 15:15:18,007] ERROR - AsyncCallback Error while creating connection pool org.apache.axis2.transport.rabbitmq.AxisRabbitMQException: Error while creating connection pool at org.apache.axis2.transport.rabbitmq.RabbitMQMessageSender.handleExcep tion(RabbitMQMessageSender.java:311) at org.apache.axis2.transport.rabbitmq.RabbitMQMessageSender.<init>(Rabb itMQMessageSender.java:61) at org.apache.axis2.transport.rabbitmq.RabbitMQSender.sendMessage(Rabbit MQSender.java:71) at org.apache.axis2.transport.base.AbstractTransportSender.invoke(Abstra ctTransportSender.java:112) at org.apache.axis2.engine.AxisEngine$TransportNonBlockingInvocationWork er.run(AxisEngine.java:626) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:908) at java.lang.Thread.run(Thread.java:662) Caused by: 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.AMQChannel.exnWrappingRpc(AMQChannel.java:12 4) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:374) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory .java:590) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory .java:624) at org.apache.axis2.transport.rabbitmq.ConnectionFactory.getConnectionPo ol(ConnectionFactory.java:93) at org.apache.axis2.transport.rabbitmq.RabbitMQMessageSender.<init>(Rabb itMQMessageSender.java:59) ... 6 more 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.AMQChannel.privateRpc(AMQChannel.java:216) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:11 8) ... 11 more Caused by: java.net.SocketException: Connection reset at java.net.SocketInputStream.read(SocketInputStream.java:168) at java.io.BufferedInputStream.fill(BufferedInputStream.java:218) at java.io.BufferedInputStream.read(BufferedInputStream.java:237) at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:271) at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHand ler.java:139) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.jav a:532) ... 1 more [2014-07-03 15:15:18,018] WARN - AsyncCallback Executing fault handler due to e xception encountered [2014-07-03 15:15:18,021] WARN - EndpointContext Endpoint : AnonymousEndpoint w ill be marked SUSPENDED as it failed [2014-07-03 15:15:18,022] WARN - EndpointContext Suspending endpoint : Anonymou sEndpoint - current suspend duration is : 30000ms - Next retry after : Thu Jul 0 3 15:15:48 IST 2014 Can we sort out this issue ? Cheers! -- Indika Sampath Software Engineer WSO2 Inc. http://wso2.com Phone: +94 716 424 744 Blog: http://indikasampath.blogspot.com/
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
