public class MulticastNetworkConnector extends NetworkConnector
Transport
instance such as when using multicast.
This implementation does not depend on multicast at all; any other group
based transport could be used.bridges, connectionFilter, localURI, serviceSupport
Constructor and Description |
---|
MulticastNetworkConnector() |
MulticastNetworkConnector(URI remoteURI) |
Modifier and Type | Method and Description |
---|---|
protected DemandForwardingBridgeSupport |
createBridge(Transport local,
Transport remote) |
DemandForwardingBridgeSupport |
getBridge() |
Transport |
getLocalTransport() |
Transport |
getRemoteTransport() |
URI |
getRemoteURI() |
protected void |
handleStart() |
protected void |
handleStop(ServiceStopper stopper) |
void |
setBridge(DemandForwardingBridgeSupport bridge) |
void |
setLocalTransport(Transport localTransport) |
void |
setRemoteTransport(Transport remoteTransport)
Sets the remote transport implementation
|
void |
setRemoteURI(URI remoteURI)
Sets the remote transport URI to some group transport like
multicast://address:port |
String |
toString() |
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getObjectName, getStaticallyIncludedDestinations, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalUri, setObjectName, setStaticallyIncludedDestinations, start, stop, unregisterNetworkBridgeMBean
getBrokerName, getBrokerURL, getConsumerPriorityBase, getDestinationFilter, getName, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isAlwaysSyncSend, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUserName
public MulticastNetworkConnector()
public MulticastNetworkConnector(URI remoteURI)
public DemandForwardingBridgeSupport getBridge()
public void setBridge(DemandForwardingBridgeSupport bridge)
public Transport getLocalTransport()
public void setLocalTransport(Transport localTransport)
public Transport getRemoteTransport()
public void setRemoteTransport(Transport remoteTransport)
public URI getRemoteURI()
public void setRemoteURI(URI remoteURI)
multicast://address:port
protected void handleStart() throws Exception
handleStart
in class NetworkConnector
Exception
protected void handleStop(ServiceStopper stopper) throws Exception
handleStop
in class NetworkConnector
Exception
protected DemandForwardingBridgeSupport createBridge(Transport local, Transport remote)
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.