|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.NetworkConnector
public class 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 PooledExecutor |
threadPool
|
Constructor Summary | |
---|---|
NetworkConnector(BrokerContainer brokerContainer)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected PooledExecutor threadPool
Constructor Detail |
---|
public NetworkConnector(BrokerContainer brokerContainer)
Method Detail |
---|
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public void setTransportChannelListener(TransportChannelListener listener)
public BrokerContainer getBrokerContainer()
public PooledExecutor getThreadPool()
public List getNetworkChannels()
public Map getLocalDetails()
public void setLocalDetails(Map localDetails)
public String getRemotePassword()
public void setRemotePassword(String remotePassword)
public String getRemoteUserName()
public void setRemoteUserName(String remoteUserName)
public void setNetworkChannels(List networkChannels)
NetworkChannel
instances
networkChannels
- public NetworkChannel addNetworkChannel(String uri) throws JMSException
uri
-
JMSException
public void addNetworkChannel(NetworkChannel networkChannel) throws JMSException
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(String url)
url
-
protected void configure(NetworkChannel networkChannel) throws JMSException
networkChannel
-
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |