mirror of https://github.com/apache/activemq.git
refactoring package name from org.activemq to org.apache.activemq
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359585 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
662d3d2469
commit
fd4bb60c2d
|
@ -14,11 +14,11 @@
|
|||
manage ActiveMQ connection when run inside a J2EE app server.
|
||||
</description>
|
||||
|
||||
<package>org.activemq.ra</package>
|
||||
<package>org.apache.activemq.ra</package>
|
||||
<packageGroups>
|
||||
<packageGroup>
|
||||
<title>JCA Managed Connections and Resource Adapters</title>
|
||||
<packages>org.activemq.ra</packages>
|
||||
<packages>org.apache.activemq.ra</packages>
|
||||
</packageGroup>
|
||||
</packageGroups>
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.beans.IntrospectionException;
|
||||
import java.beans.PropertyDescriptor;
|
||||
|
@ -30,10 +30,10 @@ import javax.resource.spi.ActivationSpec;
|
|||
import javax.resource.spi.InvalidPropertyException;
|
||||
import javax.resource.spi.ResourceAdapter;
|
||||
|
||||
import org.activemq.command.ActiveMQDestination;
|
||||
import org.activemq.command.ActiveMQQueue;
|
||||
import org.activemq.command.ActiveMQTopic;
|
||||
import org.activemq.selector.SelectorParser;
|
||||
import org.apache.activemq.command.ActiveMQDestination;
|
||||
import org.apache.activemq.command.ActiveMQQueue;
|
||||
import org.apache.activemq.command.ActiveMQTopic;
|
||||
import org.apache.activemq.selector.SelectorParser;
|
||||
|
||||
/**
|
||||
* Configures the inbound JMS consumer specification using ActiveMQ
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.resource.spi.ConnectionRequestInfo;
|
||||
import java.io.Serializable;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.resource.spi.endpoint.MessageEndpointFactory;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.lang.reflect.Method;
|
||||
|
||||
|
@ -32,10 +32,10 @@ import javax.resource.spi.work.Work;
|
|||
import javax.resource.spi.work.WorkException;
|
||||
import javax.resource.spi.work.WorkManager;
|
||||
|
||||
import org.activemq.ActiveMQConnection;
|
||||
import org.activemq.command.ActiveMQDestination;
|
||||
import org.activemq.command.ActiveMQQueue;
|
||||
import org.activemq.command.ActiveMQTopic;
|
||||
import org.apache.activemq.ActiveMQConnection;
|
||||
import org.apache.activemq.command.ActiveMQDestination;
|
||||
import org.apache.activemq.command.ActiveMQQueue;
|
||||
import org.apache.activemq.command.ActiveMQTopic;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.io.PrintWriter;
|
||||
import java.util.ArrayList;
|
||||
|
@ -35,9 +35,9 @@ import javax.transaction.xa.XAResource;
|
|||
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
import org.activemq.ActiveMQConnection;
|
||||
import org.activemq.LocalTransactionEventListener;
|
||||
import org.activemq.TransactionContext;
|
||||
import org.apache.activemq.ActiveMQConnection;
|
||||
import org.apache.activemq.LocalTransactionEventListener;
|
||||
import org.apache.activemq.TransactionContext;
|
||||
|
||||
/**
|
||||
* ActiveMQManagedConnection maps to real physical connection to the
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.io.PrintWriter;
|
||||
import java.util.Iterator;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.net.URI;
|
||||
import java.net.URISyntaxException;
|
||||
|
@ -33,11 +33,11 @@ import javax.resource.spi.ResourceAdapterInternalException;
|
|||
import javax.resource.spi.endpoint.MessageEndpointFactory;
|
||||
import javax.transaction.xa.XAResource;
|
||||
|
||||
import org.activemq.ActiveMQConnection;
|
||||
import org.activemq.ActiveMQConnectionFactory;
|
||||
import org.activemq.broker.BrokerFactory;
|
||||
import org.activemq.broker.BrokerService;
|
||||
import org.activemq.util.ServiceSupport;
|
||||
import org.apache.activemq.ActiveMQConnection;
|
||||
import org.apache.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.broker.BrokerFactory;
|
||||
import org.apache.activemq.broker.BrokerService;
|
||||
import org.apache.activemq.util.ServiceSupport;
|
||||
|
||||
/**
|
||||
* Knows how to connect to one ActiveMQ server. It can then activate endpoints
|
|
@ -14,11 +14,11 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.*;
|
||||
|
||||
import org.activemq.ActiveMQConnectionMetaData;
|
||||
import org.apache.activemq.ActiveMQConnectionMetaData;
|
||||
|
||||
/**
|
||||
* A {@link Connection} implementation which can be used with the ActiveMQ JCA
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.Connection;
|
||||
import javax.jms.ConnectionFactory;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.JMSException;
|
||||
import javax.jms.MessageProducer;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
/**
|
||||
* A helper class used to provide access to the current active
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.Destination;
|
||||
import javax.jms.JMSException;
|
|
@ -16,7 +16,7 @@
|
|||
* limitations under the License.
|
||||
*
|
||||
**/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
|
||||
import javax.jms.*;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
/**
|
||||
* Thrown to indicate that a MessageEndpoint is no longer valid
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.JMSException;
|
||||
import javax.resource.ResourceException;
|
||||
|
@ -23,7 +23,7 @@ import javax.transaction.xa.XAException;
|
|||
import javax.transaction.xa.XAResource;
|
||||
import javax.transaction.xa.Xid;
|
||||
|
||||
import org.activemq.TransactionContext;
|
||||
import org.apache.activemq.TransactionContext;
|
||||
|
||||
/**
|
||||
* Used to provide a LocalTransaction and XAResource to a JMS session.
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
|
@ -35,9 +35,9 @@ import javax.jms.Topic;
|
|||
import javax.jms.TopicConnection;
|
||||
import javax.jms.TopicSession;
|
||||
|
||||
import org.activemq.ActiveMQQueueSession;
|
||||
import org.activemq.ActiveMQSession;
|
||||
import org.activemq.ActiveMQTopicSession;
|
||||
import org.apache.activemq.ActiveMQQueueSession;
|
||||
import org.apache.activemq.ActiveMQSession;
|
||||
import org.apache.activemq.ActiveMQTopicSession;
|
||||
|
||||
|
||||
/**
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
@ -43,7 +43,7 @@ import javax.jms.TopicPublisher;
|
|||
import javax.jms.TopicSession;
|
||||
import javax.jms.TopicSubscriber;
|
||||
|
||||
import org.activemq.ActiveMQSession;
|
||||
import org.apache.activemq.ActiveMQSession;
|
||||
|
||||
/**
|
||||
* Acts as a pass through proxy for a JMS Session object. It intercepts events
|
|
@ -14,16 +14,16 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.jms.JMSException;
|
||||
import javax.transaction.xa.XAException;
|
||||
import javax.transaction.xa.XAResource;
|
||||
import javax.transaction.xa.Xid;
|
||||
|
||||
import org.activemq.TransactionContext;
|
||||
import org.activemq.command.TransactionId;
|
||||
import org.activemq.transaction.Synchronization;
|
||||
import org.apache.activemq.TransactionContext;
|
||||
import org.apache.activemq.command.TransactionId;
|
||||
import org.apache.activemq.transaction.Synchronization;
|
||||
|
||||
/**
|
||||
* Allows us to switch between using a shared transaction context,
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.lang.reflect.Method;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.lang.reflect.Method;
|
||||
|
||||
|
@ -31,8 +31,8 @@ import javax.resource.spi.work.WorkException;
|
|||
import javax.resource.spi.work.WorkListener;
|
||||
import javax.resource.spi.work.WorkManager;
|
||||
|
||||
import org.activemq.ActiveMQSession;
|
||||
import org.activemq.ActiveMQSession.DeliveryListener;
|
||||
import org.apache.activemq.ActiveMQSession;
|
||||
import org.apache.activemq.ActiveMQSession.DeliveryListener;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
|
@ -28,10 +28,10 @@ import javax.jms.Session;
|
|||
import javax.resource.spi.UnavailableException;
|
||||
import javax.resource.spi.endpoint.MessageEndpoint;
|
||||
|
||||
import org.activemq.ActiveMQQueueSession;
|
||||
import org.activemq.ActiveMQSession;
|
||||
import org.activemq.ActiveMQTopicSession;
|
||||
import org.activemq.command.MessageDispatch;
|
||||
import org.apache.activemq.ActiveMQQueueSession;
|
||||
import org.apache.activemq.ActiveMQSession;
|
||||
import org.apache.activemq.ActiveMQTopicSession;
|
||||
import org.apache.activemq.command.MessageDispatch;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
|
@ -30,7 +30,7 @@
|
|||
<license-required>true</license-required>
|
||||
</license>
|
||||
<resourceadapter>
|
||||
<resourceadapter-class>org.activemq.ra.ActiveMQResourceAdapter</resourceadapter-class>
|
||||
<resourceadapter-class>org.apache.activemq.ra.ActiveMQResourceAdapter</resourceadapter-class>
|
||||
<config-property>
|
||||
<description>
|
||||
The URL to the ActiveMQ server that you want this connection to connect to. If using
|
||||
|
@ -87,25 +87,25 @@
|
|||
</config-property>
|
||||
<outbound-resourceadapter>
|
||||
<connection-definition>
|
||||
<managedconnectionfactory-class>org.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<connectionfactory-interface>javax.jms.ConnectionFactory</connectionfactory-interface>
|
||||
<connectionfactory-impl-class>org.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connection-interface>javax.jms.Connection</connection-interface>
|
||||
<connection-impl-class>org.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
<connection-impl-class>org.apache.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
</connection-definition>
|
||||
<connection-definition>
|
||||
<managedconnectionfactory-class>org.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<connectionfactory-interface>javax.jms.QueueConnectionFactory</connectionfactory-interface>
|
||||
<connectionfactory-impl-class>org.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connection-interface>javax.jms.QueueConnection</connection-interface>
|
||||
<connection-impl-class>org.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
<connection-impl-class>org.apache.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
</connection-definition>
|
||||
<connection-definition>
|
||||
<managedconnectionfactory-class>org.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
|
||||
<connectionfactory-interface>javax.jms.TopicConnectionFactory</connectionfactory-interface>
|
||||
<connectionfactory-impl-class>org.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
|
||||
<connection-interface>javax.jms.TopicConnection</connection-interface>
|
||||
<connection-impl-class>org.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
<connection-impl-class>org.apache.activemq.ra.JMSConnectionProxy</connection-impl-class>
|
||||
</connection-definition>
|
||||
<transaction-support>XATransaction</transaction-support>
|
||||
<authentication-mechanism>
|
||||
|
@ -119,7 +119,7 @@
|
|||
<messagelistener>
|
||||
<messagelistener-type>javax.jms.MessageListener</messagelistener-type>
|
||||
<activationspec>
|
||||
<activationspec-class>org.activemq.ra.ActiveMQActivationSpec</activationspec-class>
|
||||
<activationspec-class>org.apache.activemq.ra.ActiveMQActivationSpec</activationspec-class>
|
||||
|
||||
<required-config-property>
|
||||
<config-property-name>destination</config-property-name>
|
||||
|
@ -134,7 +134,7 @@
|
|||
</inbound-resourceadapter>
|
||||
<adminobject>
|
||||
<adminobject-interface>javax.jms.Queue</adminobject-interface>
|
||||
<adminobject-class>org.activemq.command.ActiveMQQueue</adminobject-class>
|
||||
<adminobject-class>org.apache.activemq.command.ActiveMQQueue</adminobject-class>
|
||||
<config-property>
|
||||
<config-property-name>PhysicalName</config-property-name>
|
||||
<config-property-type>java.lang.String</config-property-type>
|
||||
|
@ -142,7 +142,7 @@
|
|||
</adminobject>
|
||||
<adminobject>
|
||||
<adminobject-interface>javax.jms.Topic</adminobject-interface>
|
||||
<adminobject-class>org.activemq.command.ActiveMQTopic</adminobject-class>
|
||||
<adminobject-class>org.apache.activemq.command.ActiveMQTopic</adminobject-class>
|
||||
<config-property>
|
||||
<config-property-name>PhysicalName</config-property-name>
|
||||
<config-property-type>java.lang.String</config-property-type>
|
||||
|
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.beans.IntrospectionException;
|
||||
import java.beans.PropertyDescriptor;
|
||||
|
@ -28,7 +28,8 @@ import javax.resource.spi.InvalidPropertyException;
|
|||
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.activemq.command.ActiveMQDestination;
|
||||
import org.apache.activemq.command.ActiveMQDestination;
|
||||
import org.apache.activemq.ra.ActiveMQActivationSpec;
|
||||
|
||||
/**
|
||||
* @version $Revision$
|
|
@ -14,8 +14,12 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.apache.activemq.ra.ActiveMQActivationSpec;
|
||||
import org.apache.activemq.ra.ActiveMQEndpointActivationKey;
|
||||
import org.apache.activemq.ra.ActiveMQEndpointWorker;
|
||||
import org.apache.activemq.ra.ActiveMQResourceAdapter;
|
||||
import org.jmock.cglib.Mock;
|
||||
import org.jmock.cglib.MockObjectTestCase;
|
||||
import org.jmock.core.Constraint;
|
|
@ -14,7 +14,9 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.apache.activemq.ra.ActiveMQResourceAdapter;
|
||||
|
||||
import junit.framework.TestCase;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import javax.resource.spi.ConnectionEvent;
|
||||
import javax.resource.spi.ConnectionEventListener;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.io.ByteArrayOutputStream;
|
||||
import java.io.DataOutputStream;
|
||||
|
@ -44,8 +44,10 @@ import javax.transaction.xa.Xid;
|
|||
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.activemq.ActiveMQConnectionFactory;
|
||||
import org.activemq.command.ActiveMQQueue;
|
||||
import org.apache.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.command.ActiveMQQueue;
|
||||
import org.apache.activemq.ra.ActiveMQActivationSpec;
|
||||
import org.apache.activemq.ra.ActiveMQResourceAdapter;
|
||||
|
||||
import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
|
||||
import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.HashSet;
|
||||
|
@ -37,7 +37,11 @@ import javax.resource.spi.work.WorkManager;
|
|||
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.ra.ActiveMQConnectionRequestInfo;
|
||||
import org.apache.activemq.ra.ActiveMQManagedConnectionFactory;
|
||||
import org.apache.activemq.ra.ActiveMQResourceAdapter;
|
||||
import org.apache.activemq.ra.ManagedConnectionProxy;
|
||||
|
||||
|
||||
/**
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import java.util.Timer;
|
||||
|
||||
|
@ -36,7 +36,11 @@ import javax.resource.spi.work.WorkManager;
|
|||
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.ActiveMQConnectionFactory;
|
||||
import org.apache.activemq.ra.ActiveMQManagedConnection;
|
||||
import org.apache.activemq.ra.ActiveMQManagedConnectionFactory;
|
||||
import org.apache.activemq.ra.ActiveMQResourceAdapter;
|
||||
import org.apache.activemq.ra.ManagedConnectionProxy;
|
||||
|
||||
|
||||
/**
|
|
@ -14,8 +14,11 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.apache.activemq.ra.ActiveMQEndpointWorker;
|
||||
import org.apache.activemq.ra.InvalidMessageEndpointException;
|
||||
import org.apache.activemq.ra.MessageEndpointProxy;
|
||||
import org.jmock.MockObjectTestCase;
|
||||
import org.jmock.Mock;
|
||||
|
|
@ -14,7 +14,7 @@
|
|||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.activemq.ra;
|
||||
package org.apache.activemq.ra;
|
||||
|
||||
import org.jmock.MockObjectTestCase;
|
||||
|
|
@ -3,8 +3,8 @@
|
|||
#
|
||||
log4j.rootLogger=INFO, out
|
||||
|
||||
log4j.logger.org.activemq.spring=WARN
|
||||
log4j.logger.org.activemq=INFO
|
||||
log4j.logger.org.apache.activemq.spring=WARN
|
||||
log4j.logger.org.apache.activemq=INFO
|
||||
|
||||
# CONSOLE appender not used by default
|
||||
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
|
||||
|
|
Loading…
Reference in New Issue