Author: sumedha Date: Mon Nov 3 02:06:10 2008 New Revision: 710032 URL: http://svn.apache.org/viewvc?rev=710032&view=rev Log: moved xmpp connection retrival part out of if block,commented out REST check
Modified: webservices/commons/trunk/modules/transport/modules/xmpp/src/org/apache/axis2/transport/xmpp/XMPPSender.java Modified: webservices/commons/trunk/modules/transport/modules/xmpp/src/org/apache/axis2/transport/xmpp/XMPPSender.java URL: http://svn.apache.org/viewvc/webservices/commons/trunk/modules/transport/modules/xmpp/src/org/apache/axis2/transport/xmpp/XMPPSender.java?rev=710032&r1=710031&r2=710032&view=diff ============================================================================== --- webservices/commons/trunk/modules/transport/modules/xmpp/src/org/apache/axis2/transport/xmpp/XMPPSender.java (original) +++ webservices/commons/trunk/modules/transport/modules/xmpp/src/org/apache/axis2/transport/xmpp/XMPPSender.java Mon Nov 3 02:06:10 2008 @@ -145,13 +145,12 @@ msgCtx.getProperty(Constants.OUT_TRANSPORT_INFO); } - + xmppConnection = xmppOutTransportInfo.getConnectionFactory().getXmppConnection(); + if(msgCtx.isServerSide()){ - xmppConnection = xmppOutTransportInfo.getConnectionFactory().getXmppConnection(); message.setProperty(XMPPConstants.IS_SERVER_SIDE, new Boolean(false)); message.setProperty(XMPPConstants.IN_REPLY_TO, xmppOutTransportInfo.getInReplyTo()); - }else{ - xmppConnection = xmppOutTransportInfo.getConnectionFactory().getXmppConnection(); + }else{ message.setProperty(XMPPConstants.IS_SERVER_SIDE,new Boolean(true)); message.setProperty(XMPPConstants.SERVICE_NAME, serviceName); String action = options.getAction(); @@ -176,9 +175,9 @@ try { OMElement msgElement = msgCtx.getEnvelope(); - if (msgCtx.isDoingREST()) { - msgElement = msgCtx.getEnvelope().getBody().getFirstElement(); - } + //if (msgCtx.isDoingREST()) { + // msgElement = msgCtx.getEnvelope().getBody().getFirstElement(); + //} boolean waitForResponse = msgCtx.getOperationContext() != null && WSDL2Constants.MEP_URI_OUT_IN.equals( @@ -203,6 +202,7 @@ //If this is on client side, wait for the response from server. //Is this the best way to do this? if(waitForResponse && !msgCtx.isServerSide()){ + //TODO : need to add a timeout while(! xmppClientSidePacketListener.isResponseReceived()){ try { Thread.sleep(1000);