org.apache.activemq.network.jms
Class JmsConnector
java.lang.Object
org.apache.activemq.network.jms.JmsConnector
- All Implemented Interfaces:
- Service
- Direct Known Subclasses:
- JmsQueueConnector, JmsTopicConnector
public abstract class JmsConnector
- extends java.lang.Object
- implements Service
This bridge joins the gap between foreign JMS providers and ActiveMQ As some
JMS providers are still only 1.0.1 compliant, this bridge itself aimed to be
JMS 1.0.2 compliant.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
jndiLocalTemplate
protected org.springframework.jndi.JndiTemplate jndiLocalTemplate
jndiOutboundTemplate
protected org.springframework.jndi.JndiTemplate jndiOutboundTemplate
inboundMessageConvertor
protected JmsMesageConvertor inboundMessageConvertor
outboundMessageConvertor
protected JmsMesageConvertor outboundMessageConvertor
initialized
protected java.util.concurrent.atomic.AtomicBoolean initialized
started
protected java.util.concurrent.atomic.AtomicBoolean started
embeddedConnectionFactory
protected ActiveMQConnectionFactory embeddedConnectionFactory
replyToDestinationCacheSize
protected int replyToDestinationCacheSize
outboundUsername
protected java.lang.String outboundUsername
outboundPassword
protected java.lang.String outboundPassword
localUsername
protected java.lang.String localUsername
localPassword
protected java.lang.String localPassword
outboundClientId
protected java.lang.String outboundClientId
localClientId
protected java.lang.String localClientId
replyToBridges
protected LRUCache replyToBridges
JmsConnector
public JmsConnector()
init
public boolean init()
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Throws:
java.lang.Exception
clearBridges
public void clearBridges()
createReplyToBridge
protected abstract javax.jms.Destination createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection consumerConnection,
javax.jms.Connection producerConnection)
setBrokerService
public void setBrokerService(BrokerService service)
- One way to configure the local connection - this is called by The
BrokerService when the Connector is embedded
- Parameters:
service
-
getJndiLocalTemplate
public org.springframework.jndi.JndiTemplate getJndiLocalTemplate()
- Returns:
- Returns the jndiTemplate.
setJndiLocalTemplate
public void setJndiLocalTemplate(org.springframework.jndi.JndiTemplate jndiTemplate)
- Parameters:
jndiTemplate
- The jndiTemplate to set.
getJndiOutboundTemplate
public org.springframework.jndi.JndiTemplate getJndiOutboundTemplate()
- Returns:
- Returns the jndiOutboundTemplate.
setJndiOutboundTemplate
public void setJndiOutboundTemplate(org.springframework.jndi.JndiTemplate jndiOutboundTemplate)
- Parameters:
jndiOutboundTemplate
- The jndiOutboundTemplate to set.
getInboundMessageConvertor
public JmsMesageConvertor getInboundMessageConvertor()
- Returns:
- Returns the inboundMessageConvertor.
setInboundMessageConvertor
public void setInboundMessageConvertor(JmsMesageConvertor jmsMessageConvertor)
- Parameters:
inboundMessageConvertor
- The inboundMessageConvertor to set.
getOutboundMessageConvertor
public JmsMesageConvertor getOutboundMessageConvertor()
- Returns:
- Returns the outboundMessageConvertor.
setOutboundMessageConvertor
public void setOutboundMessageConvertor(JmsMesageConvertor outboundMessageConvertor)
- Parameters:
outboundMessageConvertor
- The outboundMessageConvertor to set.
getReplyToDestinationCacheSize
public int getReplyToDestinationCacheSize()
- Returns:
- Returns the replyToDestinationCacheSize.
setReplyToDestinationCacheSize
public void setReplyToDestinationCacheSize(int replyToDestinationCacheSize)
- Parameters:
replyToDestinationCacheSize
- The replyToDestinationCacheSize to
set.
getLocalPassword
public java.lang.String getLocalPassword()
- Returns:
- Returns the localPassword.
setLocalPassword
public void setLocalPassword(java.lang.String localPassword)
- Parameters:
localPassword
- The localPassword to set.
getLocalUsername
public java.lang.String getLocalUsername()
- Returns:
- Returns the localUsername.
setLocalUsername
public void setLocalUsername(java.lang.String localUsername)
- Parameters:
localUsername
- The localUsername to set.
getOutboundPassword
public java.lang.String getOutboundPassword()
- Returns:
- Returns the outboundPassword.
setOutboundPassword
public void setOutboundPassword(java.lang.String outboundPassword)
- Parameters:
outboundPassword
- The outboundPassword to set.
getOutboundUsername
public java.lang.String getOutboundUsername()
- Returns:
- Returns the outboundUsername.
setOutboundUsername
public void setOutboundUsername(java.lang.String outboundUsername)
- Parameters:
outboundUsername
- The outboundUsername to set.
getOutboundClientId
public java.lang.String getOutboundClientId()
- Returns:
- the outboundClientId
setOutboundClientId
public void setOutboundClientId(java.lang.String outboundClientId)
- Parameters:
outboundClientId
- the outboundClientId to set
getLocalClientId
public java.lang.String getLocalClientId()
- Returns:
- the localClientId
setLocalClientId
public void setLocalClientId(java.lang.String localClientId)
- Parameters:
localClientId
- the localClientId to set
addInboundBridge
protected void addInboundBridge(DestinationBridge bridge)
addOutboundBridge
protected void addOutboundBridge(DestinationBridge bridge)
removeInboundBridge
protected void removeInboundBridge(DestinationBridge bridge)
removeOutboundBridge
protected void removeOutboundBridge(DestinationBridge bridge)
getName
public java.lang.String getName()
setName
public void setName(java.lang.String name)
restartProducerConnection
public abstract void restartProducerConnection()
throws javax.naming.NamingException,
javax.jms.JMSException
- Throws:
javax.naming.NamingException
javax.jms.JMSException
Copyright © 2005-2012. All Rights Reserved.