public class JMSTopicTransportManager extends JMSPublishingTransportManager
Purpose: Provide a transport implementation for the Remote Command Module (RCM) that both publishes and subscribes to a JMS topic.
Description: This class manages two connections to the same known JMS Topic: external connection for publishing, local connection for receiving messages.
connectionFactoryName, DEFAULT_CONNECTION_FACTORY, DEFAULT_TOPIC, reuseJMSTopicPublishertopicNameconnectionsToExternalServices, 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, localConnection, localContextProperties, namingServiceType, rcm, REGISTRY_NAMING_SERVICE, remoteContextProperties, securableObjectHolder, shouldRemoveConnectionOnError| Constructor and Description |
|---|
JMSTopicTransportManager(RemoteCommandManager rcm) |
| Modifier and Type | Method and Description |
|---|---|
void |
createLocalConnection()
INTERNAL:
JMSTopicTransportManager may have only two connections: one local and one external.
|
java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.coordination.RemoteConnection> |
getConnectionsToExternalServicesForCommandPropagation()
INTERNAL:
In case there's no external connection attempts to create one,
if that's successful then (in case there is no local connection, too)
attempts to create local connection in a separate thread.
|
void |
removeLocalConnection()
INTERNAL:
caches local connection, set localConnection to null, closes the cached connection in a new thread.
|
createConnection, createConnections, createExternalConnection, getReuseJMSTopicPublisher, getTopic, getTopicConnectionFactory, getTopicConnectionFactoryName, getTopicHostUrl, initialize, setNamingServiceType, setShouldReuseJMSTopicPublisher, setTopicConnectionFactoryName, setTopicHostUrladdConnectionToExternalService, connectBackToRemote, createConnection, createDiscoveryManager, getTopicName, setTopicNamedecrypt, discardConnections, encrypt, getConnectionsToExternalServices, getConnectionToLocalHost, getContext, getEncryptedPassword, getInitialContextFactoryName, getLocalContextProperties, getNamingServiceType, getPassword, getRemoteCommandManager, getRemoteContextProperties, getRemoteHostContext, getUserName, hasPassword, removeAllConnectionsToExternalServices, removeConnectionToExternalService, setConfig, setEncryptedPassword, setEncryptionClassName, setInitialContextFactoryName, setLocalContextProperties, setPassword, setRemoteCommandManager, setRemoteContextProperties, setShouldRemoveConnectionOnError, setUserName, shouldRemoveConnectionOnErrorpublic JMSTopicTransportManager(RemoteCommandManager rcm)
public void createLocalConnection()
createLocalConnection in class JMSPublishingTransportManagerpublic java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.coordination.RemoteConnection> getConnectionsToExternalServicesForCommandPropagation()
getConnectionsToExternalServicesForCommandPropagation in class JMSPublishingTransportManagerpublic void removeLocalConnection()
removeLocalConnection in class JMSPublishingTransportManager