|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.ra.ActiveMQResourceAdapter
Knows how to connect to one ActiveMQ server. It can then activate endpoints and deliver messages to those enpoints using the connection configure in the resource adapter.
Must override equals and hashCode (JCA spec 16.4)
Constructor Summary | |
ActiveMQResourceAdapter()
|
Method Summary | |
void |
endpointActivation(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec)
|
void |
endpointDeactivation(MessageEndpointFactory endpointFactory,
ActivationSpec activationSpec)
|
boolean |
equals(Object o)
|
BootstrapContext |
getBootstrapContext()
|
String |
getBrokerXmlConfig()
|
String |
getClientid()
|
String |
getEndpointWorkerType()
|
ActiveMQConnectionRequestInfo |
getInfo()
|
String |
getPassword()
|
String |
getServerUrl()
|
Boolean |
getUseEmbeddedBroker()
|
Boolean |
getUseInboundSession()
|
String |
getUserName()
|
XAResource[] |
getXAResources(ActivationSpec[] activationSpecs)
We only connect to one resource manager per ResourceAdapter instance, so any ActivationSpec will return the same XAResource. |
int |
hashCode()
|
Boolean |
isUseEmbeddedBroker()
|
org.activemq.ActiveMQConnection |
makeConnection()
Return a connection using the default connection request info from the RAR deployment. |
org.activemq.ActiveMQConnection |
makeConnection(ActiveMQActivationSpec activationSpec)
|
org.activemq.ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo crInfo)
Return a connection using a specific connection request info. |
void |
setBrokerXmlConfig(String brokerXmlConfig)
Sets the XML configuration file used to configure the ActiveMQ broker via Spring if using embedded mode. |
void |
setClientid(String clientid)
|
void |
setEndpointWorkerType(String endpointWorkerType)
|
void |
setPassword(String password)
|
void |
setServerUrl(String url)
|
void |
setUseEmbeddedBroker(Boolean useEmbeddedBroker)
|
void |
setUseInboundSession(Boolean useInboundSession)
|
void |
setUserName(String userid)
|
void |
start(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(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException
start
in interface ResourceAdapter
ResourceAdapterInternalException
ResourceAdapter.start(javax.resource.spi.BootstrapContext)
public org.activemq.ActiveMQConnection makeConnection() throws JMSException
JMSException
public org.activemq.ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo crInfo) throws JMSException
JMSException
public org.activemq.ActiveMQConnection makeConnection(ActiveMQActivationSpec activationSpec) throws JMSException
activationSpec
-
JMSException
public void stop()
stop
in interface ResourceAdapter
ResourceAdapter.stop()
public BootstrapContext 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)
endpointDeactivation
in interface ResourceAdapter
ResourceAdapter.endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory,
javax.resource.spi.ActivationSpec)
public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException
getXAResources
in interface ResourceAdapter
ResourceException
ResourceAdapter.getXAResources(javax.resource.spi.ActivationSpec[])
public String getClientid()
public String getPassword()
public String getServerUrl()
public String getUserName()
public void setClientid(String clientid)
clientid
- public void setPassword(String password)
password
- public void setServerUrl(String url)
url
- public void setUserName(String userid)
userid
- public String getEndpointWorkerType()
public void setEndpointWorkerType(String endpointWorkerType)
endpointWorkerType
- The endpointWorkerType to set.public String 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.setUseEmbeddedBroker(Boolean)
public Boolean isUseEmbeddedBroker()
public void setUseEmbeddedBroker(Boolean useEmbeddedBroker)
public ActiveMQConnectionRequestInfo getInfo()
public boolean equals(Object o)
public int hashCode()
public Boolean getUseEmbeddedBroker()
public Boolean getUseInboundSession()
public void setUseInboundSession(Boolean useInboundSession)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |