|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.NetworkChannel
Represents a broker's connection with a single remote broker which bridges the two brokers to form a network.
The NetworkChannel contains a JMS connection with the remote broker. New subscriptions on the local broker are multiplexed into the JMS connection so that messages published on the remote broker can be replayed onto the local broker.
Constructor Summary | |
NetworkChannel()
Default Constructor |
|
NetworkChannel(BrokerContainer brokerContainer,
String uri)
Constructor |
Method Summary | |
BrokerContainer |
getBrokerContainer()
|
int |
getMaximumRetries()
|
long |
getReconnectSleepTime()
|
String |
getRemoteBrokerName()
|
String |
getRemotePassword()
|
String |
getRemoteUserName()
|
String |
getUri()
|
void |
onConsumerInfo(BrokerClient client,
ConsumerInfo info)
Listen for new Consumer events at this broker |
void |
setBrokerContainer(BrokerContainer brokerContainer)
|
void |
setMaximumRetries(int maximumRetries)
|
void |
setReconnectSleepTime(long reconnectSleepTime)
|
void |
setRemoteBrokerName(String remoteBrokerName)
|
void |
setRemotePassword(String remotePassword)
|
void |
setRemoteUserName(String remoteUserName)
|
void |
setUri(String uri)
set the uri of the broker(s) this channel is connected to |
void |
start()
Start the channel |
void |
stop()
stop the channel |
String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public NetworkChannel()
public NetworkChannel(BrokerContainer brokerContainer, String uri)
brokerContainer
- uri
- Method Detail |
public String toString()
public void start() throws JMSException
start
in interface Service
JMSException
public void stop() throws JMSException
stop
in interface Service
JMSException
- on errorpublic void onConsumerInfo(BrokerClient client, ConsumerInfo info)
onConsumerInfo
in interface ConsumerInfoListener
client
- info
- public String getUri()
public void setUri(String uri)
uri
- public String getRemotePassword()
public void setRemotePassword(String remotePassword)
remotePassword
- The remotePassword to set.public String getRemoteUserName()
public void setRemoteUserName(String remoteUserName)
remoteUserName
- The remoteUserName to set.public BrokerContainer getBrokerContainer()
public void setBrokerContainer(BrokerContainer brokerContainer)
brokerContainer
- The brokerContainer to set.public int getMaximumRetries()
public void setMaximumRetries(int maximumRetries)
public long getReconnectSleepTime()
public void setReconnectSleepTime(long reconnectSleepTime)
public String getRemoteBrokerName()
public void setRemoteBrokerName(String remoteBrokerName)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |