public abstract class BroadcastTransportManager extends TransportManager
Purpose: Base class transport manager for broadcasting RCM protocols: JMS and Oc4jJGroups.
Description: The class doesn't use DiscoveryManager - instead the class (and it's ancestors) implement createConnections method that creates all the necessary connections. This method is called by RemoteCommendManager during initialization.
DEFAULT_CONTEXT_FACTORY, DEFAULT_DEDICATED_CONNECTION_KEY, DEFAULT_DEDICATED_CONNECTION_VALUE, DEFAULT_IIOP_URL_PORT, DEFAULT_IIOP_URL_PROTOCOL, DEFAULT_NAMING_SERVICE, DEFAULT_REMOVE_CONNECTION_ON_ERROR_MODE, DEFAULT_URL_PORT, DEFAULT_URL_PROTOCOL, DEFAULT_USER_NAME, JNDI_NAMING_SERVICE, REGISTRY_NAMING_SERVICE
Constructor and Description |
---|
BroadcastTransportManager() |
BroadcastTransportManager(RemoteCommandManager rcm) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionToExternalService(RemoteConnection connection)
INTERNAL:
Add a remote Connection to a remote service.
|
void |
connectBackToRemote(RemoteConnection connection)
INTERNAL:
Prepare receiving messages by registering this connection as a listener to the Subscriber.
|
RemoteConnection |
createConnection(ServiceId serviceId)
INTERNAL:
No-op implementation of super abstract method since there is only one connection to a known topic.
|
void |
createConnections()
INTERNAL:
BroadcastTransportManager doesn't use DiscoveryManager
(createDiscoveryManager method returns null) therefore
this method called during RCM initialization to create all the necessary connections.
|
DiscoveryManager |
createDiscoveryManager()
ADVANCED:
BroadcastTransportManager doesn't use DiscoveryManager - instead RemoteCommandManager
calls createConnections method during initialization.
|
java.lang.String |
getTopicName()
PUBLIC:
Return the topic name that this TransportManager will be connecting to.
|
void |
setTopicName(java.lang.String newTopicName)
PUBLIC:
Configure the Topic name for the Topic that this TransportManager will be connecting to.
|
createLocalConnection, discardConnections, getConnectionsToExternalServices, getConnectionsToExternalServicesForCommandPropagation, getConnectionToLocalHost, getContext, getEncryptedPassword, getInitialContextFactoryName, getLocalContextProperties, getNamingServiceType, getPassword, getRemoteCommandManager, getRemoteContextProperties, getRemoteHostContext, getUserName, initialize, removeAllConnectionsToExternalServices, removeConnectionToExternalService, removeLocalConnection, setConfig, setEncryptedPassword, setEncryptionClassName, setInitialContextFactoryName, setLocalContextProperties, setNamingServiceType, setPassword, setRemoteCommandManager, setRemoteContextProperties, setShouldRemoveConnectionOnError, setUserName, shouldRemoveConnectionOnError
public BroadcastTransportManager()
public BroadcastTransportManager(RemoteCommandManager rcm)
public DiscoveryManager createDiscoveryManager()
createDiscoveryManager
in class TransportManager
public void createConnections()
createConnections
in class TransportManager
public RemoteConnection createConnection(ServiceId serviceId)
createConnection
in class TransportManager
public void addConnectionToExternalService(RemoteConnection connection)
addConnectionToExternalService
in class TransportManager
public void connectBackToRemote(RemoteConnection connection) throws java.lang.Exception
connectBackToRemote
in class TransportManager
java.lang.Exception
public java.lang.String getTopicName()
public void setTopicName(java.lang.String newTopicName)
EclipseLink 2.6.3, "build v20160428-59c81c5" API Reference