public class SimpleJmsTopicConnector extends JmsConnector
connectionSerivce, embeddedConnectionFactory, failed, foreignConnection, foreignSideInitialized, inboundMessageConvertor, initialized, jndiLocalTemplate, jndiOutboundTemplate, localClientId, localConnection, localPassword, localSideInitialized, localUsername, outboundClientId, outboundMessageConvertor, outboundPassword, outboundUsername, preferJndiDestinationLookup, replyToBridges, replyToDestinationCacheSize, started
Constructor and Description |
---|
SimpleJmsTopicConnector() |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Topic |
createActiveMQTopic(javax.jms.TopicSession session,
String topicName) |
protected javax.jms.Topic |
createForeignTopic(javax.jms.TopicSession session,
String topicName) |
protected javax.jms.Destination |
createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection replyToProducerConnection,
javax.jms.Connection replyToConsumerConnection) |
InboundTopicBridge[] |
getInboundTopicBridges() |
String |
getLocalConnectionFactoryName() |
javax.jms.TopicConnection |
getLocalTopicConnection() |
javax.jms.TopicConnectionFactory |
getLocalTopicConnectionFactory() |
OutboundTopicBridge[] |
getOutboundTopicBridges() |
javax.jms.TopicConnection |
getOutboundTopicConnection() |
javax.jms.TopicConnectionFactory |
getOutboundTopicConnectionFactory() |
String |
getOutboundTopicConnectionFactoryName() |
protected void |
initializeForeignConnection()
Performs the work of connection to the foreign side of the Connection.
|
protected void |
initializeInboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection) |
protected void |
initializeInboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection) |
protected void |
initializeLocalConnection()
Performs the work of connection to the local side of the Connection.
|
protected void |
initializeOutboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection) |
protected void |
initializeOutboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection) |
void |
setInboundTopicBridges(InboundTopicBridge[] inboundTopicBridges) |
void |
setLocalConnectionFactoryName(String localConnectionFactoryName) |
void |
setLocalTopicConnection(javax.jms.TopicConnection localTopicConnection) |
void |
setLocalTopicConnectionFactory(javax.jms.TopicConnectionFactory localConnectionFactory) |
void |
setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges) |
void |
setOutboundTopicConnection(javax.jms.TopicConnection foreignTopicConnection) |
void |
setOutboundTopicConnectionFactory(javax.jms.TopicConnectionFactory foreignTopicConnectionFactory) |
void |
setOutboundTopicConnectionFactoryName(String foreignTopicConnectionFactoryName) |
addInboundBridge, addOutboundBridge, clearBridges, doConnectorInit, getForeignConnection, getInboundMessageConvertor, getJndiLocalTemplate, getJndiOutboundTemplate, getLocalClientId, getLocalConnection, getLocalPassword, getLocalUsername, getName, getOutboundClientId, getOutboundMessageConvertor, getOutboundPassword, getOutboundUsername, getReconnectionPolicy, getReplyToDestinationCacheSize, init, isConnected, isFailed, isPreferJndiDestinationLookup, removeInboundBridge, removeOutboundBridge, setBrokerService, setInboundMessageConvertor, setJndiLocalTemplate, setJndiOutboundTemplate, setLocalClientId, setLocalPassword, setLocalUsername, setName, setOutboundClientId, setOutboundMessageConvertor, setOutboundPassword, setOutboundUsername, setPreferJndiDestinationLookup, setReconnectionPolicy, setReplyToDestinationCacheSize, start, stop
public SimpleJmsTopicConnector()
public InboundTopicBridge[] getInboundTopicBridges()
public void setInboundTopicBridges(InboundTopicBridge[] inboundTopicBridges)
inboundTopicBridges
- The inboundTopicBridges to set.public OutboundTopicBridge[] getOutboundTopicBridges()
public void setOutboundTopicBridges(OutboundTopicBridge[] outboundTopicBridges)
outboundTopicBridges
- The outboundTopicBridges to set.public javax.jms.TopicConnectionFactory getLocalTopicConnectionFactory()
public void setLocalTopicConnectionFactory(javax.jms.TopicConnectionFactory localConnectionFactory)
localTopicConnectionFactory
- The localTopicConnectionFactory to set.public javax.jms.TopicConnectionFactory getOutboundTopicConnectionFactory()
public String getOutboundTopicConnectionFactoryName()
public void setOutboundTopicConnectionFactoryName(String foreignTopicConnectionFactoryName)
outboundTopicConnectionFactoryName
- The outboundTopicConnectionFactoryName to set.public String getLocalConnectionFactoryName()
public void setLocalConnectionFactoryName(String localConnectionFactoryName)
localConnectionFactoryName
- The localConnectionFactoryName to set.public javax.jms.TopicConnection getLocalTopicConnection()
public void setLocalTopicConnection(javax.jms.TopicConnection localTopicConnection)
localTopicConnection
- The localTopicConnection to set.public javax.jms.TopicConnection getOutboundTopicConnection()
public void setOutboundTopicConnection(javax.jms.TopicConnection foreignTopicConnection)
outboundTopicConnection
- The outboundTopicConnection to set.public void setOutboundTopicConnectionFactory(javax.jms.TopicConnectionFactory foreignTopicConnectionFactory)
outboundTopicConnectionFactory
- The outboundTopicConnectionFactory to set.protected void initializeForeignConnection() throws NamingException, javax.jms.JMSException
JmsConnector
This creates the initial connection to the foreign end of the JmsConnector
and then sets up all the destination bridges with the information needed to bridge
on the foreign side of the connection.
initializeForeignConnection
in class JmsConnector
NamingException
javax.jms.JMSException
protected void initializeLocalConnection() throws NamingException, javax.jms.JMSException
JmsConnector
This creates the initial connection to the local end of the JmsConnector
and then sets up all the destination bridges with the information needed to bridge
on the local side of the connection.
initializeLocalConnection
in class JmsConnector
NamingException
javax.jms.JMSException
protected void initializeInboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeInboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundDestinationBridgesOutboundSide(javax.jms.TopicConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected void initializeOutboundDestinationBridgesLocalSide(javax.jms.TopicConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Destination createReplyToBridge(javax.jms.Destination destination, javax.jms.Connection replyToProducerConnection, javax.jms.Connection replyToConsumerConnection)
createReplyToBridge
in class JmsConnector
protected javax.jms.Topic createActiveMQTopic(javax.jms.TopicSession session, String topicName) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Topic createForeignTopic(javax.jms.TopicSession session, String topicName) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.