Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> transport >> [ multicast overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.transport.multicast
Class MulticastTester  

java.lang.Object
  org.activemq.transport.multicast.MulticastTester

All Implemented Interfaces:

org.activemq.message.PacketListener

---

public class MulticastTester

extends java.lang.Object

implements org.activemq.message.PacketListener

An agent used to discover other instances of a service

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  MulticastTransportChannel	channel
static java.lang.String	DEFAULT_DISCOVERY_URI
private static org.activemq.util.IdGenerator	idGenerator
private  java.lang.String	localId
private  SynchronizedBoolean	started
private  java.net.URI	uri

 

Constructor Summary

MulticastTester()

 

Method Summary
void	consume(org.activemq.message.Packet packet)           Consume a Packet
java.lang.String	getLocalId()
java.net.URI	getUri()
static void	main(java.lang.String[] args)
private  void	send(org.activemq.message.ActiveMQTextMessage message)
void	setLocalId(java.lang.String localId)
void	setUri(java.net.URI uri)
void	start()
void	stop()

 

Methods inherited from class java.lang.Object

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

 

Field Detail

idGenerator

private static final org.activemq.util.IdGenerator idGenerator

---

DEFAULT_DISCOVERY_URI

public static final java.lang.String DEFAULT_DISCOVERY_URI

See Also:

Constant Field Values

---

started

private SynchronizedBoolean started

---

channel

private MulticastTransportChannel channel

---

uri

private java.net.URI uri

---

localId

private java.lang.String localId

Constructor Detail

MulticastTester

public MulticastTester()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.net.URISyntaxException,
                        javax.jms.JMSException,
                        java.lang.InterruptedException

---

send

private void send(org.activemq.message.ActiveMQTextMessage message)
           throws javax.jms.JMSException

---

start

public void start()
           throws javax.jms.JMSException

---

stop

public void stop()
          throws javax.jms.JMSException

---

consume

public void consume(org.activemq.message.Packet packet)

Description copied from interface: org.activemq.message.PacketListener

Consume a Packet

Specified by:

consume in interface org.activemq.message.PacketListener

---

getLocalId

public java.lang.String getLocalId()

---

setLocalId

public void setLocalId(java.lang.String localId)

---

getUri

public java.net.URI getUri()

---

setUri

public void setUri(java.net.URI uri)

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> transport >> [ multicast overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---