Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Set to implement Serializable. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@372479 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Frederick G. Oconer 2006-01-26 08:20:39 +00:00
parent a9d3883dc8
commit b2b1e80b86
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQResourceAdapter.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq.ra;
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.HashMap; import java.util.HashMap;
import java.io.Serializable;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.JMSException; import javax.jms.JMSException;
@ -43,13 +44,13 @@ import org.apache.activemq.util.ServiceSupport;
* Knows how to connect to one ActiveMQ server. It can then activate endpoints * 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 * and deliver messages to those end points using the connection configure in the
* resource adapter. <p/>Must override equals and hashCode (JCA spec 16.4) * resource adapter. <p/>Must override equals and hashCode (JCA spec 16.4)
* *
* @org.xbean.XBean element="resourceAdapter" rootElement="true" * @org.xbean.XBean element="resourceAdapter" rootElement="true"
* description="The JCA Resource Adaptor for ActiveMQ" * description="The JCA Resource Adaptor for ActiveMQ"
* *
* @version $Revision$ * @version $Revision$
*/ */
public class ActiveMQResourceAdapter implements ResourceAdapter { public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
private final HashMap endpointWorkers = new HashMap(); private final HashMap endpointWorkers = new HashMap();
private final ActiveMQConnectionRequestInfo info = new ActiveMQConnectionRequestInfo(); private final ActiveMQConnectionRequestInfo info = new ActiveMQConnectionRequestInfo();
@ -85,7 +86,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter {
return makeConnection(info); return makeConnection(info);
} }
} }
/** /**
*/ */
public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo info) throws JMSException { public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo info) throws JMSException {
@ -121,10 +122,10 @@ public class ActiveMQResourceAdapter implements ResourceAdapter {
} }
/** /**
* @param info * @param info
* @return * @return
* @throws JMSException * @throws JMSException
* @throws URISyntaxException * @throws URISyntaxException
*/ */
synchronized private ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo info) throws JMSException { synchronized private ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo info) throws JMSException {
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(info.getServerUrl()); ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(info.getServerUrl());
@ -226,7 +227,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter {
/** /**
* We only connect to one resource manager per ResourceAdapter instance, so * We only connect to one resource manager per ResourceAdapter instance, so
* any ActivationSpec will return the same XAResource. * any ActivationSpec will return the same XAResource.
* *
* @see javax.resource.spi.ResourceAdapter#getXAResources(javax.resource.spi.ActivationSpec[]) * @see javax.resource.spi.ResourceAdapter#getXAResources(javax.resource.spi.ActivationSpec[])
*/ */
public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException { public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException {
@ -320,7 +321,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter {
* Sets the <a href="http://activemq.org/Xml+Configuration">XML * Sets the <a href="http://activemq.org/Xml+Configuration">XML
* configuration file </a> used to configure the ActiveMQ broker via Spring * configuration file </a> used to configure the ActiveMQ broker via Spring
* if using embedded mode. * if using embedded mode.
* *
* @param brokerXmlConfig * @param brokerXmlConfig
* is the filename which is assumed to be on the classpath unless * is the filename which is assumed to be on the classpath unless
* a URL is specified. So a value of <code>foo/bar.xml</code> * a URL is specified. So a value of <code>foo/bar.xml</code>
@ -439,7 +440,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter {
return true; return true;
} }
private boolean notEqual(Object o1, Object o2) { private boolean notEqual(Object o1, Object o2) {
return (o1 == null ^ o2 == null) || (o1 != null && !o1.equals(o2)); return (o1 == null ^ o2 == null) || (o1 != null && !o1.equals(o2));
} }