|
EclipseLink1.0 - 20080707 API Reference | ||||||||
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.JMSTopicTransportManager
public class JMSTopicTransportManager
Purpose: Provide a JMS transport implementation for the Remote Command Module (RCM).
Description: This class manages two connections to the same known JMS Topic: external connection for publishing, local connection for receiving messages.
Field Summary | |
---|---|
protected java.lang.String |
connectionFactoryName
|
static java.lang.String |
DEFAULT_CONNECTION_FACTORY
|
static java.lang.String |
DEFAULT_TOPIC
|
Fields inherited from class org.eclipse.persistence.sessions.coordination.broadcast.BroadcastTransportManager |
---|
topicName |
Constructor Summary | |
---|---|
JMSTopicTransportManager(RemoteCommandManager rcm)
|
Method Summary | |
---|---|
protected org.eclipse.persistence.internal.sessions.coordination.jms.JMSTopicRemoteConnection |
createConnection(boolean isLocalConnectionBeingCreated)
INTERNAL: This method creates JMSTopicRemoteConnection to be used by this TransportManager. |
void |
createConnections()
INTERNAL: JMTopicTransportManager doesn't use DiscoveryManager, therefore this method is called during RCM initialization to create all the necessary connections. |
void |
createExternalConnection()
INTERNAL: JMSTopicTransportManager has maximum one external connection. |
void |
createLocalConnection()
INTERNAL: JMSTopicTransportManager may have only two connections: one local and one external. |
java.util.Hashtable |
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. |
protected javax.jms.Topic |
getTopic(javax.naming.Context remoteHostContext)
INTERNAL: |
protected javax.jms.TopicConnectionFactory |
getTopicConnectionFactory(javax.naming.Context remoteHostContext)
INTERNAL: |
java.lang.String |
getTopicConnectionFactoryName()
PUBLIC: Return the JMS Topic Connection Factory Name for the JMS Topic connections. |
java.lang.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: caches local connection, set localConnection to null, closes the cached connection in a new thread. |
void |
setNamingServiceType(int serviceType)
ADVANCED: This funcation is not supported for naming service other than JNDI or TransportManager.JNDI_NAMING_SERVICE. |
void |
setTopicConnectionFactoryName(java.lang.String newTopicConnectionFactoryName)
PUBLIC: Configure the JMS Topic Connection Factory Name for the JMS Topic connections. |
void |
setTopicHostUrl(java.lang.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 |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected java.lang.String connectionFactoryName
public static final java.lang.String DEFAULT_TOPIC
public static final java.lang.String DEFAULT_CONNECTION_FACTORY
Constructor Detail |
---|
public JMSTopicTransportManager(RemoteCommandManager rcm)
Method Detail |
---|
public void createExternalConnection()
public void createLocalConnection()
createLocalConnection
in class TransportManager
protected org.eclipse.persistence.internal.sessions.coordination.jms.JMSTopicRemoteConnection createConnection(boolean isLocalConnectionBeingCreated) throws RemoteCommandManagerException
RemoteCommandManagerException
public void removeLocalConnection()
removeLocalConnection
in class TransportManager
public void createConnections()
createConnections
in class BroadcastTransportManager
public void setTopicConnectionFactoryName(java.lang.String newTopicConnectionFactoryName)
public java.lang.String getTopicConnectionFactoryName()
public void initialize()
initialize
in class TransportManager
public java.lang.String getTopicHostUrl()
public void setTopicHostUrl(java.lang.String jmsHostUrl)
public void setNamingServiceType(int serviceType)
setNamingServiceType
in class TransportManager
protected javax.jms.Topic getTopic(javax.naming.Context remoteHostContext)
protected javax.jms.TopicConnectionFactory getTopicConnectionFactory(javax.naming.Context remoteHostContext)
public java.util.Hashtable getConnectionsToExternalServicesForCommandPropagation()
getConnectionsToExternalServicesForCommandPropagation
in class TransportManager
|
EclipseLink1.0 - 20080707 API Reference | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |