[Ubermq-commits] jms/src/com/ubermq/jms/client/multicast LrmpClientSession.java,1.4,1.5

[<ji...@us...>]

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/multicast
In directory usw-pr-cvs1:/tmp/cvs-serv1568/src/com/ubermq/jms/client/multicast

Modified Files:
	LrmpClientSession.java 
Log Message:
clean up internet connection descriptor


Index: LrmpClientSession.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/multicast/LrmpClientSession.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** LrmpClientSession.java	19 Sep 2002 17:30:31 -0000	1.4
--- LrmpClientSession.java	22 Sep 2002 17:19:08 -0000	1.5
***************
*** 1,7 ****
  package com.ubermq.jms.client.multicast;
  
- import com.ubermq.kernel.*;
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.InternetConnectionDescriptor;
  
  /**
--- 1,9 ----
  package com.ubermq.jms.client.multicast;
  
  import com.ubermq.jms.client.*;
+ import com.ubermq.kernel.*;
+ 
  import com.ubermq.jms.client.impl.InternetConnectionDescriptor;
+ import java.net.InetSocketAddress;
  
  /**
***************
*** 11,38 ****
   */
  public class LrmpClientSession
! 	implements IClientSession
  {
! 	public static final int
! 		TTL_MACHINE = 0,
! 		TTL_SUBNET = 1,
! 		TTL_SITE = 15,
! 		TTL_REGION = 63,
! 		TTL_WORLDWIDE = 127;
! 	
! 	public LrmpClientSession()
! 	{
! 	}
! 	
! 	public void started(IConnectionInfo c)
! 	{
! 	}
! 	
! 	public IConnectionInfo connect(javax.jms.Connection cxn,
! 								   ConnectionDescriptor descriptor,
! 								   IMessageProcessor proc)
! 		throws java.io.IOException
! 	{
! 		InternetConnectionDescriptor d = (InternetConnectionDescriptor)descriptor;
! 		return new LrmpConnectionInfo(cxn, d.getHost(), d.getPort(), TTL_SUBNET, proc);
! 	}
  }
--- 13,41 ----
   */
  public class LrmpClientSession
!     implements IClientSession
  {
!     public static final int
!         TTL_MACHINE = 0,
!         TTL_SUBNET = 1,
!         TTL_SITE = 15,
!         TTL_REGION = 63,
!         TTL_WORLDWIDE = 127;
! 
!     public LrmpClientSession()
!     {
!     }
! 
!     public void started(IConnectionInfo c)
!     {
!     }
! 
!     public IConnectionInfo connect(javax.jms.Connection cxn,
!                                    ConnectionDescriptor descriptor,
!                                    IMessageProcessor proc)
!         throws java.io.IOException
!     {
!         InternetConnectionDescriptor d = (InternetConnectionDescriptor)descriptor;
!         InetSocketAddress a = (InetSocketAddress)d.getAddress();
!         return new LrmpConnectionInfo(cxn, a.getHostName(), a.getPort(), TTL_SUBNET, proc);
!     }
  }