|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.ra.ActiveMQResourceAdapter
public class ActiveMQResourceAdapter
Knows how to connect to one ActiveMQ server. It can then activate endpoints and deliver messages to those end points using the connection configure in the resource adapter.
Must override equals and hashCode (JCA spec 16.4)
Constructor Summary | |
---|---|
ActiveMQResourceAdapter()
|
Method Summary | |
---|---|
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()
|
java.lang.String |
getClientid()
|
ActiveMQConnectionFactory |
getConnectionFactory()
|
java.lang.Integer |
getDurableTopicPrefetch()
|
ActiveMQConnectionRequestInfo |
getInfo()
|
java.lang.Long |
getInitialRedeliveryDelay()
|
java.lang.Integer |
getInputStreamPrefetch()
|
java.lang.Integer |
getMaximumRedeliveries()
|
java.lang.String |
getPassword()
|
java.lang.Integer |
getQueueBrowserPrefetch()
|
java.lang.Integer |
getQueuePrefetch()
|
java.lang.Short |
getRedeliveryBackOffMultiplier()
|
java.lang.Boolean |
getRedeliveryUseExponentialBackOff()
|
java.lang.String |
getServerUrl()
|
java.lang.Integer |
getTopicPrefetch()
|
java.lang.Boolean |
getUseInboundSession()
|
java.lang.String |
getUserName()
|
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()
|
boolean |
isUseInboundSessionEnabled()
|
ActiveMQConnection |
makeConnection()
|
ActiveMQConnection |
makeConnection(ActiveMQActivationSpec activationSpec)
|
ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo info)
|
ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo info,
ActiveMQConnectionFactory connectionFactory)
|
void |
setAllPrefetchValues(java.lang.Integer i)
|
void |
setBrokerXmlConfig(java.lang.String brokerXmlConfig)
Sets the XML configuration file used to configure the ActiveMQ broker via Spring if using embedded mode. |
void |
setClientid(java.lang.String clientid)
|
void |
setConnectionFactory(ActiveMQConnectionFactory connectionFactory)
This allows a connection factory to be configured and shared between a ResourceAdaptor and outbound messaging. |
void |
setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
|
void |
setInitialRedeliveryDelay(java.lang.Long value)
|
void |
setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
|
void |
setMaximumRedeliveries(java.lang.Integer value)
|
void |
setPassword(java.lang.String password)
|
void |
setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
|
void |
setQueuePrefetch(java.lang.Integer queuePrefetch)
|
void |
setRedeliveryBackOffMultiplier(java.lang.Short value)
|
void |
setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
|
void |
setServerUrl(java.lang.String url)
|
void |
setTopicPrefetch(java.lang.Integer topicPrefetch)
|
void |
setUseInboundSession(java.lang.Boolean useInboundSession)
|
void |
setUserName(java.lang.String userid)
|
void |
start(javax.resource.spi.BootstrapContext bootstrapContext)
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ActiveMQResourceAdapter()
Method Detail |
---|
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
public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo info) throws javax.jms.JMSException
javax.jms.JMSException
public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo info, ActiveMQConnectionFactory connectionFactory) throws javax.jms.JMSException
javax.jms.JMSException
public ActiveMQConnection makeConnection(ActiveMQActivationSpec activationSpec) throws javax.jms.JMSException
activationSpec
-
javax.jms.JMSException
public void stop()
stop
in interface javax.resource.spi.ResourceAdapter
ResourceAdapter.stop()
public javax.resource.spi.BootstrapContext 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 getClientid()
public java.lang.String getPassword()
public java.lang.String getServerUrl()
public java.lang.String getUserName()
public void setClientid(java.lang.String clientid)
clientid
- public void setPassword(java.lang.String password)
password
- public void setServerUrl(java.lang.String url)
url
- public void setUserName(java.lang.String userid)
userid
- public java.lang.String 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.#setUseEmbeddedBroker(Boolean)
public java.lang.Integer getDurableTopicPrefetch()
public java.lang.Long getInitialRedeliveryDelay()
public java.lang.Integer getInputStreamPrefetch()
public java.lang.Integer getMaximumRedeliveries()
public java.lang.Integer getQueueBrowserPrefetch()
public java.lang.Integer getQueuePrefetch()
public java.lang.Short getRedeliveryBackOffMultiplier()
public java.lang.Boolean getRedeliveryUseExponentialBackOff()
public java.lang.Integer getTopicPrefetch()
public boolean isUseInboundSessionEnabled()
public void setAllPrefetchValues(java.lang.Integer i)
public void setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
public void setInitialRedeliveryDelay(java.lang.Long value)
public void setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
public void setMaximumRedeliveries(java.lang.Integer value)
public void setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
public void setQueuePrefetch(java.lang.Integer queuePrefetch)
public void setRedeliveryBackOffMultiplier(java.lang.Short value)
public void setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
public void setTopicPrefetch(java.lang.Integer topicPrefetch)
public ActiveMQConnectionRequestInfo getInfo()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.Boolean getUseInboundSession()
public void setUseInboundSession(java.lang.Boolean useInboundSession)
public ActiveMQConnectionFactory getConnectionFactory()
public void setConnectionFactory(ActiveMQConnectionFactory connectionFactory)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |