public abstract class JmsConnector extends java.lang.Object implements Service
Modifier and Type | Field and Description |
---|---|
protected ActiveMQConnectionFactory |
embeddedConnectionFactory |
protected JmsMesageConvertor |
inboundMessageConvertor |
protected java.util.concurrent.atomic.AtomicBoolean |
initialized |
protected org.springframework.jndi.JndiTemplate |
jndiLocalTemplate |
protected org.springframework.jndi.JndiTemplate |
jndiOutboundTemplate |
protected java.lang.String |
localClientId |
protected java.lang.String |
localPassword |
protected java.lang.String |
localUsername |
protected java.lang.String |
outboundClientId |
protected JmsMesageConvertor |
outboundMessageConvertor |
protected java.lang.String |
outboundPassword |
protected java.lang.String |
outboundUsername |
protected LRUCache |
replyToBridges |
protected int |
replyToDestinationCacheSize |
protected java.util.concurrent.atomic.AtomicBoolean |
started |
Constructor and Description |
---|
JmsConnector() |
Modifier and Type | Method and Description |
---|---|
protected void |
addInboundBridge(DestinationBridge bridge) |
protected void |
addOutboundBridge(DestinationBridge bridge) |
void |
clearBridges() |
protected abstract javax.jms.Destination |
createReplyToBridge(javax.jms.Destination destination,
javax.jms.Connection consumerConnection,
javax.jms.Connection producerConnection) |
JmsMesageConvertor |
getInboundMessageConvertor() |
org.springframework.jndi.JndiTemplate |
getJndiLocalTemplate() |
org.springframework.jndi.JndiTemplate |
getJndiOutboundTemplate() |
java.lang.String |
getLocalClientId() |
java.lang.String |
getLocalPassword() |
java.lang.String |
getLocalUsername() |
java.lang.String |
getName() |
java.lang.String |
getOutboundClientId() |
JmsMesageConvertor |
getOutboundMessageConvertor() |
java.lang.String |
getOutboundPassword() |
java.lang.String |
getOutboundUsername() |
int |
getReplyToDestinationCacheSize() |
boolean |
init() |
protected void |
removeInboundBridge(DestinationBridge bridge) |
protected void |
removeOutboundBridge(DestinationBridge bridge) |
abstract void |
restartProducerConnection() |
void |
setBrokerService(BrokerService service)
One way to configure the local connection - this is called by The
BrokerService when the Connector is embedded
|
void |
setInboundMessageConvertor(JmsMesageConvertor jmsMessageConvertor) |
void |
setJndiLocalTemplate(org.springframework.jndi.JndiTemplate jndiTemplate) |
void |
setJndiOutboundTemplate(org.springframework.jndi.JndiTemplate jndiOutboundTemplate) |
void |
setLocalClientId(java.lang.String localClientId) |
void |
setLocalPassword(java.lang.String localPassword) |
void |
setLocalUsername(java.lang.String localUsername) |
void |
setName(java.lang.String name) |
void |
setOutboundClientId(java.lang.String outboundClientId) |
void |
setOutboundMessageConvertor(JmsMesageConvertor outboundMessageConvertor) |
void |
setOutboundPassword(java.lang.String outboundPassword) |
void |
setOutboundUsername(java.lang.String outboundUsername) |
void |
setReplyToDestinationCacheSize(int replyToDestinationCacheSize) |
void |
start() |
void |
stop() |
protected org.springframework.jndi.JndiTemplate jndiLocalTemplate
protected org.springframework.jndi.JndiTemplate jndiOutboundTemplate
protected JmsMesageConvertor inboundMessageConvertor
protected JmsMesageConvertor outboundMessageConvertor
protected java.util.concurrent.atomic.AtomicBoolean initialized
protected java.util.concurrent.atomic.AtomicBoolean started
protected ActiveMQConnectionFactory embeddedConnectionFactory
protected int replyToDestinationCacheSize
protected java.lang.String outboundUsername
protected java.lang.String outboundPassword
protected java.lang.String localUsername
protected java.lang.String localPassword
protected java.lang.String outboundClientId
protected java.lang.String localClientId
protected LRUCache replyToBridges
public JmsConnector()
public boolean init()
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public void clearBridges()
protected abstract javax.jms.Destination createReplyToBridge(javax.jms.Destination destination, javax.jms.Connection consumerConnection, javax.jms.Connection producerConnection)
public void setBrokerService(BrokerService service)
service
- public org.springframework.jndi.JndiTemplate getJndiLocalTemplate()
public void setJndiLocalTemplate(org.springframework.jndi.JndiTemplate jndiTemplate)
jndiTemplate
- The jndiTemplate to set.public org.springframework.jndi.JndiTemplate getJndiOutboundTemplate()
public void setJndiOutboundTemplate(org.springframework.jndi.JndiTemplate jndiOutboundTemplate)
jndiOutboundTemplate
- The jndiOutboundTemplate to set.public JmsMesageConvertor getInboundMessageConvertor()
public void setInboundMessageConvertor(JmsMesageConvertor jmsMessageConvertor)
inboundMessageConvertor
- The inboundMessageConvertor to set.public JmsMesageConvertor getOutboundMessageConvertor()
public void setOutboundMessageConvertor(JmsMesageConvertor outboundMessageConvertor)
outboundMessageConvertor
- The outboundMessageConvertor to set.public int getReplyToDestinationCacheSize()
public void setReplyToDestinationCacheSize(int replyToDestinationCacheSize)
replyToDestinationCacheSize
- The replyToDestinationCacheSize to
set.public java.lang.String getLocalPassword()
public void setLocalPassword(java.lang.String localPassword)
localPassword
- The localPassword to set.public java.lang.String getLocalUsername()
public void setLocalUsername(java.lang.String localUsername)
localUsername
- The localUsername to set.public java.lang.String getOutboundPassword()
public void setOutboundPassword(java.lang.String outboundPassword)
outboundPassword
- The outboundPassword to set.public java.lang.String getOutboundUsername()
public void setOutboundUsername(java.lang.String outboundUsername)
outboundUsername
- The outboundUsername to set.public java.lang.String getOutboundClientId()
public void setOutboundClientId(java.lang.String outboundClientId)
outboundClientId
- the outboundClientId to setpublic java.lang.String getLocalClientId()
public void setLocalClientId(java.lang.String localClientId)
localClientId
- the localClientId to setprotected void addInboundBridge(DestinationBridge bridge)
protected void addOutboundBridge(DestinationBridge bridge)
protected void removeInboundBridge(DestinationBridge bridge)
protected void removeOutboundBridge(DestinationBridge bridge)
public java.lang.String getName()
public void setName(java.lang.String name)
public abstract void restartProducerConnection() throws javax.naming.NamingException, javax.jms.JMSException
javax.naming.NamingException
javax.jms.JMSException
Copyright © 2005-2012. All Rights Reserved.