public class ActiveMQResourceAdapter extends ActiveMQConnectionSupport implements MessageResourceAdapter
log
Constructor and Description |
---|
ActiveMQResourceAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
javax.resource.spi.ActivationSpec activationSpec) |
void |
endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
javax.resource.spi.ActivationSpec activationSpec) |
boolean |
equals(java.lang.Object o) |
javax.resource.spi.BootstrapContext |
getBootstrapContext() |
java.lang.String |
getBrokerXmlConfig() |
ActiveMQConnectionFactory |
getConnectionFactory() |
javax.transaction.xa.XAResource[] |
getXAResources(javax.resource.spi.ActivationSpec[] activationSpecs)
We only connect to one resource manager per ResourceAdapter instance, so
any ActivationSpec will return the same XAResource.
|
int |
hashCode() |
ActiveMQConnection |
makeConnection() |
ActiveMQConnection |
makeConnection(MessageActivationSpec activationSpec) |
void |
setBrokerXmlConfig(java.lang.String brokerXmlConfig)
Sets the XML
configuration file used to configure the ActiveMQ broker via Spring
if using embedded mode.
|
void |
setConnectionFactory(ActiveMQConnectionFactory aConnectionFactory) |
void |
start(javax.resource.spi.BootstrapContext bootstrapContext) |
void |
stop() |
createConnectionFactory, defaultValue, emptyToNull, getClientid, getDurableTopicPrefetch, getInfo, getInitialRedeliveryDelay, getInputStreamPrefetch, getMaximumRedeliveries, getMaximumRedeliveryDelay, getPassword, getQueueBrowserPrefetch, getQueuePrefetch, getRedeliveryBackOffMultiplier, getRedeliveryUseExponentialBackOff, getServerUrl, getTopicPrefetch, getUseInboundSession, getUserName, isUseInboundSessionEnabled, makeConnection, makeConnection, notEqual, setAllPrefetchValues, setClientid, setDurableTopicPrefetch, setInfo, setInitialRedeliveryDelay, setInputStreamPrefetch, setMaximumRedeliveries, setMaximumRedeliveryDelay, setPassword, setQueueBrowserPrefetch, setQueuePrefetch, setRedeliveryBackOffMultiplier, setRedeliveryUseExponentialBackOff, setServerUrl, setTopicPrefetch, setUseInboundSession, setUserName
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getInfo, makeConnection
public ActiveMQResourceAdapter()
public void start(javax.resource.spi.BootstrapContext bootstrapContext) throws javax.resource.spi.ResourceAdapterInternalException
start
in interface javax.resource.spi.ResourceAdapter
javax.resource.spi.ResourceAdapterInternalException
ResourceAdapter.start(javax.resource.spi.BootstrapContext)
public ActiveMQConnection makeConnection() throws javax.jms.JMSException
javax.jms.JMSException
org.apache.activemq.ra.MessageResourceAdapter#makeConnection()
public ActiveMQConnection makeConnection(MessageActivationSpec activationSpec) throws javax.jms.JMSException
makeConnection
in interface MessageResourceAdapter
activationSpec
- javax.jms.JMSException
public void stop()
stop
in interface javax.resource.spi.ResourceAdapter
ResourceAdapter.stop()
public javax.resource.spi.BootstrapContext getBootstrapContext()
getBootstrapContext
in interface MessageResourceAdapter
MessageResourceAdapter.getBootstrapContext()
public void endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec activationSpec) throws javax.resource.ResourceException
endpointActivation
in interface javax.resource.spi.ResourceAdapter
javax.resource.ResourceException
ResourceAdapter.endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory,
javax.resource.spi.ActivationSpec)
public void endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec activationSpec)
endpointDeactivation
in interface javax.resource.spi.ResourceAdapter
ResourceAdapter.endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory,
javax.resource.spi.ActivationSpec)
public javax.transaction.xa.XAResource[] getXAResources(javax.resource.spi.ActivationSpec[] activationSpecs) throws javax.resource.ResourceException
getXAResources
in interface javax.resource.spi.ResourceAdapter
javax.resource.ResourceException
ResourceAdapter.getXAResources(javax.resource.spi.ActivationSpec[])
public java.lang.String getBrokerXmlConfig()
getBrokerXmlConfig
in interface MessageResourceAdapter
MessageResourceAdapter.getBrokerXmlConfig()
public void setBrokerXmlConfig(java.lang.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(java.lang.Object o)
equals
in class java.lang.Object
Object.equals(java.lang.Object)
public int hashCode()
hashCode
in class java.lang.Object
Object.hashCode()
public ActiveMQConnectionFactory getConnectionFactory()
public void setConnectionFactory(ActiveMQConnectionFactory aConnectionFactory)
Copyright © 2005-2017. All Rights Reserved.