modules/transport/xmpp/src/org/apache/axis2/transport/xmpp/util/XMPPClientConnectionFactory.java [49:162]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public XMPPConnection connect(final XMPPServerCredentials serverCredentials) throws AxisFault {
		//XMPPConnection.DEBUG_ENABLED = true;		
		if(XMPPConstants.XMPP_SERVER_TYPE_JABBER.equals(serverCredentials.getServerType())){
			xmppConnection = new XMPPConnection(serverCredentials.getServerUrl());
			try {
				xmppConnection.connect();
			} 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()){
				String resource = serverCredentials.getResource()+ new Object().hashCode();
				if(! xmppConnection.isAuthenticated()){
					try {
						//xmppConnection.login(serverCredentials.getAccountName()+"@"+
						//                serverCredentials.getServerUrl(),
                       xmppConnection.login(serverCredentials.getAccountName(), 
								serverCredentials.getPassword(),
								resource,
								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(),
                           xmppConnection.login(serverCredentials.getAccountName(), 
                                            serverCredentials.getPassword(),
                                            resource,
                                            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())){
			ConnectionConfiguration connectionConfiguration = 
				new ConnectionConfiguration(XMPPConstants.GOOGLETALK_URL
					,XMPPConstants.GOOGLETALK_PORT
					,XMPPConstants.GOOGLETALK_SERVICE_NAME);				
			xmppConnection = new XMPPConnection(connectionConfiguration);
			try {
				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.");
			}	
		}
		
		ConnectionListener connectionListener = null;
		connectionListener = new ConnectionListener(){
			public void connectionClosed() {
				log.debug("Connection closed normally");
			}
			public void connectionClosedOnError(
					Exception e1) {
				log.error("Connection to "+serverCredentials.getServerUrl()
						+ " closed with error.",e1);
			}
			public void reconnectingIn(int seconds) {
				log.error("Connection to "+serverCredentials.getServerUrl() 
						+" failed. Reconnecting in "+seconds+"s");
			}
			public void reconnectionFailed(Exception e) {
				log.error("Reconnection to "+serverCredentials.getServerUrl()+" failed.",e);
			}
			public void reconnectionSuccessful() {
				log.debug("Reconnection to "+serverCredentials.getServerUrl()+" successful.");
			}
		};
		if(xmppConnection != null && xmppConnection.isConnected()){
			xmppConnection.addConnectionListener(connectionListener);
			log.info("Connected to " +serverCredentials.getAccountName()+ "@" 
					+ serverCredentials.getServerUrl()+ "/"+ serverCredentials.getResource());
		}else{
			log.warn(" Not Connected to " +serverCredentials.getAccountName()+ "@" 
					+ serverCredentials.getServerUrl()+ "/"+ serverCredentials.getResource());
		}
		return xmppConnection;
	} 
	
	public XMPPConnection getXmppConnection(){
	    return xmppConnection;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



modules/transport/xmpp/src/org/apache/axis2/transport/xmpp/util/XMPPConnectionFactory.java [49:153]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public XMPPConnection connect(final XMPPServerCredentials serverCredentials) throws AxisFault {
		//XMPPConnection.DEBUG_ENABLED = true;		
		if(XMPPConstants.XMPP_SERVER_TYPE_JABBER.equals(serverCredentials.getServerType())){
			xmppConnection = new XMPPConnection(serverCredentials.getServerUrl());
			try {
				xmppConnection.connect();
			} 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()){
				String resource = serverCredentials.getResource()+ new Object().hashCode();
				if(! xmppConnection.isAuthenticated()){
					try {
                       xmppConnection.login(serverCredentials.getAccountName(), 
								serverCredentials.getPassword(),
								resource,
								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.getPassword(),
                                            resource,
                                            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 FromContainsFilter(serverCredentials.getServerUrl());					
				}
			}	
		}else if(XMPPConstants.XMPP_SERVER_TYPE_GOOGLETALK.equals(serverCredentials.getServerType())){
			ConnectionConfiguration connectionConfiguration = 
				new ConnectionConfiguration(XMPPConstants.GOOGLETALK_URL
					,XMPPConstants.GOOGLETALK_PORT
					,XMPPConstants.GOOGLETALK_SERVICE_NAME);				
			xmppConnection = new XMPPConnection(connectionConfiguration);
			try {
				xmppConnection.connect();
				xmppConnection.login(serverCredentials.getAccountName()
						, serverCredentials.getPassword()
						,serverCredentials.getResource(),
						true);
				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.");
			}	
		}
		
		ConnectionListener connectionListener = null;
		connectionListener = new ConnectionListener(){
			public void connectionClosed() {
				log.debug("Connection closed normally");
			}
			public void connectionClosedOnError(
					Exception e1) {
				log.error("Connection to "+serverCredentials.getServerUrl()
						+ " closed with error.",e1);
			}
			public void reconnectingIn(int seconds) {
				log.error("Connection to "+serverCredentials.getServerUrl() 
						+" failed. Reconnecting in "+seconds+"s");
			}
			public void reconnectionFailed(Exception e) {
				log.error("Reconnection to "+serverCredentials.getServerUrl()+" failed.",e);
			}
			public void reconnectionSuccessful() {
				log.debug("Reconnection to "+serverCredentials.getServerUrl()+" successful.");
			}
		};
		if(xmppConnection != null && xmppConnection.isConnected()){
			xmppConnection.addConnectionListener(connectionListener);
			log.info("Connected to " +serverCredentials.getAccountName()+ "@" 
					+ serverCredentials.getServerUrl()+ "/"+ serverCredentials.getResource());
		}else{
			log.warn(" Not Connected to " +serverCredentials.getAccountName()+ "@" 
					+ serverCredentials.getServerUrl()+ "/"+ serverCredentials.getResource());
		}
		return xmppConnection;
	} 
	
	public XMPPConnection getXmppConnection(){
	    return xmppConnection;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -