org.qbroker.net

Class MulticastGroup

java.lang.Object

org.qbroker.net.MulticastGroup

public class MulticastGroup
extends java.lang.Object

MulticastGroup connects to a multicast socket for publishing or receiving Datagram packets. It supports binding to a given network interface under Java 1.4.

This is NOT MT-Safe.

Author:

yannanlu@yahoo.com

Constructor Summary

Constructors

Constructor and Description
MulticastGroup(java.lang.String group, int port)
MulticastGroup(java.lang.String group, int port, int bufferSize)
MulticastGroup(java.lang.String group, int port, int bufferSize, int timeout, int ttl, java.lang.String inf)

Method Summary

Modifier and Type	Method and Description
void	close()
java.net.InetAddress	getInetAddress()
java.net.InetAddress	getInterface()
java.net.NetworkInterface	getNetworkInterface()
int	getPort()
java.net.DatagramSocket	getSocket()
int	getTimeout()
boolean	isConnected()
static void	main(java.lang.String[] args)
java.lang.String	receive()
void	receive(java.net.DatagramPacket p)
void	receive(XQueue xq) get a used packet from XQ first and send the received packet to XQ if the used packet is null, create a new packet for use
int	reconnect()
void	send(byte[] buffer, int offset, int length)
void	send(java.net.DatagramPacket p)
void	send(java.lang.String text)
void	send(XQueue xq)
void	setSleepTime(int ms)
void	setTimeout(int timeout)
void	setTimeToLive(int tll)
void	setWaitTime(int ms)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MulticastGroup

public MulticastGroup(java.lang.String group,
                      int port)

MulticastGroup

public MulticastGroup(java.lang.String group,
                      int port,
                      int bufferSize)

MulticastGroup

public MulticastGroup(java.lang.String group,
                      int port,
                      int bufferSize,
                      int timeout,
                      int ttl,
                      java.lang.String inf)

Method Detail

reconnect

public int reconnect()

close

public void close()

isConnected

public boolean isConnected()

getInetAddress

public java.net.InetAddress getInetAddress()

getPort

public int getPort()

getTimeout

public int getTimeout()

getInterface

public java.net.InetAddress getInterface()
                                  throws java.net.SocketException

Throws:

java.net.SocketException

getNetworkInterface

public java.net.NetworkInterface getNetworkInterface()
                                              throws java.net.SocketException

Throws:

java.net.SocketException

getSocket

public java.net.DatagramSocket getSocket()

setTimeout

public void setTimeout(int timeout)

setTimeToLive

public void setTimeToLive(int tll)

setSleepTime

public void setSleepTime(int ms)

setWaitTime

public void setWaitTime(int ms)

send

public void send(java.net.DatagramPacket p)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(byte[] buffer,
                 int offset,
                 int length)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(java.lang.String text)
          throws java.io.IOException

Throws:

java.io.IOException

send

public void send(XQueue xq)
          throws java.io.IOException

Throws:

java.io.IOException

receive

public void receive(java.net.DatagramPacket p)
             throws java.io.IOException

Throws:

java.io.IOException

receive

public void receive(XQueue xq)
             throws java.io.IOException

get a used packet from XQ first and send the received packet to XQ if the used packet is null, create a new packet for use

Throws:

java.io.IOException

receive

public java.lang.String receive()
                         throws java.io.IOException

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)