Warning in standalone esb client with messaging
Hi,
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
