public class TransportConnector extends Object implements Connector, BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected CopyOnWriteArrayList<TransportConnection> |
connections |
protected TransportStatusDetector |
statusDector |
Constructor and Description |
---|
TransportConnector() |
TransportConnector(TransportServer server) |
Modifier and Type | Method and Description |
---|---|
void |
addPeerBroker(BrokerInfo info) |
ManagedTransportConnector |
asManagedConnector(ManagementContext context,
ObjectName connectorName)
Factory method to create a JMX managed version of this transport
connector
|
int |
connectionCount() |
protected Connection |
createConnection(Transport transport) |
protected DiscoveryAgent |
createDiscoveryAgent() |
protected TransportServer |
createTransportServer() |
Broker |
getBroker() |
BrokerInfo |
getBrokerInfo() |
BrokerService |
getBrokerService() |
protected ConnectionControl |
getConnectionControl() |
CopyOnWriteArrayList<TransportConnection> |
getConnections() |
URI |
getConnectUri() |
DiscoveryAgent |
getDiscoveryAgent() |
URI |
getDiscoveryUri() |
int |
getMaximumConsumersAllowedPerConnection() |
int |
getMaximumProducersAllowedPerConnection() |
MessageAuthorizationPolicy |
getMessageAuthorizationPolicy() |
String |
getName() |
LinkedList<String> |
getPeerBrokers() |
String |
getPublishableConnectString() |
URI |
getPublishableConnectURI() |
PublishedAddressPolicy |
getPublishedAddressPolicy()
Gets the currently configured policy for creating the published connection address of this
TransportConnector.
|
TransportServer |
getServer() |
ConnectorStatistics |
getStatistics() |
TaskRunnerFactory |
getTaskRunnerFactory() |
String |
getUpdateClusterFilter() |
URI |
getUri() |
boolean |
isAllowLinkStealing()
If enabled, older connections with the same clientID are stopped
|
boolean |
isAuditNetworkProducers() |
boolean |
isDisableAsyncDispatch() |
boolean |
isEnableStatusMonitor() |
boolean |
isRebalanceClusterClients() |
boolean |
isUpdateClusterClients() |
boolean |
isUpdateClusterClientsOnRemove() |
void |
onStarted(TransportConnection connection) |
void |
onStopped(TransportConnection connection) |
void |
removePeerBroker(BrokerInfo info) |
void |
setAllowLinkStealing(boolean allowLinkStealing) |
void |
setAuditNetworkProducers(boolean auditNetworkProducers)
Enable a producer audit on network connections, Traps the case of a missing send reply and resend.
|
void |
setBrokerInfo(BrokerInfo brokerInfo) |
void |
setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.
|
void |
setDisableAsyncDispatch(boolean disableAsyncDispatch) |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent) |
void |
setDiscoveryUri(URI discoveryUri) |
void |
setEnableStatusMonitor(boolean enableStatusMonitor) |
void |
setMaximumConsumersAllowedPerConnection(int maximumConsumersAllowedPerConnection) |
void |
setMaximumProducersAllowedPerConnection(int maximumProducersAllowedPerConnection) |
void |
setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
Sets the policy used to decide if the current connection is authorized to
consume a given message
|
void |
setName(String name) |
void |
setPublishedAddressPolicy(PublishedAddressPolicy publishedAddressPolicy)
Sets the configured policy for creating the published connection address of this
TransportConnector.
|
void |
setRebalanceClusterClients(boolean rebalanceClusterClients) |
void |
setServer(TransportServer server) |
void |
setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory) |
void |
setUpdateClusterClients(boolean updateClusterClients) |
void |
setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove) |
void |
setUpdateClusterFilter(String updateClusterFilter) |
void |
setUri(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() |
String |
toString() |
void |
updateClientClusterInfo()
Update all the connections with information
about the connected brokers in the cluster
|
protected final CopyOnWriteArrayList<TransportConnection> connections
protected TransportStatusDetector statusDector
public TransportConnector()
public TransportConnector(TransportServer server)
public CopyOnWriteArrayList<TransportConnection> getConnections()
public ManagedTransportConnector asManagedConnector(ManagementContext context, ObjectName connectorName) throws IOException, URISyntaxException
IOException
URISyntaxException
public BrokerInfo getBrokerInfo()
getBrokerInfo
in interface Connector
public void setBrokerInfo(BrokerInfo brokerInfo)
public TransportServer getServer() throws IOException, URISyntaxException
IOException
URISyntaxException
public void setServer(TransportServer server)
public void setUri(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 String getPublishableConnectString() throws Exception
Exception
public URI getPublishableConnectURI() throws Exception
Exception
protected Connection createConnection(Transport transport) throws IOException
IOException
protected TransportServer createTransportServer() throws IOException, URISyntaxException
IOException
URISyntaxException
public DiscoveryAgent getDiscoveryAgent() throws IOException
IOException
protected DiscoveryAgent createDiscoveryAgent() throws IOException
IOException
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
public URI getDiscoveryUri()
public void setDiscoveryUri(URI discoveryUri)
public URI getConnectUri() throws IOException, URISyntaxException
IOException
URISyntaxException
public void onStarted(TransportConnection connection)
public void onStopped(TransportConnection connection)
protected ConnectionControl getConnectionControl()
public void addPeerBroker(BrokerInfo info)
public void removePeerBroker(BrokerInfo info)
public LinkedList<String> getPeerBrokers()
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 String getUpdateClusterFilter()
getUpdateClusterFilter
in interface Connector
public void setUpdateClusterFilter(String updateClusterFilter)
updateClusterFilter
- the updateClusterFilter to setpublic int connectionCount()
connectionCount
in interface Connector
public boolean isAllowLinkStealing()
Connector
isAllowLinkStealing
in interface Connector
public void setAllowLinkStealing(boolean allowLinkStealing)
public boolean isAuditNetworkProducers()
public void setAuditNetworkProducers(boolean auditNetworkProducers)
auditNetworkProducers
- public int getMaximumProducersAllowedPerConnection()
public void setMaximumProducersAllowedPerConnection(int maximumProducersAllowedPerConnection)
public int getMaximumConsumersAllowedPerConnection()
public void setMaximumConsumersAllowedPerConnection(int maximumConsumersAllowedPerConnection)
public PublishedAddressPolicy getPublishedAddressPolicy()
public void setPublishedAddressPolicy(PublishedAddressPolicy publishedAddressPolicy)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.