KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > ubermq > jms > client > multicast > MulticastTopicConnection


1 package com.ubermq.jms.client.multicast;
2 import com.ubermq.jms.client.impl.*;
3 import com.ubermq.jms.client.*;
4
5
6 import com.ubermq.jms.client.IClientSession;
7 import com.ubermq.jms.client.multicast.LrmpClientSession;
8 import com.ubermq.jms.client.proc.LrmpClientProc;
9 import com.ubermq.jms.common.datagram.impl.DatagramFactory;
10 import java.io.IOException JavaDoc;
11
12 /**
13  * A topic connection that uses LRMP multicast to send and receive messages
14  * from a set of nodes.
15  */
16 public class MulticastTopicConnection
17     extends Connection
18 {
19     private static IClientSession theSession = new LrmpClientSession();
20
21     /**
22      * Creates a multicast topic connection.
23      *
24      * @param icd a connection descriptor
25      */
26     public MulticastTopicConnection(InternetConnectionDescriptor icd)
27         throws IOException JavaDoc
28     {
29         super(theSession,
30               new LrmpClientProc(DatagramFactory.getInstance()),
31               new SimpleDeliveryManager(),
32               DatagramFactory.getHolder(),
33               icd);
34     }
35 }
36
Popular Tags