|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.eclipse.persistence.sessions.coordination.TransportManager
org.eclipse.persistence.sessions.coordination.broadcast.BroadcastTransportManager
org.eclipse.persistence.sessions.coordination.jms.JMSPublishingTransportManager
public class JMSPublishingTransportManager
Purpose: Provide a transport implementation for the Remote Command Module (RCM) that publishes to a JMS topic.
Description: This class manages two connections: an external connection for publishing to JMS, and a local connection which can be used to process JMS messages received from an application JMS listener.
Field Summary | |
---|---|
static String |
DEFAULT_CONNECTION_FACTORY
|
static String |
DEFAULT_TOPIC
|
Fields inherited from class org.eclipse.persistence.sessions.coordination.TransportManager |
---|
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 Summary | |
---|---|
JMSPublishingTransportManager(RemoteCommandManager rcm)
PUBLIC: Creates a JMSPublishingOnlyTopicTransportManager |
Method Summary | |
---|---|
void |
createConnections()
INTERNAL: JMSTopicTransportManager doesn't use DiscoveryManager, therefore this method is called during RCM initialization to create all the necessary connections. |
void |
createExternalConnection()
INTERNAL: JMSPublishingTransportManager has maximum one external connection. |
void |
createLocalConnection()
INTERNAL: JMSPublishingTransportManager has only two connections: one local and one external. |
Hashtable |
getConnectionsToExternalServicesForCommandPropagation()
INTERNAL: In case there's no external connection attempts to create one. |
boolean |
getReuseJMSTopicPublisher()
PUBLIC: flag used to toggle between j2EE/JMS spec compliant behavior and legacy behavior. |
String |
getTopicConnectionFactoryName()
PUBLIC: Return the JMS Topic Connection Factory Name for the JMS Topic connections. |
String |
getTopicHostUrl()
PUBLIC: Return the URL of the machine on the network that hosts the JMS Topic. |
void |
initialize()
INTERNAL: Initialize default properties. |
void |
removeLocalConnection()
INTERNAL: No-op, as the local connection does not need to be removed from JMSPublishingTransportManager. |
void |
setNamingServiceType(int serviceType)
ADVANCED: This function is not supported for naming service other than JNDI or TransportManager.JNDI_NAMING_SERVICE. |
void |
setShouldReuseJMSTopicPublisher(boolean reuseJMSTopicPublisher)
PUBLIC: flag used to toggle between j2EE/JMS spec compliant behavior and legacy behavior. |
void |
setTopicConnectionFactoryName(String newTopicConnectionFactoryName)
PUBLIC: Configure the JMS Topic Connection Factory Name for the JMS Topic connections. |
void |
setTopicHostUrl(String jmsHostUrl)
PUBLIC: Configure the URL of the machine on the network that hosts the JMS Topic. |
Methods inherited from class org.eclipse.persistence.sessions.coordination.broadcast.BroadcastTransportManager |
---|
addConnectionToExternalService, connectBackToRemote, createConnection, createDiscoveryManager, getTopicName, setTopicName |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String DEFAULT_TOPIC
public static final String DEFAULT_CONNECTION_FACTORY
Constructor Detail |
---|
public JMSPublishingTransportManager(RemoteCommandManager rcm)
Method Detail |
---|
public void createConnections()
createConnections
in class BroadcastTransportManager
public void createExternalConnection()
public void createLocalConnection()
createLocalConnection
in class TransportManager
public Hashtable getConnectionsToExternalServicesForCommandPropagation()
getConnectionsToExternalServicesForCommandPropagation
in class TransportManager
public boolean getReuseJMSTopicPublisher()
public String getTopicConnectionFactoryName()
public String getTopicHostUrl()
public void initialize()
initialize
in class TransportManager
public void removeLocalConnection()
removeLocalConnection
in class TransportManager
public void setNamingServiceType(int serviceType)
setNamingServiceType
in class TransportManager
public void setShouldReuseJMSTopicPublisher(boolean reuseJMSTopicPublisher)
reuseJMSTopicPublisher
- public void setTopicConnectionFactoryName(String newTopicConnectionFactoryName)
public void setTopicHostUrl(String jmsHostUrl)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |