public class ManagedTransportConnector extends TransportConnector
connections, statusDector
Constructor and Description |
---|
ManagedTransportConnector(ManagementContext context,
ObjectName connectorName,
TransportServer server) |
Modifier and Type | Method and Description |
---|---|
ManagedTransportConnector |
asManagedConnector(MBeanServer mbeanServer,
ObjectName connectorName) |
protected Connection |
createConnection(Transport transport) |
protected static long |
getNextConnectionId() |
addPeerBroker, asManagedConnector, connectionCount, createDiscoveryAgent, createTransportServer, getBroker, getBrokerInfo, getBrokerService, getConnectionControl, getConnections, getConnectUri, getDiscoveryAgent, getDiscoveryUri, getMaximumConsumersAllowedPerConnection, getMaximumProducersAllowedPerConnection, getMessageAuthorizationPolicy, getName, getPeerBrokers, getPublishableConnectString, getPublishableConnectString, getServer, getStatistics, getTaskRunnerFactory, getUpdateClusterFilter, getUri, isAuditNetworkProducers, isDisableAsyncDispatch, isEnableStatusMonitor, isRebalanceClusterClients, isUpdateClusterClients, isUpdateClusterClientsOnRemove, onStarted, onStopped, removePeerBroker, setAuditNetworkProducers, setBrokerInfo, setBrokerName, setBrokerService, setConnectUri, setDisableAsyncDispatch, setDiscoveryAgent, setDiscoveryUri, setEnableStatusMonitor, setMaximumConsumersAllowedPerConnection, setMaximumProducersAllowedPerConnection, setMessageAuthorizationPolicy, setName, setRebalanceClusterClients, setServer, setTaskRunnerFactory, setUpdateClusterClients, setUpdateClusterClientsOnRemove, setUpdateClusterFilter, setUri, start, stop, toString, updateClientClusterInfo
public ManagedTransportConnector(ManagementContext context, ObjectName connectorName, TransportServer server)
public ManagedTransportConnector asManagedConnector(MBeanServer mbeanServer, ObjectName connectorName) throws IOException, URISyntaxException
IOException
URISyntaxException
protected Connection createConnection(Transport transport) throws IOException
createConnection
in class TransportConnector
IOException
protected static long getNextConnectionId()
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.