|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.NetworkConnector
Represents a connector to one or more remote brokers.
This class manages a number of NetworkChannel
instances
which may or may not be connected to a
remote broker at any point in time.
NetworkChannel
instances or could use
discovery to find them.
Field Summary | |
protected EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
threadPool
|
Constructor Summary | |
NetworkConnector(BrokerContainer brokerContainer)
|
Method Summary | |
void |
addNetworkChannel(NetworkChannel networkChannel)
Adds a new network channel |
NetworkChannel |
addNetworkChannel(java.lang.String uri)
Adds a new network channel for the given URI |
protected void |
configure(NetworkChannel networkChannel)
Performs any network connector based configuration; such as setting the dispatch policies |
protected NetworkChannel |
createNetworkChannel(java.lang.String url)
Create a channel from the url |
BrokerContainer |
getBrokerContainer()
|
java.util.Map |
getLocalDetails()
|
int |
getLocalDurableTopicPrefetch()
|
ActiveMQPrefetchPolicy |
getLocalPrefetchPolicy()
|
int |
getLocalQueueBrowserPrefetch()
|
int |
getLocalQueuePrefetch()
|
int |
getLocalTopicPrefetch()
|
java.util.List |
getNetworkChannels()
|
int |
getRemoteDurableTopicPrefetch()
|
java.lang.String |
getRemotePassword()
|
ActiveMQPrefetchPolicy |
getRemotePrefetchPolicy()
|
int |
getRemoteQueueBrowserPrefetch()
|
int |
getRemoteQueuePrefetch()
|
int |
getRemoteTopicPrefetch()
|
java.lang.String |
getRemoteUserName()
|
EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
getThreadPool()
|
void |
removeNetworkChannel(NetworkChannel networkChannel)
Removes a network channel |
void |
setLocalDetails(java.util.Map localDetails)
|
void |
setLocalDurableTopicPrefetch(int durableTopicPrefetch)
|
void |
setLocalPrefetchPolicy(ActiveMQPrefetchPolicy localPrefetchPolicy)
|
void |
setLocalQueueBrowserPrefetch(int queueBrowserPrefetch)
|
void |
setLocalQueuePrefetch(int queuePrefetch)
|
void |
setLocalTopicPrefetch(int topicPrefetch)
|
void |
setNetworkChannels(java.util.List networkChannels)
Sets a list of NetworkChannel instances |
void |
setRemoteDurableTopicPrefetch(int durableTopicPrefetch)
|
void |
setRemotePassword(java.lang.String remotePassword)
|
void |
setRemotePrefetchPolicy(ActiveMQPrefetchPolicy remotePrefetchPolicy)
|
void |
setRemoteQueueBrowserPrefetch(int queueBrowserPrefetch)
|
void |
setRemoteQueuePrefetch(int queuePrefetch)
|
void |
setRemoteTopicPrefetch(int topicPrefetch)
|
void |
setRemoteUserName(java.lang.String remoteUserName)
|
void |
setTransportChannelListener(TransportChannelListener listener)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected EDU.oswego.cs.dl.util.concurrent.PooledExecutor threadPool
Constructor Detail |
public NetworkConnector(BrokerContainer brokerContainer)
Method Detail |
public void start() throws javax.jms.JMSException
Service
start
in interface Service
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
Service
stop
in interface Service
javax.jms.JMSException
public void setTransportChannelListener(TransportChannelListener listener)
public BrokerContainer getBrokerContainer()
public EDU.oswego.cs.dl.util.concurrent.PooledExecutor getThreadPool()
public java.util.List getNetworkChannels()
public java.util.Map getLocalDetails()
public void setLocalDetails(java.util.Map localDetails)
public java.lang.String getRemotePassword()
public void setRemotePassword(java.lang.String remotePassword)
public java.lang.String getRemoteUserName()
public void setRemoteUserName(java.lang.String remoteUserName)
public void setNetworkChannels(java.util.List networkChannels)
NetworkChannel
instances
networkChannels
- public NetworkChannel addNetworkChannel(java.lang.String uri) throws javax.jms.JMSException
uri
-
javax.jms.JMSException
public void addNetworkChannel(NetworkChannel networkChannel) throws javax.jms.JMSException
javax.jms.JMSException
public void removeNetworkChannel(NetworkChannel networkChannel)
public ActiveMQPrefetchPolicy getLocalPrefetchPolicy()
public void setLocalPrefetchPolicy(ActiveMQPrefetchPolicy localPrefetchPolicy)
public ActiveMQPrefetchPolicy getRemotePrefetchPolicy()
public void setRemotePrefetchPolicy(ActiveMQPrefetchPolicy remotePrefetchPolicy)
public int getLocalDurableTopicPrefetch()
public void setLocalDurableTopicPrefetch(int durableTopicPrefetch)
public int getLocalQueuePrefetch()
public void setLocalQueuePrefetch(int queuePrefetch)
public int getLocalQueueBrowserPrefetch()
public void setLocalQueueBrowserPrefetch(int queueBrowserPrefetch)
public int getLocalTopicPrefetch()
public void setLocalTopicPrefetch(int topicPrefetch)
public int getRemoteDurableTopicPrefetch()
public void setRemoteDurableTopicPrefetch(int durableTopicPrefetch)
public int getRemoteQueuePrefetch()
public void setRemoteQueuePrefetch(int queuePrefetch)
public int getRemoteQueueBrowserPrefetch()
public void setRemoteQueueBrowserPrefetch(int queueBrowserPrefetch)
public int getRemoteTopicPrefetch()
public void setRemoteTopicPrefetch(int topicPrefetch)
protected NetworkChannel createNetworkChannel(java.lang.String url)
url
-
protected void configure(NetworkChannel networkChannel) throws javax.jms.JMSException
networkChannel
-
javax.jms.JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |