axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sume...@apache.org
Subject svn commit: r629402 - in /webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp: ./ util/
Date Wed, 20 Feb 2008 10:04:45 GMT
Author: sumedha
Date: Wed Feb 20 02:04:32 2008
New Revision: 629402

URL: http://svn.apache.org/viewvc?rev=629402&view=rev
Log:
xmpp transport for axis2.More information can be found @ http://people.apache.org/~sumedha/xmpp-transport.html

Added:
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPListener.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPSender.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPClientSidePacketListener.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConstants.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPOutTransportInfo.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPPacketListener.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPServerCredentials.java
    webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPUtils.java

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPListener.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPListener.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPListener.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,195 @@
+/*
+* Copyright 2004,2005 The Apache Software Foundation.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*      http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+package org.apache.axis2.transport.xmpp;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.SessionContext;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ParameterIncludeImpl;
+import org.apache.axis2.description.TransportInDescription;
+import org.apache.axis2.transport.TransportListener;
+import org.apache.axis2.transport.xmpp.util.XMPPConnectionFactory;
+import org.apache.axis2.transport.xmpp.util.XMPPConstants;
+import org.apache.axis2.transport.xmpp.util.XMPPPacketListener;
+import org.apache.axis2.transport.xmpp.util.XMPPServerCredentials;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jivesoftware.smack.XMPPConnection;
+
+import edu.emory.mathcs.backport.java.util.concurrent.ExecutorService;
+import edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue;
+import edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor;
+import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
+
+
+public class XMPPListener implements TransportListener {
+    private Log log = null;
+    private ConfigurationContext configurationContext = null;
+    private String replyTo = "";
+
+    /**
+     * A Map containing the connection factories managed by this, 
+     * keyed by userName-at-jabberServerURL
+     */
+    private Map connectionFactories = new HashMap();
+    private ExecutorService workerPool;
+    private static final int WORKERS_MAX_THREADS = 5;
+    private static final long WORKER_KEEP_ALIVE = 60L;
+    private static final TimeUnit TIME_UNIT = TimeUnit.SECONDS;
+    private XMPPConnection xmppConnection = null;
+
+
+    
+    public XMPPListener() {
+    	log = LogFactory.getLog(XMPPListener.class);
+	}
+
+	/**
+     * Initializing the XMPPListener. Retrieve connection details provided in
+     * xmpp transport receiver, connect to those servers & start listening in
+     * for messages.
+     */
+    public void init(ConfigurationContext configurationCtx, TransportInDescription transportIn)
+            throws AxisFault {
+    	log.info("Initializing XMPPListener...");
+        configurationContext = configurationCtx;
+        initializeConnectionFactories(configurationContext,transportIn);
+        if (connectionFactories.isEmpty()) {
+            log.warn("No XMPP connection factories defined." +
+                     "Will not listen for any XMPP messages");
+            return;
+        }
+    }    
+   
+    /**
+     * Extract connection details & connect to those xmpp servers.
+     * @see init(ConfigurationContext configurationCtx, TransportInDescription transportIn)
+     * @param configurationContext
+     * @param transportIn
+     */
+    private void initializeConnectionFactories(
+			ConfigurationContext configurationContext,
+			TransportInDescription transportIn) throws AxisFault{
+    	
+        Iterator serversToListenOn = transportIn.getParameters().iterator();
+        while (serversToListenOn.hasNext()) {
+            Parameter connection = (Parameter) serversToListenOn.next();
+            log.info("Trying to establish connection for : "+connection.getName());
+            ParameterIncludeImpl pi = new ParameterIncludeImpl();
+            try {
+                pi.deserializeParameters((OMElement) connection.getValue());
+            } catch (AxisFault axisFault) {
+                log.error("Error reading parameters");
+            }
+
+            Iterator params = pi.getParameters().iterator();
+            XMPPServerCredentials serverCredentials = 
+            	new XMPPServerCredentials();
+            
+            while (params.hasNext()) {
+                Parameter param = (Parameter) params.next();
+                if(XMPPConstants.XMPP_SERVER_URL.equals(param.getName())){
+        			serverCredentials.setServerUrl((String)param.getValue());                	
+                }else if(XMPPConstants.XMPP_SERVER_USERNAME.equals(param.getName())){
+        			serverCredentials.setAccountName((String)param.getValue());                	
+                }else if(XMPPConstants.XMPP_SERVER_PASSWORD.equals(param.getName())){
+        			serverCredentials.setPassword((String)param.getValue());                	
+                }else if(XMPPConstants.XMPP_SERVER_TYPE.equals(param.getName())){
+        			serverCredentials.setServerType((String)param.getValue());                	
+                }
+            }
+    		XMPPConnectionFactory xmppConnectionFactory = new XMPPConnectionFactory();
+    		xmppConnectionFactory.connect(serverCredentials);
+    		
+    		connectionFactories.put(serverCredentials.getAccountName() + "@"
+    				+ serverCredentials.getServerUrl(), xmppConnectionFactory);           
+        }
+	}
+
+    /**
+     * Stop XMPP listener & disconnect from all XMPP Servers
+     */
+    public void stop() {
+        if (!workerPool.isShutdown()) {
+            workerPool.shutdown();
+        }
+        //TODO : Iterate through all connections in connectionFactories & call disconnect()
+    }
+
+    /**
+     * Returns Default EPR for a given Service name & IP
+     * @param serviceName
+     * @param ip
+     */
+    public EndpointReference getEPRForService(String serviceName, String ip) throws AxisFault
{
+        return getEPRsForService(serviceName, ip)[0];
+    }
+
+    /**
+     * Returns all EPRs for a given Service name & IP
+     * @param serviceName
+     * @param ip
+     */    
+    public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault
{
+        return new EndpointReference[]{new EndpointReference(XMPPConstants.XMPP_PREFIX +
+                replyTo + "?" + configurationContext
+                .getServiceContextPath() + "/" + serviceName)};
+    }
+
+
+    public SessionContext getSessionContext(MessageContext messageContext) {
+        return null;
+    }
+
+	public void destroy() {
+		if(xmppConnection != null && xmppConnection.isConnected()){
+			xmppConnection.disconnect();
+		}
+	}
+
+	/**
+	 * Start a pool of Workers. For each connection in connectionFactories,
+	 * assign a packer listener. This packet listener will trigger when a 
+	 * message arrives.
+	 */
+	public void start() throws AxisFault {
+        // create thread pool of workers
+       ExecutorService workerPool = new ThreadPoolExecutor(
+                1,
+                WORKERS_MAX_THREADS, WORKER_KEEP_ALIVE, TIME_UNIT,
+                new LinkedBlockingQueue(),
+                new org.apache.axis2.util.threadpool.DefaultThreadFactory(
+                        new ThreadGroup("XMPP Worker thread group"),
+                        "XMPPWorker"));
+
+        Iterator iter = connectionFactories.values().iterator();
+        while (iter.hasNext()) {
+            XMPPConnectionFactory connectionFactory = (XMPPConnectionFactory) iter.next();

+            XMPPPacketListener xmppPacketListener =
+                    new XMPPPacketListener(connectionFactory,this.configurationContext,workerPool);
+            connectionFactory.listen(xmppPacketListener);
+        }	
+	}
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPSender.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPSender.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPSender.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/XMPPSender.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,260 @@
+package org.apache.axis2.transport.xmpp;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.TransportOutDescription;
+import org.apache.axis2.description.WSDL2Constants;
+import org.apache.axis2.handlers.AbstractHandler;
+import org.apache.axis2.transport.OutTransportInfo;
+import org.apache.axis2.transport.TransportSender;
+import org.apache.axis2.transport.xmpp.util.XMPPClientSidePacketListener;
+import org.apache.axis2.transport.xmpp.util.XMPPConnectionFactory;
+import org.apache.axis2.transport.xmpp.util.XMPPConstants;
+import org.apache.axis2.transport.xmpp.util.XMPPOutTransportInfo;
+import org.apache.axis2.transport.xmpp.util.XMPPServerCredentials;
+import org.apache.axis2.transport.xmpp.util.XMPPUtils;
+import org.apache.axis2.util.Utils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jivesoftware.smack.Chat;
+import org.jivesoftware.smack.ChatManager;
+import org.jivesoftware.smack.XMPPConnection;
+import org.jivesoftware.smack.XMPPException;
+import org.jivesoftware.smack.filter.PacketFilter;
+import org.jivesoftware.smack.filter.PacketTypeFilter;
+import org.jivesoftware.smack.packet.Message;
+
+public class XMPPSender extends AbstractHandler implements TransportSender {
+	Log log = null;
+    XMPPConnectionFactory connectionFactory;
+	
+    public XMPPSender() {
+        log = LogFactory.getLog(XMPPSender.class);
+    }
+    
+	public void cleanup(MessageContext msgContext) throws AxisFault {	
+	}
+
+    /**
+     * Initialize the transport sender by reading pre-defined connection factories for
+     * outgoing messages. These will create sessions (one per each destination dealt with)
+     * to be used when messages are being sent.
+     * @param confContext the configuration context
+     * @param transportOut the transport sender definition from axis2.xml
+     * @throws AxisFault on error
+     */	
+	public void init(ConfigurationContext confContext,
+			TransportOutDescription transportOut) throws AxisFault {
+		//if connection details are available from axis configuration
+		//use those & connect to jabber server(s)
+		XMPPServerCredentials serverCredentials = new XMPPServerCredentials();
+		getConnectionDetailsFromAxisConfiguration(serverCredentials,transportOut);
+		connectionFactory = new XMPPConnectionFactory();
+		connectionFactory.connect(serverCredentials);		
+	}
+
+	/**
+	 * Extract connection details from Client options
+	 * @param msgCtx
+	 */
+	private void connectUsingClientOptions(MessageContext msgCtx) throws AxisFault{		
+		XMPPServerCredentials serverCredentials = new XMPPServerCredentials();
+		getConnectionDetailsFromClientOptions(serverCredentials,msgCtx);
+		connectionFactory = new XMPPConnectionFactory();
+		connectionFactory.connect(serverCredentials);
+	}
+	
+	public void stop() {}
+
+	public InvocationResponse invoke(MessageContext msgContext)
+			throws AxisFault {
+        String targetAddress = (String) msgContext.getProperty(
+                Constants.Configuration.TRANSPORT_URL);
+            if (targetAddress != null) {
+                sendMessage(msgContext, targetAddress, null);
+            } else if (msgContext.getTo() != null && !msgContext.getTo().hasAnonymousAddress())
{
+                targetAddress = msgContext.getTo().getAddress();
+
+                if (!msgContext.getTo().hasNoneAddress()) {
+                    sendMessage(msgContext, targetAddress, null);
+                } else {
+                    //Don't send the message.
+                    return InvocationResponse.CONTINUE;
+                }
+            } else if (msgContext.isServerSide()) {
+                // get the out transport info for server side when target EPR is unknown
+                sendMessage(msgContext, null,
+                    (OutTransportInfo) msgContext.getProperty(Constants.OUT_TRANSPORT_INFO));
+            }
+            return InvocationResponse.CONTINUE;
+	}
+
+    /**
+     * Send the given message over XMPP transport
+     *
+     * @param msgCtx the axis2 message context
+     * @throws AxisFault on error
+     */
+    public void sendMessage(MessageContext msgCtx, String targetAddress,
+        OutTransportInfo outTransportInfo) throws AxisFault {
+		XMPPConnection xmppConnection = null;
+		XMPPOutTransportInfo xmppOutTransportInfo = null;
+		
+		//if on client side,create connection to xmpp server
+		if(!msgCtx.isServerSide()){
+			connectUsingClientOptions(msgCtx);
+		}
+		
+		Message message = new Message();
+		Options options = msgCtx.getOptions();    	
+    	String serviceName = XMPPUtils.getServiceName(targetAddress);    	
+    	
+		if (targetAddress != null) {
+			xmppOutTransportInfo = new XMPPOutTransportInfo(targetAddress);
+			xmppOutTransportInfo.setConnectionFactory(connectionFactory);
+		} else if (targetAddress == null && msgCtx.getTo() != null &&
+				!msgCtx.getTo().hasAnonymousAddress()) {
+			//TODO 
+		} else if (msgCtx.isServerSide()) {
+			xmppOutTransportInfo = (XMPPOutTransportInfo)
+			msgCtx.getProperty(Constants.OUT_TRANSPORT_INFO);
+		}
+    	
+    	
+		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();
+			message.setProperty(XMPPConstants.IS_SERVER_SIDE, new Boolean(true));
+			message.setProperty(XMPPConstants.SERVICE_NAME, serviceName);
+			message.setProperty(XMPPConstants.ACTION, options.getAction());
+		}
+		
+    	if(xmppConnection == null){
+    		handleException("Connection to XMPP Server is not established.");    		
+    	}
+		
+		//initialize the chat manager using connection
+		ChatManager chatManager = xmppConnection.getChatManager();
+		Chat chat = chatManager.createChat(xmppOutTransportInfo.getDestinationAccount(), null);
	
+		
+		try 
+		{
+			OMElement msgElement = msgCtx.getEnvelope();
+			if (msgCtx.isDoingREST()) {
+				msgElement = msgCtx.getEnvelope().getBody().getFirstElement();
+			}
+			boolean waitForResponse =
+				msgCtx.getOperationContext() != null &&
+				WSDL2Constants.MEP_URI_OUT_IN.equals(
+						msgCtx.getOperationContext().getAxisOperation().getMessageExchangePattern());
+			
+			
+			String soapMessage = msgElement.toString();
+			//int endOfXMLDeclaration = soapMessage.indexOf("?>");
+			//String modifiedSOAPMessage = soapMessage.substring(endOfXMLDeclaration+2);
+			message.setBody(soapMessage);	
+			
+			XMPPClientSidePacketListener xmppClientSidePacketListener = null;
+			if(waitForResponse && !msgCtx.isServerSide()){
+				PacketFilter filter = new PacketTypeFilter(message.getClass());				
+				xmppClientSidePacketListener = new XMPPClientSidePacketListener(msgCtx);
+				xmppConnection.addPacketListener(xmppClientSidePacketListener,filter);
+			}			
+
+			chat.sendMessage(message);
+			log.debug("Sent message :"+message.toXML());
+
+			//If this is on client side, wait for the response from server.
+			//Is this the best way to do this?
+			if(waitForResponse && !msgCtx.isServerSide()){
+				while(! xmppClientSidePacketListener.isResponseReceived()){
+					try {
+						Thread.sleep(1000);
+					} catch (InterruptedException e) {
+						log.debug("Sleep interrupted",e);
+					}		
+				}
+				xmppConnection.disconnect();
+			}
+
+		} catch (XMPPException e) {
+			log.error("Error occurred while sending the message : "+message.toXML(),e);
+			handleException("Error occurred while sending the message : "+message.toXML(),e);
+		}finally{
+			if(!msgCtx.isServerSide()){
+				xmppConnection.disconnect();
+			}
+		}
+    }	
+    
+    
+    /**
+     * Extract connection details from axis2.xml's transportsender section
+     * @param serverCredentials
+     * @param transportOut
+     */
+	private void getConnectionDetailsFromAxisConfiguration(XMPPServerCredentials serverCredentials,
+			TransportOutDescription transportOut){
+		if(transportOut != null){
+			Parameter serverUrl = transportOut.getParameter(XMPPConstants.XMPP_SERVER_URL);
+			if (serverUrl != null) {
+				serverCredentials.setServerUrl(Utils.getParameterValue(serverUrl));
+			}
+			
+			Parameter userName = transportOut.getParameter(XMPPConstants.XMPP_SERVER_USERNAME);
+			if (userName != null) {
+				serverCredentials.setAccountName(Utils.getParameterValue(userName));
+			}
+		
+			Parameter password = transportOut.getParameter(XMPPConstants.XMPP_SERVER_PASSWORD);
+			if (password != null) {
+				serverCredentials.setPassword(Utils.getParameterValue(password));
+			}
+
+			Parameter serverType = transportOut.getParameter(XMPPConstants.XMPP_SERVER_TYPE);			
+			if (serverType != null) {
+				serverCredentials.setServerType(Utils.getParameterValue(serverType));
+			}			
+		}
+	}
+	
+	/**
+	 * Extract connection details from client options
+	 * @param serverCredentials
+	 * @param msgContext
+	 */
+	private void getConnectionDetailsFromClientOptions(XMPPServerCredentials serverCredentials,
+			MessageContext msgContext){
+		Options clientOptions = msgContext.getOptions();
+
+		if (clientOptions.getProperty(XMPPConstants.XMPP_SERVER_USERNAME) != null){
+			serverCredentials.setAccountName((String)clientOptions.getProperty(XMPPConstants.XMPP_SERVER_USERNAME));
+		}
+		if (clientOptions.getProperty(XMPPConstants.XMPP_SERVER_PASSWORD) != null){
+			serverCredentials.setPassword((String)clientOptions.getProperty(XMPPConstants.XMPP_SERVER_PASSWORD));
+		}
+		if (clientOptions.getProperty(XMPPConstants.XMPP_SERVER_URL) != null){
+			serverCredentials.setServerUrl((String)clientOptions.getProperty(XMPPConstants.XMPP_SERVER_URL));
+		}
+		if (clientOptions.getProperty(XMPPConstants.XMPP_SERVER_TYPE) != null){
+			serverCredentials.setServerType((String)clientOptions.getProperty(XMPPConstants.XMPP_SERVER_TYPE));
+		}		
+	}  
+	
+    private void handleException(String msg, Exception e) throws AxisFault {
+        log.error(msg, e);
+        throw new AxisFault(msg, e);
+    }
+    private void handleException(String msg) throws AxisFault {
+        log.error(msg);
+        throw new AxisFault(msg);
+    }
+}
\ No newline at end of file

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPClientSidePacketListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPClientSidePacketListener.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPClientSidePacketListener.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPClientSidePacketListener.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,44 @@
+package org.apache.axis2.transport.xmpp.util;
+
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+
+import org.apache.axis2.context.MessageContext;
+import org.apache.commons.lang.StringEscapeUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jivesoftware.smack.PacketListener;
+import org.jivesoftware.smack.packet.Message;
+import org.jivesoftware.smack.packet.Packet;
+
+public class XMPPClientSidePacketListener implements PacketListener {
+	private Log log = LogFactory.getLog(XMPPClientSidePacketListener.class);
+	private MessageContext messageContext = null;
+	private boolean responseReceived;
+
+	public XMPPClientSidePacketListener(MessageContext messageContext){
+		this.messageContext = messageContext;
+	}
+
+	/**
+	 * This method will be triggered, when a message is arrived at client side
+	 */
+	public void processPacket(Packet packet) {		
+		Message message = (Message)packet;
+		String xml = StringEscapeUtils.unescapeXml(message.getBody());
+		log.info("Client received message : "+xml);
+		this.responseReceived = true;
+		InputStream inputStream = new ByteArrayInputStream(xml.getBytes());
+		messageContext.setProperty(MessageContext.TRANSPORT_IN, inputStream);
+	}
+
+	/**
+	 * Indicates response message is received at client side.
+	 * @see processPacket(Packet packet)
+	 * @return
+	 */
+	public boolean isResponseReceived() {
+		return responseReceived;
+	}
+
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,175 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.axis2.transport.xmpp.util;
+
+import java.util.HashMap;
+
+import org.apache.axis2.AxisFault;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jivesoftware.smack.ConnectionConfiguration;
+import org.jivesoftware.smack.ConnectionListener;
+import org.jivesoftware.smack.XMPPConnection;
+import org.jivesoftware.smack.XMPPException;
+import org.jivesoftware.smack.filter.FromContainsFilter;
+import org.jivesoftware.smack.filter.PacketFilter;
+import org.jivesoftware.smack.filter.ToContainsFilter;
+
+public class XMPPConnectionFactory {
+	private Log log = LogFactory.getLog(XMPPConnectionFactory.class);
+	private XMPPConnection xmppConnection = null;
+	private PacketFilter packetFilter = null;
+	private HashMap xmppConnections = new HashMap();
+
+	public XMPPConnectionFactory(){}
+
+	/**
+	 * Connects to a XMPP server based on the details available in serverCredentials object
+	 * @param serverCredentials
+	 * @throws XMPPException 
+	 */
+	public void connect(final XMPPServerCredentials serverCredentials) throws AxisFault {
+		if(XMPPConstants.XMPP_SERVER_TYPE_JABBER.equals(serverCredentials.getServerType())){
+			ConnectionListener connectionListener = null;
+			try 
+			{
+				//XMPPConnection.DEBUG_ENABLED = true;
+				xmppConnection = new XMPPConnection(serverCredentials.getServerUrl());
+				xmppConnection.connect();
+				connectionListener = new ConnectionListener(){
+
+					public void connectionClosed() {
+						log.debug("Connection closed normally");
+					}
+
+					public void connectionClosedOnError(
+							Exception e1) {
+						log.debug("Connection to "+serverCredentials.getServerUrl()
+								+ " closed with error.",e1);
+						log.debug("Retrying to connect in 2 secs");
+						try
+						{
+							Thread.sleep(2000);
+							xmppConnection = new XMPPConnection(serverCredentials.getServerUrl());
+							log.debug("connected to "+serverCredentials.getServerUrl());
+						} catch (InterruptedException e2) {
+							log.debug("Sleep interrupted.",e2);
+						}
+					}
+
+					public void reconnectingIn(int seconds) {			
+					}
+
+					public void reconnectionFailed(Exception e) {
+					}
+
+					public void reconnectionSuccessful() {
+					}
+				};
+				xmppConnection.addConnectionListener(connectionListener);
+			}
+			catch(XMPPException e){
+				log.error("Failed to connect to server :"+serverCredentials.getServerUrl(), e);
+				throw new AxisFault("Failed to connect to server :"+serverCredentials.getServerUrl());
+			}
+
+			//Pause for a small time before trying to login.
+			//This prevents random ssl exception from Smack API
+			try {
+				Thread.sleep(100);
+			} catch (InterruptedException e5) {
+				log.debug("Sleep interrupted ",e5);
+			}
+
+			if(xmppConnection.isConnected()){
+				if(! xmppConnection.isAuthenticated()){
+					try {
+						xmppConnection.login(serverCredentials.getAccountName()+"@"+
+								serverCredentials.getServerUrl(), 
+								serverCredentials.getPassword(),
+								serverCredentials.getResource(),
+								true);
+					} catch (XMPPException e) {
+						try {
+							log.error("Login failed for "
+									+serverCredentials.getAccountName()
+									+"@"+serverCredentials.getServerUrl() 
+									+".Retrying in 2 secs",e); 
+							Thread.sleep(2000);
+							xmppConnection.login(serverCredentials.getAccountName()+"@"+
+									serverCredentials.getServerUrl(), 
+									serverCredentials.getPassword(),
+									serverCredentials.getResource(),
+									true);
+						} catch (InterruptedException e1) {
+							log.error("Sleep interrupted.",e1);
+						} catch (XMPPException e2) {
+							log.error("Login failed for : "+serverCredentials.getAccountName()
+									+"@"+serverCredentials.getServerUrl(),e2);
+							throw new AxisFault("Login failed for : "+serverCredentials.getAccountName()
+									+"@"+serverCredentials.getServerUrl());
+						}
+					}
+					//Listen for Message type packets from specified server url
+					//packetFilter = new AndFilter(new PacketTypeFilter(Message.class), 
+					//		new FromContainsFilter(serverCredentials.getServerUrl()));
+					packetFilter = new FromContainsFilter(serverCredentials.getServerUrl());					
+				}
+			}
+		}else if(XMPPConstants.XMPP_SERVER_TYPE_GOOGLETALK.equals(serverCredentials.getServerType())){
+			try {
+				ConnectionConfiguration connectionConfiguration = 
+					new ConnectionConfiguration(XMPPConstants.GOOGLETALK_URL
+						,XMPPConstants.GOOGLETALK_PORT
+						,XMPPConstants.GOOGLETALK_SERVICE_NAME);				
+				xmppConnection = new XMPPConnection(connectionConfiguration);
+				xmppConnection.connect();
+
+				xmppConnection.login(serverCredentials.getAccountName()
+						, serverCredentials.getPassword()
+						,serverCredentials.getResource(),
+						true);
+				//packetFilter = new AndFilter(new PacketTypeFilter(Message.class), 
+				//		new FromContainsFilter(XMPPConstants.GOOGLETALK_FROM));
+				//packetFilter = new FromContainsFilter(XMPPConstants.GOOGLETALK_FROM);
+				packetFilter = new ToContainsFilter("@gmail.com");
+				
+			} catch (XMPPException e1) {
+				log.error("Error occured while connecting to Googletalk server.",e1);
+				throw new AxisFault("Error occured while connecting to Googletalk server.");
+			}
+		}
+	} 
+
+	public XMPPConnection getConnection(String connectionIdentifier){
+		return (XMPPConnection)xmppConnections.get(connectionIdentifier);
+	}
+
+
+	public XMPPConnection getXmppConnection() {
+		return xmppConnection;
+	}
+
+	public void setXmppConnection(XMPPConnection xmppConnection) {
+		this.xmppConnection = xmppConnection;
+	}
+
+	public void listen(XMPPPacketListener packetListener){
+		xmppConnection.addPacketListener(packetListener,packetFilter);
+	}
+
+	public void stop() {}
+}
\ No newline at end of file

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConstants.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConstants.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConstants.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPConstants.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.axis2.transport.xmpp.util;
+
+
+public class XMPPConstants {	
+	public static final String XMPP = "xmpp";
+    //The prefix indicating an Axis XMPP URL
+    public static final String XMPP_PREFIX = "xmpp://";
+
+    //properties related to XMPP server connection
+    public static final String XMPP_SERVER_USERNAME = "transport.xmpp.ServerAccountUserName";
+    public static final String XMPP_SERVER_PASSWORD = "transport.xmpp.ServerAccountPassword";
   
+    public static final String XMPP_SERVER_URL = "transport.xmpp.ServerUrl";
+    
+    //Google talk attributes
+    public static final String GOOGLETALK_URL = "talk.google.com";
+    public static final int GOOGLETALK_PORT = 5222;
+    public static final String GOOGLETALK_SERVICE_NAME = "gmail.com";
+    public static final String GOOGLETALK_FROM = "gmail.com";
+    
+    
+    //XMPP Server Types
+    public static final String XMPP_SERVER_TYPE = "transport.xmpp.ServerType";
+    public static final String XMPP_SERVER_TYPE_JABBER = "transport.xmpp.ServerType.Jabber";
+    public static final String XMPP_SERVER_TYPE_GOOGLETALK = "transport.xmpp.ServerType.GoogleTalk";
  
+    
+    public static final String IS_SERVER_SIDE = "isServerSide";
+    public static final String IN_REPLY_TO = "inReplyTo";
+    public static final String SERVICE_NAME = "ServiceName";
+    public static final String ACTION = "Action";
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPOutTransportInfo.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPOutTransportInfo.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPOutTransportInfo.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPOutTransportInfo.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,65 @@
+package org.apache.axis2.transport.xmpp.util;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.transport.OutTransportInfo;
+
+/**
+ * 
+ * Holds XMPP transport out details
+ *
+ */
+public class XMPPOutTransportInfo implements OutTransportInfo{
+	private String contentType = null;
+	private String destinationAccount = null;
+	private String inReplyTo;
+	private EndpointReference from;
+	private XMPPConnectionFactory connectionFactory = null;
+	
+	public XMPPOutTransportInfo(){
+		
+	}
+	
+	public XMPPOutTransportInfo(String transportUrl) throws AxisFault {
+        this.destinationAccount = XMPPUtils.getAccountName(transportUrl);
+	}
+	public void setContentType(String contentType) {
+		this.contentType = contentType;
+	}		
+		
+    public XMPPConnectionFactory getConnectionFactory() {
+		return connectionFactory;
+	}
+
+    public void setConnectionFactory(XMPPConnectionFactory connectionFactory) {
+		this.connectionFactory = connectionFactory;
+	}
+	
+	public String getDestinationAccount() {
+		return destinationAccount;
+	}
+
+	public EndpointReference getFrom() {
+		return from;
+	}
+
+	public void setFrom(EndpointReference from) {
+		this.from = from;
+	}
+
+	public String getInReplyTo() {
+		return inReplyTo;
+	}
+
+	public void setInReplyTo(String inReplyTo) {
+		this.inReplyTo = inReplyTo;
+	}
+
+	public void setDestinationAccount(String destinationAccount) {
+		this.destinationAccount = destinationAccount;
+	}
+
+	public String getContentType() {
+		return contentType;
+	}	
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPPacketListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPPacketListener.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPPacketListener.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPPacketListener.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,206 @@
+package org.apache.axis2.transport.xmpp.util;
+
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.util.HashMap;
+
+import javax.xml.parsers.FactoryConfigurationError;
+import javax.xml.stream.XMLStreamException;
+
+import org.apache.axiom.om.OMException;
+import org.apache.axiom.soap.SOAPEnvelope;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.description.TransportInDescription;
+import org.apache.axis2.description.TransportOutDescription;
+import org.apache.axis2.engine.AxisEngine;
+import org.apache.axis2.transport.TransportUtils;
+import org.apache.axis2.util.MessageContextBuilder;
+import org.apache.commons.lang.StringEscapeUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jivesoftware.smack.PacketListener;
+import org.jivesoftware.smack.packet.Message;
+import org.jivesoftware.smack.packet.Packet;
+
+import edu.emory.mathcs.backport.java.util.concurrent.Executor;
+
+public class XMPPPacketListener implements PacketListener {
+	private static final Log log = LogFactory.getLog(XMPPPacketListener.class);
+	private XMPPConnectionFactory xmppConnectionFactory = null;
+	private ConfigurationContext configurationContext = null;
+	private Executor workerPool = null;
+
+	public XMPPPacketListener(XMPPConnectionFactory xmppConnectionFactory, ConfigurationContext
configurationContext, Executor workerPool) {
+		this.xmppConnectionFactory = xmppConnectionFactory;
+		this.configurationContext = configurationContext;
+		this.workerPool = workerPool;
+	}
+
+	/**
+	 * This method gets triggered when server side gets a message
+	 */
+	public void processPacket(Packet packet) {
+		log.info("Received : "+packet.toXML());
+		if(packet instanceof Message){
+			workerPool.execute(new Worker(packet));			
+		}
+	}
+
+	/**
+	 * Creates message context using values received in XMPP packet
+	 * @param packet
+	 * @return MessageContext
+	 * @throws AxisFault
+	 */
+	private MessageContext createMessageContext(Packet packet) throws AxisFault {
+		Message message = (Message) packet;
+
+		Boolean isServerSide = (Boolean) message
+				.getProperty(XMPPConstants.IS_SERVER_SIDE);
+		String serviceName = (String) message
+				.getProperty(XMPPConstants.SERVICE_NAME);
+		String action = (String) message.getProperty(XMPPConstants.ACTION);
+		MessageContext msgContext = null;
+
+		TransportInDescription transportIn = configurationContext
+				.getAxisConfiguration().getTransportIn("xmpp");
+		TransportOutDescription transportOut = configurationContext
+				.getAxisConfiguration().getTransportOut("xmpp");
+		if ((transportIn != null) && (transportOut != null)) {
+			msgContext = configurationContext.createMessageContext();
+			msgContext.setTransportIn(transportIn);
+			msgContext.setTransportOut(transportOut);
+			if (isServerSide != null) {
+				msgContext.setServerSide(isServerSide.booleanValue());
+			}
+			msgContext.setProperty(
+					org.apache.axis2.transport.mail.Constants.CONTENT_TYPE,
+					"text/xml");
+			msgContext.setProperty(
+					Constants.Configuration.CHARACTER_SET_ENCODING, "UTF-8");
+			msgContext.setIncomingTransportName("xmpp");
+
+			HashMap services = configurationContext.getAxisConfiguration()
+					.getServices();
+
+			AxisService axisService = (AxisService) services.get(serviceName);
+			msgContext.setAxisService(axisService);
+			msgContext.setSoapAction(action);
+
+			// pass the configurationFactory to transport sender
+			msgContext.setProperty("XMPPConfigurationFactory",
+					this.xmppConnectionFactory);
+
+			if (packet.getFrom() != null) {
+				msgContext.setFrom(new EndpointReference(packet.getFrom()));
+			}
+			if (packet.getTo() != null) {
+				msgContext.setTo(new EndpointReference(packet.getTo()));
+			}
+
+			XMPPOutTransportInfo xmppOutTransportInfo = new XMPPOutTransportInfo();
+			xmppOutTransportInfo
+					.setConnectionFactory(this.xmppConnectionFactory);
+
+			String packetFrom = packet.getFrom();
+			if (packetFrom != null) {
+				EndpointReference fromEPR = new EndpointReference(packetFrom);
+				xmppOutTransportInfo.setFrom(fromEPR);
+				xmppOutTransportInfo.setDestinationAccount(packetFrom);
+			}
+
+			// Save Message-Id to set as In-Reply-To on reply
+			String xmppMessageId = packet.getPacketID();
+			if (xmppMessageId != null) {
+				xmppOutTransportInfo.setInReplyTo(xmppMessageId);
+			}
+			msgContext.setProperty(
+					org.apache.axis2.Constants.OUT_TRANSPORT_INFO,
+					xmppOutTransportInfo);
+			buildSOAPEnvelope(packet, msgContext);
+		} else {
+			throw new AxisFault("Either transport in or transport out is null");
+		}
+		return msgContext;
+	}
+
+    /**
+     * builds SOAP envelop using message contained in packet
+     * @param packet
+     * @param msgContext
+     * @throws AxisFault
+     */
+	private void buildSOAPEnvelope(Packet packet, MessageContext msgContext) throws AxisFault{
+		Message message = (Message)packet;
+		String xml = StringEscapeUtils.unescapeXml(message.getBody());
+		InputStream inputStream = new ByteArrayInputStream(xml.getBytes());
+		SOAPEnvelope envelope;
+		try {
+			envelope = TransportUtils.createSOAPMessage(msgContext, inputStream, "text/xml");
+			if(msgContext.isServerSide()){
+				log.info("Received Envelope : "+xml);
+			}
+			msgContext.setEnvelope(envelope);
+		}catch (OMException e) {
+			log.error("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML(), e);
+			throw new AxisFault("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML());
+		}catch (XMLStreamException e) {
+			log.error("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML(), e);
+			throw new AxisFault("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML());
+		}catch (FactoryConfigurationError e) {
+			log.error("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML(), e);
+			throw new AxisFault("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML());
+		}catch (AxisFault e){
+			log.error("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML(), e);
+			throw new AxisFault("Error occured while trying to create " +
+					"message content using XMPP message received :"+packet.toXML());
+		}
+	}
+
+
+	/**
+	 * The actual Runnable Worker implementation which will process the
+	 * received XMPP messages in the worker thread pool
+	 */
+	class Worker implements Runnable {
+		private Packet packet = null;
+		Worker(Packet packet) {
+			this.packet = packet;
+		}
+
+		public void run() {
+			MessageContext msgCtx = null;
+			try {
+				msgCtx = createMessageContext(packet);
+				if(msgCtx.isProcessingFault() && msgCtx.isServerSide()){
+					AxisEngine.sendFault(msgCtx);
+				}else{
+					AxisEngine.receive(msgCtx);	
+				}
+			} catch (AxisFault e) {
+				log.error("Error occurred while sending message"+e);
+   				if (msgCtx.isServerSide()) {
+    				MessageContext faultContext;
+					try {
+						faultContext = MessageContextBuilder.createFaultMessageContext(msgCtx, e);
+	    				AxisEngine.sendFault(faultContext);
+					} catch (AxisFault e1) {
+						log.error("Error occurred while creating SOAPFault message"+e1);
+					}
+   				}
+			}
+		}
+	}
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPServerCredentials.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPServerCredentials.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPServerCredentials.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPServerCredentials.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,65 @@
+package org.apache.axis2.transport.xmpp.util;
+
+/**
+ * Holds connection details to a XMPP Server 
+ * 
+ */
+public class XMPPServerCredentials {
+	private String accountName;
+	private String serverUrl;
+	private String password;		
+	private String serverType;
+	private String resource; 
+	
+	public String getAccountName() {
+		return accountName;
+	}
+	public void setAccountName(String accountName) {
+		this.accountName = accountName;
+	}
+	public String getServerUrl() {
+		return serverUrl;
+	}
+	public void setServerUrl(String serverUrl) {
+		this.serverUrl = serverUrl;
+	}
+	public String getPassword() {
+		return password;
+	}
+	public void setPassword(String password) {
+		this.password = password;
+	}
+	public String getServerType() {
+		return serverType;
+	}
+	public void setServerType(String serverType) {
+		this.serverType = serverType;
+	}
+	public String getResource() {
+		return resource;
+	}
+	public void setResource(String resource) {
+		this.resource = resource;
+	}
+	
+	public XMPPServerCredentials() {
+		super();
+		this.accountName = "";
+		this.serverUrl = "";
+		this.password = "";
+		this.serverType = "";
+		this.resource = "soapserver"; //Default value
+	}
+	
+	public XMPPServerCredentials(String accountName, String serverUrl,
+			String password, String serverType, String resource) {
+		super();
+		this.accountName = accountName;
+		this.serverUrl = serverUrl;
+		this.password = password;
+		this.serverType = serverType;
+		this.resource = resource;
+	}
+	
+
+}

Added: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPUtils.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPUtils.java?rev=629402&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPUtils.java
(added)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/transport/xmpp/util/XMPPUtils.java
Wed Feb 20 02:04:32 2008
@@ -0,0 +1,60 @@
+package org.apache.axis2.transport.xmpp.util;
+
+import org.apache.axis2.AxisFault;
+
+
+public class XMPPUtils {
+    
+	/**
+	 * Extract XMPP server accountName section from transport URL passed in.  
+	 * @param transportUrl
+	 * @return String 
+	 * @throws AxisFault
+	 */
+    public static String getAccountName(String transportUrl) throws AxisFault{
+    	String accountName = "";
+    	if(transportUrl == null){
+    		return null;
+    	}
+    	
+        if (!transportUrl.startsWith(XMPPConstants.XMPP)) {
+            throw new AxisFault ("Invalid XMPP URL : " + transportUrl +
+                    " Must begin with the prefix xmpp");
+        }
+        //eg: transportUrl is similar to xmpp://axisserver@sumedha/Version
+        int start = transportUrl.indexOf("://") + 3;
+        int end = transportUrl.lastIndexOf("/"); //first index
+        if(start != -1 && end != -1){
+        	accountName = transportUrl.substring(start, end);
+        }else{
+        	accountName = transportUrl;
+        }
+        return accountName;
+    }
+
+    /**
+     * Extract Service name from transport URL passed in
+     * @param transportUrl
+     * @return
+     * @throws AxisFault
+     */
+    public static String getServiceName(String transportUrl) throws AxisFault{
+    	String serviceName = "";
+    	if(transportUrl == null){
+    		return null;
+    	}
+        if (!transportUrl.startsWith(XMPPConstants.XMPP)) {
+            throw new AxisFault ("Invalid XMPP URL : " + transportUrl +
+                    " Must begin with the prefix xmpp");
+        }
+        //eg: transportUrl is similar to xmpp://axisserver@sumedha/Version
+        int start = transportUrl.lastIndexOf("/") + 1;
+        int end = transportUrl.length();
+        if(start != -1 && end != -1){
+        	serviceName = transportUrl.substring(start, end);
+        }
+        return serviceName;
+    }
+    
+}
+



---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org


Mime
View raw message