|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.NetworkMessageBridge
A NetworkMessageBridge consumes messages from a remote broker and daisy chains them to the local message producer, which will pass them into the local broker for consumption
Constructor Summary | |
NetworkMessageBridge()
Construct the NetworkMessageConsumer |
Method Summary | |
int |
decrementReferenceCount()
decrement number of references to this consumer |
boolean |
equals(Object obj)
|
ActiveMQDestination |
getDestination()
|
String |
getLocalBrokerName()
|
Session |
getLocalSession()
|
Session |
getRemoteSession()
|
int |
hashCode()
|
int |
incrementReferenceCount()
increment number of references to this consumer |
boolean |
isDurableTopic()
|
void |
onMessage(Message msg)
|
void |
setDestination(ActiveMQDestination destination)
|
void |
setDurableTopic(boolean durableTopic)
sett the durable value of the consumer |
void |
setLocalBrokerName(String localBrokerName)
|
void |
setLocalSession(Session localSession)
|
void |
setRemoteSession(Session remoteSession)
|
void |
start()
start the bridge |
void |
stop()
stop the bridge |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public NetworkMessageBridge()
Method Detail |
public void setDurableTopic(boolean durableTopic)
durableTopic
- public boolean isDurableTopic()
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
destination
- The destination to set.public String getLocalBrokerName()
public void setLocalBrokerName(String localBrokerName)
localBrokerName
- The localBrokerName to set.public Session getLocalSession()
public void setLocalSession(Session localSession)
localSession
- The localSession to set.public Session getRemoteSession()
public void setRemoteSession(Session remoteSession)
remoteSession
- The remoteSession to set.public int incrementReferenceCount()
public int decrementReferenceCount()
public void start() throws JMSException
start
in interface Service
JMSException
public void stop()
stop
in interface Service
public void onMessage(Message msg)
onMessage
in interface MessageListener
msg
- consumed message from remote brokerpublic int hashCode()
public boolean equals(Object obj)
obj
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |