public class TransportConnector extends java.lang.Object implements Connector, BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.CopyOnWriteArrayList<TransportConnection> |
connections |
protected TransportStatusDetector |
statusDector |
Constructor and Description |
---|
TransportConnector() |
TransportConnector(TransportServer server) |
Modifier and Type | Method and Description |
---|---|
ManagedTransportConnector |
asManagedConnector(ManagementContext context,
javax.management.ObjectName connectorName)
Factory method to create a JMX managed version of this transport
connector
|
protected Connection |
createConnection(Transport transport) |
protected DiscoveryAgent |
createDiscoveryAgent() |
protected TransportServer |
createTransportServer() |
Broker |
getBroker() |
BrokerInfo |
getBrokerInfo() |
BrokerService |
getBrokerService() |
protected ConnectionControl |
getConnectionControl() |
java.util.concurrent.CopyOnWriteArrayList<TransportConnection> |
getConnections() |
java.net.URI |
getConnectUri() |
DiscoveryAgent |
getDiscoveryAgent() |
java.net.URI |
getDiscoveryUri() |
MessageAuthorizationPolicy |
getMessageAuthorizationPolicy() |
java.lang.String |
getName() |
java.lang.String |
getPublishableConnectString() |
TransportServer |
getServer() |
ConnectorStatistics |
getStatistics() |
TaskRunnerFactory |
getTaskRunnerFactory() |
java.lang.String |
getUpdateClusterFilter() |
java.net.URI |
getUri() |
boolean |
isDisableAsyncDispatch() |
boolean |
isEnableStatusMonitor() |
boolean |
isRebalanceClusterClients() |
boolean |
isUpdateClusterClients() |
boolean |
isUpdateClusterClientsOnRemove() |
void |
onStarted(TransportConnection connection) |
void |
onStopped(TransportConnection connection) |
void |
setBrokerInfo(BrokerInfo brokerInfo) |
void |
setBrokerName(java.lang.String name)
Deprecated.
use the
setBrokerService(BrokerService) method
instead. |
void |
setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.
|
void |
setConnectUri(java.net.URI transportUri) |
void |
setDisableAsyncDispatch(boolean disableAsyncDispatch) |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent) |
void |
setDiscoveryUri(java.net.URI discoveryUri) |
void |
setEnableStatusMonitor(boolean enableStatusMonitor) |
void |
setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
Sets the policy used to decide if the current connection is authorized to
consume a given message
|
void |
setName(java.lang.String name) |
void |
setRebalanceClusterClients(boolean rebalanceClusterClients) |
void |
setServer(TransportServer server) |
void |
setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory) |
void |
setUpdateClusterClients(boolean updateClusterClients) |
void |
setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove) |
void |
setUpdateClusterFilter(java.lang.String updateClusterFilter) |
void |
setUri(java.net.URI uri)
Sets the server transport URI to use if there is not a
TransportServer configured via the
setServer(TransportServer) method. |
void |
start() |
void |
stop() |
java.lang.String |
toString() |
void |
updateClientClusterInfo()
Update all the connections with information
about the connected brokers in the cluster
|
protected java.util.concurrent.CopyOnWriteArrayList<TransportConnection> connections
protected TransportStatusDetector statusDector
public TransportConnector()
public TransportConnector(TransportServer server)
public java.util.concurrent.CopyOnWriteArrayList<TransportConnection> getConnections()
public ManagedTransportConnector asManagedConnector(ManagementContext context, javax.management.ObjectName connectorName) throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public BrokerInfo getBrokerInfo()
getBrokerInfo
in interface Connector
public void setBrokerInfo(BrokerInfo brokerInfo)
@Deprecated public void setBrokerName(java.lang.String name)
setBrokerService(BrokerService)
method
instead.public TransportServer getServer() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public void setServer(TransportServer server)
public java.net.URI getUri()
public void setUri(java.net.URI uri)
TransportServer
configured via the
setServer(TransportServer)
method. This value is used to lazy
create a TransportServer
instanceuri
- public TaskRunnerFactory getTaskRunnerFactory()
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
public ConnectorStatistics getStatistics()
getStatistics
in interface Connector
public MessageAuthorizationPolicy getMessageAuthorizationPolicy()
public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
public void start() throws java.lang.Exception
public java.lang.String getPublishableConnectString() throws java.lang.Exception
java.lang.Exception
public void stop() throws java.lang.Exception
protected Connection createConnection(Transport transport) throws java.io.IOException
java.io.IOException
protected TransportServer createTransportServer() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public DiscoveryAgent getDiscoveryAgent() throws java.io.IOException
java.io.IOException
protected DiscoveryAgent createDiscoveryAgent() throws java.io.IOException
java.io.IOException
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
public java.net.URI getDiscoveryUri()
public void setDiscoveryUri(java.net.URI discoveryUri)
public java.net.URI getConnectUri() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public void setConnectUri(java.net.URI transportUri)
public void onStarted(TransportConnection connection)
public void onStopped(TransportConnection connection)
public java.lang.String getName()
public void setName(java.lang.String name)
public java.lang.String toString()
toString
in class java.lang.Object
protected ConnectionControl getConnectionControl()
public void updateClientClusterInfo()
Connector
updateClientClusterInfo
in interface Connector
public boolean isDisableAsyncDispatch()
public void setDisableAsyncDispatch(boolean disableAsyncDispatch)
public boolean isEnableStatusMonitor()
public void setEnableStatusMonitor(boolean enableStatusMonitor)
enableStatusMonitor
- the enableStatusMonitor to setpublic void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
public BrokerService getBrokerService()
public boolean isUpdateClusterClients()
isUpdateClusterClients
in interface Connector
public void setUpdateClusterClients(boolean updateClusterClients)
updateClusterClients
- the updateClusterClients to setpublic boolean isRebalanceClusterClients()
isRebalanceClusterClients
in interface Connector
public void setRebalanceClusterClients(boolean rebalanceClusterClients)
rebalanceClusterClients
- the rebalanceClusterClients to setpublic boolean isUpdateClusterClientsOnRemove()
isUpdateClusterClientsOnRemove
in interface Connector
public void setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)
updateClusterClientsOnRemove
- the updateClusterClientsOnRemove to setpublic java.lang.String getUpdateClusterFilter()
public void setUpdateClusterFilter(java.lang.String updateClusterFilter)
updateClusterFilter
- the updateClusterFilter to setCopyright © 2005-2012. All Rights Reserved.