Warning in standalone esb client with messaging
claudio_br Jun 21, 2007 12:57 PMHi,
I have created a standalone esb client with messaging.
My client run normally, but I got this warning in jboss console:
13:43:51,546 WARN [BisocketClientInvoker] Unable to send ping: shutting down PingTimerTask java.net.SocketException: Connection reset by peer: socket write error at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92) at java.net.SocketOutputStream.write(SocketOutputStream.java:115) at org.jboss.remoting.transport.bisocket.BisocketClientInvoker$PingTimerTask.run(BisocketClientInvoker.java:497) at java.util.TimerThread.mainLoop(Timer.java:512) at java.util.TimerThread.run(Timer.java:462) 13:44:26,375 WARN [SimpleConnectionManager] ConnectionManager[1c3c6d8] cannot look up remoting session ID 5c4ok4j-i4a259-f37grfrb-1-f37grg9z-4 13:44:26,562 WARN [SimpleConnectionManager] A problem has been detected with the connection to remote client 5c4ok4j-i4a259-f37grfrb-1-f37grg9z-4. It is possible the client has exited without closing its connection(s) or there is a network problem. All connection resources corresponding to that client process will now be removed.
This warning doesn´t occurs with jbossmq.
In my classpath I have:
commons-logging.jar javassist.jar jaxr-api-1.0-SNAPSHOT.jar jbossall-client.jar jboss-aop-jdk50.jar jbossesb-listeners.jar jbossesb-registry.jar jbossesb-rosetta.jar jbossesb-services.jar jboss-messaging.jar jbossts-common.jar juddi-client-1.0-SNAPSHOT.jar log4j.jar scout-1.0-SNAPSHOT.jar stax-api-1.0.1.jar trove.jar xbean.jar xercesImpl.jar
My client code:
package com; import org.jboss.soa.esb.listeners.message.MessageDeliveryAdapter; import org.jboss.soa.esb.message.Message; import org.jboss.soa.esb.message.format.MessageFactory; import org.jboss.soa.esb.message.format.MessageType; public class TestePipeline { public static void main(String[] args) throws Exception{ MessageDeliveryAdapter deliveryAdapter = new MessageDeliveryAdapter("Cat","Serv"); MessageFactory mfactory = MessageFactory.getInstance(); Message requestMessage; Message replyMessage = null; // Create and populate the request message... requestMessage = mfactory.getMessage(MessageType.JBOSS_XML); String teste = "testando..."; requestMessage.getBody().setContents(teste.getBytes()); replyMessage = deliveryAdapter.deliverSync(requestMessage, 5000); String resp = new String(replyMessage.getBody().getContents()); System.out.println(resp); } }
Did I miss anything?
Thanks