public class ActiveMQResourceAdapter extends ActiveMQConnectionSupport implements MessageResourceAdapter
log
Constructor and Description |
---|
ActiveMQResourceAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
endpointActivation(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec) |
void |
endpointDeactivation(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec) |
boolean |
equals(Object o) |
BootstrapContext |
getBootstrapContext() |
String |
getBrokerXmlConfig() |
org.apache.activemq.ActiveMQConnectionFactory |
getConnectionFactory() |
XAResource[] |
getXAResources(ActivationSpec[] activationSpecs)
We only connect to one resource manager per ResourceAdapter instance, so
any ActivationSpec will return the same XAResource.
|
int |
hashCode() |
org.apache.activemq.ActiveMQConnection |
makeConnection() |
org.apache.activemq.ActiveMQConnection |
makeConnection(MessageActivationSpec activationSpec) |
void |
setBrokerXmlConfig(String brokerXmlConfig)
Sets the XML
configuration file used to configure the ActiveMQ broker via Spring
if using embedded mode.
|
void |
setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory aConnectionFactory) |
void |
start(BootstrapContext bootstrapContext) |
void |
stop() |
createConnectionFactory, defaultValue, emptyToNull, getClientid, getDurableTopicPrefetch, getInfo, getInitialRedeliveryDelay, getInputStreamPrefetch, getMaximumRedeliveries, getMaximumRedeliveryDelay, getOptimizeDurableTopicPrefetch, getPassword, getQueueBrowserPrefetch, getQueuePrefetch, getRedeliveryBackOffMultiplier, getRedeliveryUseExponentialBackOff, getServerUrl, getTopicPrefetch, getUseInboundSession, getUserName, getUseSessionArgs, isUseInboundSessionEnabled, isUseSessionArgs, makeConnection, makeConnection, notEqual, setAllPrefetchValues, setClientid, setDurableTopicPrefetch, setInfo, setInitialRedeliveryDelay, setInputStreamPrefetch, setKeyStore, setKeyStoreKeyPassword, setKeyStorePassword, setMaximumRedeliveries, setMaximumRedeliveryDelay, setOptimizeDurableTopicPrefetch, setPassword, setQueueBrowserPrefetch, setQueuePrefetch, setRedeliveryBackOffMultiplier, setRedeliveryUseExponentialBackOff, setServerUrl, setTopicPrefetch, setTrustStore, setTrustStorePassword, setUseInboundSession, setUserName, setUseSessionArgs
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getInfo, makeConnection
public ActiveMQResourceAdapter()
public void start(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException
start
in interface ResourceAdapter
ResourceAdapterInternalException
ResourceAdapter.start(javax.resource.spi.BootstrapContext)
public org.apache.activemq.ActiveMQConnection makeConnection() throws JMSException
JMSException
public org.apache.activemq.ActiveMQConnection makeConnection(MessageActivationSpec activationSpec) throws JMSException
makeConnection
in interface MessageResourceAdapter
activationSpec
- JMSException
public void stop()
stop
in interface ResourceAdapter
ResourceAdapter.stop()
public BootstrapContext getBootstrapContext()
getBootstrapContext
in interface MessageResourceAdapter
MessageResourceAdapter.getBootstrapContext()
public void endpointActivation(MessageEndpointFactory endpointFactory, ActivationSpec activationSpec) throws ResourceException
endpointActivation
in interface ResourceAdapter
ResourceException
ResourceAdapter.endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory,
javax.resource.spi.ActivationSpec)
public void endpointDeactivation(MessageEndpointFactory endpointFactory, ActivationSpec activationSpec)
public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException
getXAResources
in interface ResourceAdapter
ResourceException
ResourceAdapter.getXAResources(javax.resource.spi.ActivationSpec[])
public String getBrokerXmlConfig()
getBrokerXmlConfig
in interface MessageResourceAdapter
MessageResourceAdapter.getBrokerXmlConfig()
public void setBrokerXmlConfig(String brokerXmlConfig)
brokerXmlConfig
- is the filename which is assumed to be on the
classpath unless a URL is specified. So a value of
foo/bar.xml
would be assumed to be on the
classpath whereas file:dir/file.xml
would
use the file system. Any valid URL string is supported.public boolean equals(Object o)
equals
in class Object
Object.equals(java.lang.Object)
public int hashCode()
hashCode
in class Object
Object.hashCode()
public org.apache.activemq.ActiveMQConnectionFactory getConnectionFactory()
public void setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory aConnectionFactory)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.