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

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

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

Modified Files:
	MulticastTopicConnection.java 
Log Message:
delimited datagram factory fixes & test cases, plus some clean up of
durable active/backup logic.


Index: MulticastTopicConnection.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/multicast/MulticastTopicConnection.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** MulticastTopicConnection.java	20 Sep 2002 15:52:22 -0000	1.5
--- MulticastTopicConnection.java	10 Oct 2002 14:32:32 -0000	1.6
***************
*** 16,25 ****
  {
      private static IClientSession theSession = new LrmpClientSession();
!     
! 	/**
! 	 * Creates a multicast topic connection on the given class D address and port.
! 	 * @param host a multicast address
! 	 * @param port the port to use
! 	 */
      public MulticastTopicConnection(String host, int port)
          throws IOException
--- 16,25 ----
  {
      private static IClientSession theSession = new LrmpClientSession();
! 
!     /**
!      * Creates a multicast topic connection on the given class D address and port.
!      * @param host a multicast address
!      * @param port the port to use
!      */
      public MulticastTopicConnection(String host, int port)
          throws IOException
***************
*** 28,34 ****
                new LrmpClientProc(DatagramFactory.getInstance()),
                new SimpleDeliveryManager(),
! 			  DatagramFactory.getInstance(),
! 			  DatagramFactory.getInstance(),
! 			  DatagramFactory.getInstance(),
                new InternetConnectionDescriptor(host, port));
      }
--- 28,32 ----
                new LrmpClientProc(DatagramFactory.getInstance()),
                new SimpleDeliveryManager(),
!               DatagramFactory.getHolder(),
                new InternetConnectionDescriptor(host, port));
      }