You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2014/11/19 00:38:13 UTC
[20/52] [abbrv] [partial] activemq-6 git commit: ACTIVEMQ6-4 Rename
HornetQ* classes to ActiveMQ*
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRALogger.java
----------------------------------------------------------------------
diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRALogger.java b/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRALogger.java
deleted file mode 100644
index d582e50..0000000
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRALogger.java
+++ /dev/null
@@ -1,122 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-
-package org.apache.activemq.ra;
-
-import org.apache.activemq.ra.inflow.HornetQActivationSpec;
-import org.jboss.logging.BasicLogger;
-import org.jboss.logging.Logger;
-import org.jboss.logging.annotations.Cause;
-import org.jboss.logging.annotations.LogMessage;
-import org.jboss.logging.annotations.Message;
-import org.jboss.logging.annotations.MessageLogger;
-
-/**
- * Logger Code 15
- * <p/>
- * each message id must be 6 digits long starting with 15, the 3rd digit donates
- * the level so
- * <p/>
- * <pre>
- * INF0 1
- * WARN 2
- * DEBUG 3
- * ERROR 4
- * TRACE 5
- * FATAL 6
- * </pre>
- * <p/>
- * so an INFO message would be 151000 to 151999
- *
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 3/15/12
- */
-@MessageLogger(projectCode = "HQ")
-public interface HornetQRALogger extends BasicLogger
-{
- /**
- * The default logger.
- */
- HornetQRALogger LOGGER = Logger.getMessageLogger(HornetQRALogger.class, HornetQRALogger.class.getPackage().getName());
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151000, value = "awaiting topic/queue creation {0}", format = Message.Format.MESSAGE_FORMAT)
- void awaitingTopicQueueCreation(String destination);
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151001, value = "Attempting to reconnect {0}", format = Message.Format.MESSAGE_FORMAT)
- void attemptingReconnect(HornetQActivationSpec spec);
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151002, value = "Reconnected with HornetQ", format = Message.Format.MESSAGE_FORMAT)
- void reconnected();
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151003, value = "HornetQ resource adaptor stopped", format = Message.Format.MESSAGE_FORMAT)
- void raStopped();
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151004, value = "Instantiating {0} \"{1}\" directly since UseJNDI=false.", format = Message.Format.MESSAGE_FORMAT)
- void instantiatingDestination(String destinationType, String destination);
-
- @LogMessage(level = Logger.Level.INFO)
- @Message(id = 151005, value = "awaiting HornetQ Server availability", format = Message.Format.MESSAGE_FORMAT)
- void awaitingJMSServerCreation();
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152000, value = "It wasn''t possible to lookup for a Transaction Manager through the configured properties TransactionManagerLocatorClass and TransactionManagerLocatorMethod\nHornetQ Resource Adapter won''t be able to set and verify transaction timeouts in certain cases.", format = Message.Format.MESSAGE_FORMAT)
- void noTXLocator();
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152001, value = "problem resetting HornetQ xa session after failure", format = Message.Format.MESSAGE_FORMAT)
- void problemResettingXASession();
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152002, value = "Unable to roll local transaction back", format = Message.Format.MESSAGE_FORMAT)
- void unableToRollbackTX();
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152003, value = "unable to reset session after failure", format = Message.Format.MESSAGE_FORMAT)
- void unableToResetSession();
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152004, value = "Handling JMS exception failure", format = Message.Format.MESSAGE_FORMAT)
- void handlingJMSFailure(@Cause Exception e);
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152005, value = "Failure in HornetQ activation {0}", format = Message.Format.MESSAGE_FORMAT)
- void failureInActivation(@Cause Throwable t, HornetQActivationSpec spec);
-
- @LogMessage(level = Logger.Level.WARN)
- @Message(id = 152006, value = "Unable to call after delivery", format = Message.Format.MESSAGE_FORMAT)
- void unableToCallAfterDelivery(@Cause Exception e);
-
- @LogMessage(level = Logger.Level.ERROR)
- @Message(id = 154000, value = "Error while creating object Reference.", format = Message.Format.MESSAGE_FORMAT)
- void errorCreatingReference(@Cause Exception e);
-
- @LogMessage(level = Logger.Level.ERROR)
- @Message(id = 154001, value = "Unable to stop HornetQ resource adapter.", format = Message.Format.MESSAGE_FORMAT)
- void errorStoppingRA(@Cause Exception e);
-
- @LogMessage(level = Logger.Level.ERROR)
- @Message(id = 154003, value = "Unable to reconnect {0}", format = Message.Format.MESSAGE_FORMAT)
- void errorReconnecting(@Cause Throwable t, HornetQActivationSpec spec);
-
- @LogMessage(level = Logger.Level.ERROR)
- @Message(id = 154004, value = "Failed to deliver message", format = Message.Format.MESSAGE_FORMAT)
- void errorDeliveringMessage(@Cause Throwable t);
-
- @LogMessage(level = Logger.Level.DEBUG)
- @Message(id = 153001, value = "using different HornetQRAConnectionFactory", format = Message.Format.MESSAGE_FORMAT)
- void warnDifferentConnectionfactory();
-}
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMCFProperties.java
----------------------------------------------------------------------
diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMCFProperties.java b/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMCFProperties.java
deleted file mode 100644
index a161027..0000000
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMCFProperties.java
+++ /dev/null
@@ -1,204 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-package org.apache.activemq.ra;
-
-import java.io.Serializable;
-
-import javax.jms.Queue;
-import javax.jms.Topic;
-
-
-/**
- * The MCF default properties - these are set in the <tx-connection-factory> at the jms-ds.xml
- *
- * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a>
- * @author <a href="mailto:jesper.pedersen@jboss.org">Jesper Pedersen</a>
- * @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a>
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
- */
-public class HornetQRAMCFProperties extends ConnectionFactoryProperties implements Serializable
-{
- /**
- * Serial version UID
- */
- static final long serialVersionUID = -5951352236582886862L;
- /**
- * Trace enabled
- */
- private static boolean trace = HornetQRALogger.LOGGER.isTraceEnabled();
-
- /**
- * The queue type
- */
- private static final String QUEUE_TYPE = Queue.class.getName();
-
- /**
- * The topic type
- */
- private static final String TOPIC_TYPE = Topic.class.getName();
-
-
- private String strConnectorClassName;
-
- public String strConnectionParameters;
-
- /**
- * The connection type
- */
- private int type = HornetQRAConnectionFactory.CONNECTION;
-
- /**
- * Use tryLock
- */
- private Integer useTryLock;
-
- /**
- * Constructor
- */
- public HornetQRAMCFProperties()
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("constructor()");
- }
-
- useTryLock = null;
- }
-
- /**
- * Get the connection type
- *
- * @return The type
- */
- public int getType()
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("getType()");
- }
-
- return type;
- }
-
- public String getConnectorClassName()
- {
- return strConnectorClassName;
- }
-
- public void setConnectorClassName(final String connectorClassName)
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("setConnectorClassName(" + connectorClassName + ")");
- }
-
- strConnectorClassName = connectorClassName;
-
- setParsedConnectorClassNames(HornetQRaUtils.parseConnectorConnectorConfig(connectorClassName));
- }
- /**
- * @return the connectionParameters
- */
- public String getStrConnectionParameters()
- {
- return strConnectionParameters;
- }
-
- public void setConnectionParameters(final String configuration)
- {
- strConnectionParameters = configuration;
- setParsedConnectionParameters(HornetQRaUtils.parseConfig(configuration));
- }
-
- /**
- * Set the default session type.
- *
- * @param defaultType either javax.jms.Topic or javax.jms.Queue
- */
- public void setSessionDefaultType(final String defaultType)
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("setSessionDefaultType(" + type + ")");
- }
-
- if (defaultType.equals(HornetQRAMCFProperties.QUEUE_TYPE))
- {
- type = HornetQRAConnectionFactory.QUEUE_CONNECTION;
- }
- else if (defaultType.equals(HornetQRAMCFProperties.TOPIC_TYPE))
- {
- type = HornetQRAConnectionFactory.TOPIC_CONNECTION;
- }
- else
- {
- type = HornetQRAConnectionFactory.CONNECTION;
- }
- }
-
- /**
- * Get the default session type.
- *
- * @return The default session type
- */
- public String getSessionDefaultType()
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("getSessionDefaultType()");
- }
-
- if (type == HornetQRAConnectionFactory.CONNECTION)
- {
- return "BOTH";
- }
- else if (type == HornetQRAConnectionFactory.QUEUE_CONNECTION)
- {
- return HornetQRAMCFProperties.TOPIC_TYPE;
- }
- else
- {
- return HornetQRAMCFProperties.QUEUE_TYPE;
- }
- }
-
- /**
- * Get the useTryLock.
- *
- * @return the useTryLock.
- */
- public Integer getUseTryLock()
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("getUseTryLock()");
- }
-
- return useTryLock;
- }
-
- /**
- * Set the useTryLock.
- *
- * @param useTryLock the useTryLock.
- */
- public void setUseTryLock(final Integer useTryLock)
- {
- if (HornetQRAMCFProperties.trace)
- {
- HornetQRALogger.LOGGER.trace("setUseTryLock(" + useTryLock + ")");
- }
-
- this.useTryLock = useTryLock;
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnection.java
----------------------------------------------------------------------
diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnection.java b/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnection.java
deleted file mode 100644
index d61c2b5..0000000
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnection.java
+++ /dev/null
@@ -1,921 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-package org.apache.activemq.ra;
-
-import javax.jms.ExceptionListener;
-import javax.jms.JMSException;
-import javax.jms.ResourceAllocationException;
-import javax.jms.Session;
-import javax.jms.XASession;
-import javax.resource.ResourceException;
-import javax.resource.spi.ConnectionEvent;
-import javax.resource.spi.ConnectionEventListener;
-import javax.resource.spi.ConnectionRequestInfo;
-import javax.resource.spi.IllegalStateException;
-import javax.resource.spi.LocalTransaction;
-import javax.resource.spi.ManagedConnection;
-import javax.resource.spi.ManagedConnectionMetaData;
-import javax.resource.spi.SecurityException;
-import javax.security.auth.Subject;
-import javax.transaction.Status;
-import javax.transaction.SystemException;
-import javax.transaction.Transaction;
-import javax.transaction.TransactionManager;
-import javax.transaction.xa.XAResource;
-import java.io.PrintWriter;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Set;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.locks.ReentrantLock;
-
-import org.apache.activemq.core.client.impl.ClientSessionInternal;
-import org.apache.activemq.jms.client.HornetQConnection;
-import org.apache.activemq.jms.client.HornetQConnectionFactory;
-import org.apache.activemq.jms.client.HornetQXAConnection;
-
-/**
- * The managed connection
- *
- * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a>
- * @author <a href="mailto:jesper.pedersen@jboss.org">Jesper Pedersen</a>
- * @author <a href="mailto:mtaylor@redhat.com">Martyn Taylor</a>
- */
-public final class HornetQRAManagedConnection implements ManagedConnection, ExceptionListener
-{
- /**
- * Trace enabled
- */
- private static boolean trace = HornetQRALogger.LOGGER.isTraceEnabled();
-
- /**
- * The managed connection factory
- */
- private final HornetQRAManagedConnectionFactory mcf;
-
- /**
- * The connection request information
- */
- private final HornetQRAConnectionRequestInfo cri;
-
- /**
- * The resource adapter
- */
- private final HornetQResourceAdapter ra;
-
- /**
- * The user name
- */
- private final String userName;
-
- /**
- * The password
- */
- private final String password;
-
- /**
- * Has the connection been destroyed
- */
- private final AtomicBoolean isDestroyed = new AtomicBoolean(false);
-
- /**
- * Event listeners
- */
- private final List<ConnectionEventListener> eventListeners;
-
- /**
- * Handles
- */
- private final Set<HornetQRASession> handles;
-
- /**
- * Lock
- */
- private ReentrantLock lock = new ReentrantLock();
-
- // Physical connection stuff
- private HornetQConnectionFactory connectionFactory;
-
- private HornetQXAConnection connection;
-
- // The ManagedConnection will play with a XA and a NonXASession to couple with
- // cases where a commit is called on a non-XAed (or non-enlisted) case.
- private Session nonXAsession;
-
- private XASession xaSession;
-
- private XAResource xaResource;
-
- private final TransactionManager tm;
-
- private boolean inManagedTx;
-
- /**
- * Constructor
- *
- * @param mcf The managed connection factory
- * @param cri The connection request information
- * @param userName The user name
- * @param password The password
- */
- public HornetQRAManagedConnection(final HornetQRAManagedConnectionFactory mcf,
- final HornetQRAConnectionRequestInfo cri,
- final HornetQResourceAdapter ra,
- final String userName,
- final String password) throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("constructor(" + mcf + ", " + cri + ", " + userName + ", ****)");
- }
-
- this.mcf = mcf;
- this.cri = cri;
- this.tm = ra.getTM();
- this.ra = ra;
- this.userName = userName;
- this.password = password;
- eventListeners = Collections.synchronizedList(new ArrayList<ConnectionEventListener>());
- handles = Collections.synchronizedSet(new HashSet<HornetQRASession>());
-
- connection = null;
- nonXAsession = null;
- xaSession = null;
- xaResource = null;
-
- try
- {
- setup();
- }
- catch (ResourceException e)
- {
- try
- {
- destroy();
- }
- catch (Throwable ignored)
- {
- }
-
- throw e;
- }
- catch (Throwable t)
- {
- try
- {
- destroy();
- }
- catch (Throwable ignored)
- {
- }
- throw new ResourceException("Error during setup", t);
- }
- }
-
- /**
- * Get a connection
- *
- * @param subject The security subject
- * @param cxRequestInfo The request info
- * @return The connection
- * @throws ResourceException Thrown if an error occurs
- */
- public synchronized Object getConnection(final Subject subject, final ConnectionRequestInfo cxRequestInfo) throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getConnection(" + subject + ", " + cxRequestInfo + ")");
- }
-
- // Check user first
- HornetQRACredential credential = HornetQRACredential.getCredential(mcf, subject, cxRequestInfo);
-
- // Null users are allowed!
- if (userName != null && !userName.equals(credential.getUserName()))
- {
- throw new SecurityException("Password credentials not the same, reauthentication not allowed");
- }
-
- if (userName == null && credential.getUserName() != null)
- {
- throw new SecurityException("Password credentials not the same, reauthentication not allowed");
- }
-
- if (isDestroyed.get())
- {
- throw new IllegalStateException("The managed connection is already destroyed");
- }
-
- HornetQRASession session = new HornetQRASession(this, (HornetQRAConnectionRequestInfo) cxRequestInfo);
- handles.add(session);
- return session;
- }
-
- /**
- * Destroy all handles.
- *
- * @throws ResourceException Failed to close one or more handles.
- */
- private void destroyHandles() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("destroyHandles()");
- }
-
- try
- {
-
- if (connection != null)
- {
- connection.stop();
- }
- }
- catch (Throwable t)
- {
- HornetQRALogger.LOGGER.trace("Ignored error stopping connection", t);
- }
-
- for (HornetQRASession session : handles)
- {
- session.destroy();
- }
-
- handles.clear();
- }
-
- /**
- * Destroy the physical connection.
- *
- * @throws ResourceException Could not property close the session and connection.
- */
- public void destroy() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("destroy()");
- }
-
- if (isDestroyed.get() || connection == null)
- {
- return;
- }
-
- isDestroyed.set(true);
-
- try
- {
- connection.setExceptionListener(null);
- }
- catch (JMSException e)
- {
- HornetQRALogger.LOGGER.debug("Error unsetting the exception listener " + this, e);
- }
- if (connection != null)
- {
- connection.signalStopToAllSessions();
- }
-
- destroyHandles();
-
- try
- {
- /**
- * (xa|nonXA)Session.close() may NOT be called BEFORE connection.close()
- * <p>
- * If the ClientSessionFactory is trying to fail-over or reconnect with -1 attempts, and
- * one calls session.close() it may effectively dead-lock.
- * <p>
- * connection close will close the ClientSessionFactory which will close all sessions.
- */
- if (connection != null)
- {
- connection.close();
- }
-
- // The following calls should not be necessary, as the connection should close the
- // ClientSessionFactory, which will close the sessions.
- try
- {
- if (nonXAsession != null)
- {
- nonXAsession.close();
- }
-
- if (xaSession != null)
- {
- xaSession.close();
- }
- }
- catch (JMSException e)
- {
- HornetQRALogger.LOGGER.debug("Error closing session " + this, e);
- }
-
- // we must close the HornetQConnectionFactory because it contains a ServerLocator
- if (connectionFactory != null)
- {
- connectionFactory.close();
- }
- }
- catch (Throwable e)
- {
- throw new ResourceException("Could not properly close the session and connection", e);
- }
- }
-
- /**
- * Cleanup
- *
- * @throws ResourceException Thrown if an error occurs
- */
- public void cleanup() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("cleanup()");
- }
-
- if (isDestroyed.get())
- {
- throw new IllegalStateException("ManagedConnection already destroyed");
- }
-
- destroyHandles();
-
- inManagedTx = false;
-
- inManagedTx = false;
-
- // I'm recreating the lock object when we return to the pool
- // because it looks too nasty to expect the connection handle
- // to unlock properly in certain race conditions
- // where the dissociation of the managed connection is "random".
- lock = new ReentrantLock();
- }
-
- /**
- * Move a handler from one mc to this one.
- *
- * @param obj An object of type HornetQSession.
- * @throws ResourceException Failed to associate connection.
- * @throws IllegalStateException ManagedConnection in an illegal state.
- */
- public void associateConnection(final Object obj) throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("associateConnection(" + obj + ")");
- }
-
- if (!isDestroyed.get() && obj instanceof HornetQRASession)
- {
- HornetQRASession h = (HornetQRASession) obj;
- h.setManagedConnection(this);
- handles.add(h);
- }
- else
- {
- throw new IllegalStateException("ManagedConnection in an illegal state");
- }
- }
-
- public void checkTransactionActive() throws JMSException
- {
- // don't bother looking at the transaction if there's an active XID
- if (!inManagedTx && tm != null)
- {
- try
- {
- Transaction tx = tm.getTransaction();
- if (tx != null)
- {
- int status = tx.getStatus();
- // Only allow states that will actually succeed
- if (status != Status.STATUS_ACTIVE && status != Status.STATUS_PREPARING &&
- status != Status.STATUS_PREPARED &&
- status != Status.STATUS_COMMITTING)
- {
- throw new javax.jms.IllegalStateException("Transaction " + tx + " not active");
- }
- }
- }
- catch (SystemException e)
- {
- JMSException jmsE = new javax.jms.IllegalStateException("Unexpected exception on the Transaction ManagerTransaction");
- jmsE.initCause(e);
- throw jmsE;
- }
- }
- }
-
-
- /**
- * Aqquire a lock on the managed connection
- */
- protected void lock()
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("lock()");
- }
-
- lock.lock();
- }
-
- /**
- * Aqquire a lock on the managed connection within the specified period
- *
- * @throws JMSException Thrown if an error occurs
- */
- protected void tryLock() throws JMSException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("tryLock()");
- }
-
- Integer tryLock = mcf.getUseTryLock();
- if (tryLock == null || tryLock.intValue() <= 0)
- {
- lock();
- return;
- }
- try
- {
- if (lock.tryLock(tryLock.intValue(), TimeUnit.SECONDS) == false)
- {
- throw new ResourceAllocationException("Unable to obtain lock in " + tryLock + " seconds: " + this);
- }
- }
- catch (InterruptedException e)
- {
- throw new ResourceAllocationException("Interrupted attempting lock: " + this);
- }
- }
-
- /**
- * Unlock the managed connection
- */
- protected void unlock()
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("unlock()");
- }
-
- lock.unlock();
- }
-
- /**
- * Add a connection event listener.
- *
- * @param l The connection event listener to be added.
- */
- public void addConnectionEventListener(final ConnectionEventListener l)
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("addConnectionEventListener(" + l + ")");
- }
-
- eventListeners.add(l);
- }
-
- /**
- * Remove a connection event listener.
- *
- * @param l The connection event listener to be removed.
- */
- public void removeConnectionEventListener(final ConnectionEventListener l)
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("removeConnectionEventListener(" + l + ")");
- }
-
- eventListeners.remove(l);
- }
-
- /**
- * Get the XAResource for the connection.
- *
- * @return The XAResource for the connection.
- * @throws ResourceException XA transaction not supported
- */
- public XAResource getXAResource() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getXAResource()");
- }
-
- //
- // Spec says a mc must always return the same XA resource,
- // so we cache it.
- //
- if (xaResource == null)
- {
- ClientSessionInternal csi = (ClientSessionInternal) xaSession.getXAResource();
- HornetQRAXAResource hqXAResource = new HornetQRAXAResource(this, xaSession.getXAResource());
- xaResource = new HornetQXAResourceWrapper(hqXAResource, ra.getJndiName(), csi.getNodeId());
- }
-
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("XAResource=" + xaResource);
- }
-
- return xaResource;
- }
-
- /**
- * Get the location transaction for the connection.
- *
- * @return The local transaction for the connection.
- * @throws ResourceException Thrown if operation fails.
- */
- public LocalTransaction getLocalTransaction() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getLocalTransaction()");
- }
-
- LocalTransaction tx = new HornetQRALocalTransaction(this);
-
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("LocalTransaction=" + tx);
- }
-
- return tx;
- }
-
- /**
- * Get the meta data for the connection.
- *
- * @return The meta data for the connection.
- * @throws ResourceException Thrown if the operation fails.
- * @throws IllegalStateException Thrown if the managed connection already is destroyed.
- */
- public ManagedConnectionMetaData getMetaData() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getMetaData()");
- }
-
- if (isDestroyed.get())
- {
- throw new IllegalStateException("The managed connection is already destroyed");
- }
-
- return new HornetQRAMetaData(this);
- }
-
- /**
- * Set the log writer -- NOT SUPPORTED
- *
- * @param out The log writer
- * @throws ResourceException If operation fails
- */
- public void setLogWriter(final PrintWriter out) throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("setLogWriter(" + out + ")");
- }
- }
-
- /**
- * Get the log writer -- NOT SUPPORTED
- *
- * @return Always null
- * @throws ResourceException If operation fails
- */
- public PrintWriter getLogWriter() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getLogWriter()");
- }
-
- return null;
- }
-
- /**
- * Notifies user of a JMS exception.
- *
- * @param exception The JMS exception
- */
- public void onException(final JMSException exception)
- {
- if (HornetQConnection.EXCEPTION_FAILOVER.equals(exception.getErrorCode()))
- {
- return;
- }
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("onException(" + exception + ")");
- }
-
- if (isDestroyed.get())
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("Ignoring error on already destroyed connection " + this, exception);
- }
- return;
- }
-
- HornetQRALogger.LOGGER.handlingJMSFailure(exception);
-
- try
- {
- connection.setExceptionListener(null);
- }
- catch (JMSException e)
- {
- HornetQRALogger.LOGGER.debug("Unable to unset exception listener", e);
- }
-
- ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_ERROR_OCCURRED, exception);
- sendEvent(event);
- }
-
- /**
- * Get the session for this connection.
- *
- * @return The session
- * @throws JMSException
- */
- protected Session getSession() throws JMSException
- {
- if (xaResource != null && inManagedTx)
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getSession() -> XA session " + xaSession.getSession());
- }
-
- return xaSession.getSession();
- }
- else
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getSession() -> non XA session " + nonXAsession);
- }
-
- return nonXAsession;
- }
- }
-
- /**
- * Send an event.
- *
- * @param event The event to send.
- */
- protected void sendEvent(final ConnectionEvent event)
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("sendEvent(" + event + ")");
- }
-
- int type = event.getId();
-
- // convert to an array to avoid concurrent modification exceptions
- ConnectionEventListener[] list = eventListeners.toArray(new ConnectionEventListener[eventListeners.size()]);
-
- for (ConnectionEventListener l : list)
- {
- switch (type)
- {
- case ConnectionEvent.CONNECTION_CLOSED:
- l.connectionClosed(event);
- break;
-
- case ConnectionEvent.LOCAL_TRANSACTION_STARTED:
- l.localTransactionStarted(event);
- break;
-
- case ConnectionEvent.LOCAL_TRANSACTION_COMMITTED:
- l.localTransactionCommitted(event);
- break;
-
- case ConnectionEvent.LOCAL_TRANSACTION_ROLLEDBACK:
- l.localTransactionRolledback(event);
- break;
-
- case ConnectionEvent.CONNECTION_ERROR_OCCURRED:
- l.connectionErrorOccurred(event);
- break;
-
- default:
- throw new IllegalArgumentException("Illegal eventType: " + type);
- }
- }
- }
-
- /**
- * Remove a handle from the handle map.
- *
- * @param handle The handle to remove.
- */
- protected void removeHandle(final HornetQRASession handle)
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("removeHandle(" + handle + ")");
- }
-
- handles.remove(handle);
- }
-
- /**
- * Get the request info for this connection.
- *
- * @return The connection request info for this connection.
- */
- protected HornetQRAConnectionRequestInfo getCRI()
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getCRI()");
- }
-
- return cri;
- }
-
- /**
- * Get the connection factory for this connection.
- *
- * @return The connection factory for this connection.
- */
- protected HornetQRAManagedConnectionFactory getManagedConnectionFactory()
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getManagedConnectionFactory()");
- }
-
- return mcf;
- }
-
- /**
- * Start the connection
- *
- * @throws JMSException Thrown if the connection can't be started
- */
- void start() throws JMSException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("start()");
- }
-
- if (connection != null)
- {
- connection.start();
- }
- }
-
- /**
- * Stop the connection
- *
- * @throws JMSException Thrown if the connection can't be stopped
- */
- void stop() throws JMSException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("stop()");
- }
-
- if (connection != null)
- {
- connection.stop();
- }
- }
-
- /**
- * Get the user name
- *
- * @return The user name
- */
- protected String getUserName()
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("getUserName()");
- }
-
- return userName;
- }
-
- /**
- * Setup the connection.
- *
- * @throws ResourceException Thrown if a connection couldn't be created
- */
- private void setup() throws ResourceException
- {
- if (HornetQRAManagedConnection.trace)
- {
- HornetQRALogger.LOGGER.trace("setup()");
- }
-
- try
- {
-
- createCF();
-
- boolean transacted = cri.isTransacted();
- int acknowledgeMode = Session.AUTO_ACKNOWLEDGE;
- if (cri.getType() == HornetQRAConnectionFactory.TOPIC_CONNECTION)
- {
- if (userName != null && password != null)
- {
- connection = (HornetQXAConnection) connectionFactory.createXATopicConnection(userName, password);
- }
- else
- {
- connection = (HornetQXAConnection) connectionFactory.createXATopicConnection();
- }
-
- connection.setExceptionListener(this);
-
- xaSession = connection.createXATopicSession();
- nonXAsession = connection.createNonXATopicSession(transacted, acknowledgeMode);
-
- }
- else if (cri.getType() == HornetQRAConnectionFactory.QUEUE_CONNECTION)
- {
- if (userName != null && password != null)
- {
- connection = (HornetQXAConnection) connectionFactory.createXAQueueConnection(userName, password);
- }
- else
- {
- connection = (HornetQXAConnection) connectionFactory.createXAQueueConnection();
- }
-
- connection.setExceptionListener(this);
-
- xaSession = connection.createXAQueueSession();
- nonXAsession = connection.createNonXAQueueSession(transacted, acknowledgeMode);
-
- }
- else
- {
- if (userName != null && password != null)
- {
- connection = (HornetQXAConnection) connectionFactory.createXAConnection(userName, password);
- }
- else
- {
- connection = (HornetQXAConnection) connectionFactory.createXAConnection();
- }
-
- connection.setExceptionListener(this);
-
- xaSession = connection.createXASession();
- nonXAsession = connection.createNonXASession(transacted, acknowledgeMode);
- }
-
- }
- catch (JMSException je)
- {
- throw new ResourceException(je.getMessage(), je);
- }
- }
-
- private void createCF()
- {
- if (connectionFactory == null)
- {
- connectionFactory = ra.createHornetQConnectionFactory(mcf.getProperties());
- }
- }
-
- protected void setInManagedTx(boolean inManagedTx)
- {
- this.inManagedTx = inManagedTx;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnectionFactory.java
----------------------------------------------------------------------
diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnectionFactory.java b/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnectionFactory.java
deleted file mode 100644
index 788d867..0000000
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAManagedConnectionFactory.java
+++ /dev/null
@@ -1,805 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-package org.apache.activemq.ra;
-
-import javax.jms.ConnectionMetaData;
-import javax.resource.ResourceException;
-import javax.resource.spi.ConnectionManager;
-import javax.resource.spi.ConnectionRequestInfo;
-import javax.resource.spi.ManagedConnection;
-import javax.resource.spi.ManagedConnectionFactory;
-import javax.resource.spi.ResourceAdapter;
-import javax.resource.spi.ResourceAdapterAssociation;
-import javax.security.auth.Subject;
-import java.io.PrintWriter;
-import java.util.Iterator;
-import java.util.Set;
-
-import org.apache.activemq.jms.client.HornetQConnectionFactory;
-import org.apache.activemq.jms.server.recovery.XARecoveryConfig;
-
-/**
- * HornetQ ManagedConnectionFactory
- *
- * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a>
- * @author <a href="mailto:jesper.pedersen@jboss.org">Jesper Pedersen</a>.
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
- */
-public final class HornetQRAManagedConnectionFactory implements ManagedConnectionFactory, ResourceAdapterAssociation
-{
- /**
- * Serial version UID
- */
- static final long serialVersionUID = -1452379518562456741L;
- /**
- * Trace enabled
- */
- private static boolean trace = HornetQRALogger.LOGGER.isTraceEnabled();
-
- /**
- * The resource adapter
- */
- private HornetQResourceAdapter ra;
-
- /**
- * Connection manager
- */
- private ConnectionManager cm;
-
- /**
- * The managed connection factory properties
- */
- private final HornetQRAMCFProperties mcfProperties;
-
- /**
- * Connection Factory used if properties are set
- */
- private HornetQConnectionFactory recoveryConnectionFactory;
-
- /*
- * The resource recovery if there is one
- * */
- private XARecoveryConfig resourceRecovery;
-
- /**
- * Constructor
- */
- public HornetQRAManagedConnectionFactory()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("constructor()");
- }
-
- ra = null;
- cm = null;
- mcfProperties = new HornetQRAMCFProperties();
- }
-
- /**
- * Creates a Connection Factory instance
- *
- * @return javax.resource.cci.ConnectionFactory instance
- * @throws ResourceException Thrown if a connection factory can't be created
- */
- public Object createConnectionFactory() throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.debug("createConnectionFactory()");
- }
-
- return createConnectionFactory(new HornetQRAConnectionManager());
- }
-
- /**
- * Creates a Connection Factory instance
- *
- * @param cxManager The connection manager
- * @return javax.resource.cci.ConnectionFactory instance
- * @throws ResourceException Thrown if a connection factory can't be created
- */
- public Object createConnectionFactory(final ConnectionManager cxManager) throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("createConnectionFactory(" + cxManager + ")");
- }
-
- cm = cxManager;
-
- HornetQRAConnectionFactory cf = new HornetQRAConnectionFactoryImpl(this, cm);
-
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("Created connection factory: " + cf +
- ", using connection manager: " +
- cm);
- }
- return cf;
- }
-
- /**
- * Creates a new physical connection to the underlying EIS resource manager.
- *
- * @param subject Caller's security information
- * @param cxRequestInfo Additional resource adapter specific connection request information
- * @return The managed connection
- * @throws ResourceException Thrown if a managed connection can't be created
- */
- public ManagedConnection createManagedConnection(final Subject subject, final ConnectionRequestInfo cxRequestInfo) throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("createManagedConnection(" + subject + ", " + cxRequestInfo + ")");
- }
-
- HornetQRAConnectionRequestInfo cri = getCRI((HornetQRAConnectionRequestInfo) cxRequestInfo);
-
- HornetQRACredential credential = HornetQRACredential.getCredential(this, subject, cri);
-
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("jms credential: " + credential);
- }
-
- HornetQRAManagedConnection mc = new HornetQRAManagedConnection(this,
- cri,
- ra,
- credential.getUserName(),
- credential.getPassword());
-
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("created new managed connection: " + mc);
- }
-
- registerRecovery();
-
- return mc;
- }
-
- private synchronized void registerRecovery()
- {
- if (recoveryConnectionFactory == null)
- {
- recoveryConnectionFactory = ra.createRecoveryHornetQConnectionFactory(mcfProperties);
- resourceRecovery = ra.getRecoveryManager().register(recoveryConnectionFactory, null, null);
- }
- }
-
- public XARecoveryConfig getResourceRecovery()
- {
- return resourceRecovery;
- }
-
- /**
- * Returns a matched connection from the candidate set of connections.
- *
- * @param connectionSet The candidate connection set
- * @param subject Caller's security information
- * @param cxRequestInfo Additional resource adapter specific connection request information
- * @return The managed connection
- * @throws ResourceException Thrown if the managed connection can not be found
- */
- public ManagedConnection matchManagedConnections(@SuppressWarnings("rawtypes") final Set connectionSet, final Subject subject, final ConnectionRequestInfo cxRequestInfo) throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("matchManagedConnections(" + connectionSet +
- ", " +
- subject +
- ", " +
- cxRequestInfo +
- ")");
- }
-
- HornetQRAConnectionRequestInfo cri = getCRI((HornetQRAConnectionRequestInfo) cxRequestInfo);
- HornetQRACredential credential = HornetQRACredential.getCredential(this, subject, cri);
-
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("Looking for connection matching credentials: " + credential);
- }
-
- Iterator<?> connections = connectionSet.iterator();
-
- while (connections.hasNext())
- {
- Object obj = connections.next();
-
- if (obj instanceof HornetQRAManagedConnection)
- {
- HornetQRAManagedConnection mc = (HornetQRAManagedConnection) obj;
- ManagedConnectionFactory mcf = mc.getManagedConnectionFactory();
-
- if ((mc.getUserName() == null || mc.getUserName() != null && mc.getUserName()
- .equals(credential.getUserName())) && mcf.equals(this))
- {
- if (cri.equals(mc.getCRI()))
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("Found matching connection: " + mc);
- }
-
- return mc;
- }
- }
- }
- }
-
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("No matching connection was found");
- }
-
- return null;
- }
-
- /**
- * Set the log writer -- NOT SUPPORTED
- *
- * @param out The writer
- * @throws ResourceException Thrown if the writer can't be set
- */
- public void setLogWriter(final PrintWriter out) throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("setLogWriter(" + out + ")");
- }
- }
-
- /**
- * Get the log writer -- NOT SUPPORTED
- *
- * @return The writer
- * @throws ResourceException Thrown if the writer can't be retrieved
- */
- public PrintWriter getLogWriter() throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getLogWriter()");
- }
-
- return null;
- }
-
- /**
- * Get the resource adapter
- *
- * @return The resource adapter
- */
- public ResourceAdapter getResourceAdapter()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getResourceAdapter()");
- }
-
- return ra;
- }
-
- /**
- * Set the resource adapter
- * <p/>
- * This should ensure that when the RA is stopped, this MCF will be stopped as well.
- *
- * @param ra The resource adapter
- * @throws ResourceException Thrown if incorrect resource adapter
- */
- public void setResourceAdapter(final ResourceAdapter ra) throws ResourceException
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("setResourceAdapter(" + ra + ")");
- }
-
- if (ra == null || !(ra instanceof HornetQResourceAdapter))
- {
- throw new ResourceException("Resource adapter is " + ra);
- }
-
- this.ra = (HornetQResourceAdapter) ra;
- this.ra.setManagedConnectionFactory(this);
- }
-
- /**
- * Indicates whether some other object is "equal to" this one.
- *
- * @param obj Object with which to compare
- * @return True if this object is the same as the obj argument; false otherwise.
- */
- @Override
- public boolean equals(final Object obj)
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("equals(" + obj + ")");
- }
-
- if (obj == null)
- {
- return false;
- }
-
- if (obj instanceof HornetQRAManagedConnectionFactory)
- {
- HornetQRAManagedConnectionFactory other = (HornetQRAManagedConnectionFactory) obj;
-
- return mcfProperties.equals(other.getProperties()) && ra.equals(other.getResourceAdapter());
- }
- else
- {
- return false;
- }
- }
-
- /**
- * Return the hash code for the object
- *
- * @return The hash code
- */
- @Override
- public int hashCode()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("hashCode()");
- }
-
- int hash = mcfProperties.hashCode();
- hash += 31 * ra.hashCode();
-
- return hash;
- }
-
- /**
- * Get the default session type
- *
- * @return The value
- */
- public String getSessionDefaultType()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getSessionDefaultType()");
- }
-
- return mcfProperties.getSessionDefaultType();
- }
-
- /**
- * Set the default session type
- *
- * @param type either javax.jms.Topic or javax.jms.Queue
- */
- public void setSessionDefaultType(final String type)
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("setSessionDefaultType(" + type + ")");
- }
-
- mcfProperties.setSessionDefaultType(type);
- }
-
- /**
- * @return the connectionParameters
- */
- public String getConnectionParameters()
- {
- return mcfProperties.getStrConnectionParameters();
- }
-
- public void setConnectionParameters(final String configuration)
- {
- mcfProperties.setConnectionParameters(configuration);
- }
-
- /**
- * @return the transportType
- */
- public String getConnectorClassName()
- {
- return mcfProperties.getConnectorClassName();
- }
-
- public void setConnectorClassName(final String value)
- {
- mcfProperties.setConnectorClassName(value);
- }
-
- public String getConnectionLoadBalancingPolicyClassName()
- {
- return mcfProperties.getConnectionLoadBalancingPolicyClassName();
- }
-
- public void setConnectionLoadBalancingPolicyClassName(final String connectionLoadBalancingPolicyClassName)
- {
- mcfProperties.setConnectionLoadBalancingPolicyClassName(connectionLoadBalancingPolicyClassName);
- }
-
- public String getDiscoveryAddress()
- {
- return mcfProperties.getDiscoveryAddress();
- }
-
- public void setDiscoveryAddress(final String discoveryAddress)
- {
- mcfProperties.setDiscoveryAddress(discoveryAddress);
- }
-
- public Integer getDiscoveryPort()
- {
- return mcfProperties.getDiscoveryPort();
- }
-
- public void setDiscoveryPort(final Integer discoveryPort)
- {
- mcfProperties.setDiscoveryPort(discoveryPort);
- }
-
- public Long getDiscoveryRefreshTimeout()
- {
- return mcfProperties.getDiscoveryRefreshTimeout();
- }
-
- public void setDiscoveryRefreshTimeout(final Long discoveryRefreshTimeout)
- {
- mcfProperties.setDiscoveryRefreshTimeout(discoveryRefreshTimeout);
- }
-
- public Long getDiscoveryInitialWaitTimeout()
- {
- return mcfProperties.getDiscoveryInitialWaitTimeout();
- }
-
- public void setDiscoveryInitialWaitTimeout(final Long discoveryInitialWaitTimeout)
- {
- mcfProperties.setDiscoveryInitialWaitTimeout(discoveryInitialWaitTimeout);
- }
-
- public String getClientID()
- {
- return mcfProperties.getClientID();
- }
-
- public void setClientID(final String clientID)
- {
- mcfProperties.setClientID(clientID);
- }
-
- public Integer getDupsOKBatchSize()
- {
- return mcfProperties.getDupsOKBatchSize();
- }
-
- public void setDupsOKBatchSize(final Integer dupsOKBatchSize)
- {
- mcfProperties.setDupsOKBatchSize(dupsOKBatchSize);
- }
-
- public Integer getTransactionBatchSize()
- {
- return mcfProperties.getTransactionBatchSize();
- }
-
- public void setTransactionBatchSize(final Integer transactionBatchSize)
- {
- mcfProperties.setTransactionBatchSize(transactionBatchSize);
- }
-
- public Long getClientFailureCheckPeriod()
- {
- return mcfProperties.getClientFailureCheckPeriod();
- }
-
- public void setClientFailureCheckPeriod(final Long clientFailureCheckPeriod)
- {
- mcfProperties.setClientFailureCheckPeriod(clientFailureCheckPeriod);
- }
-
- public Long getConnectionTTL()
- {
- return mcfProperties.getConnectionTTL();
- }
-
- public void setConnectionTTL(final Long connectionTTL)
- {
- mcfProperties.setConnectionTTL(connectionTTL);
- }
-
- public Long getCallTimeout()
- {
- return mcfProperties.getCallTimeout();
- }
-
- public void setCallTimeout(final Long callTimeout)
- {
- mcfProperties.setCallTimeout(callTimeout);
- }
-
- public Integer getConsumerWindowSize()
- {
- return mcfProperties.getConsumerWindowSize();
- }
-
- public void setConsumerWindowSize(final Integer consumerWindowSize)
- {
- mcfProperties.setConsumerWindowSize(consumerWindowSize);
- }
-
- public Integer getConsumerMaxRate()
- {
- return mcfProperties.getConsumerMaxRate();
- }
-
- public void setConsumerMaxRate(final Integer consumerMaxRate)
- {
- mcfProperties.setConsumerMaxRate(consumerMaxRate);
- }
-
- public Integer getConfirmationWindowSize()
- {
- return mcfProperties.getConfirmationWindowSize();
- }
-
- public void setConfirmationWindowSize(final Integer confirmationWindowSize)
- {
- mcfProperties.setConfirmationWindowSize(confirmationWindowSize);
- }
-
- public Integer getProducerMaxRate()
- {
- return mcfProperties.getProducerMaxRate();
- }
-
- public void setProducerMaxRate(final Integer producerMaxRate)
- {
- mcfProperties.setProducerMaxRate(producerMaxRate);
- }
-
- public Integer getMinLargeMessageSize()
- {
- return mcfProperties.getMinLargeMessageSize();
- }
-
- public void setMinLargeMessageSize(final Integer minLargeMessageSize)
- {
- mcfProperties.setMinLargeMessageSize(minLargeMessageSize);
- }
-
- public Boolean isBlockOnAcknowledge()
- {
- return mcfProperties.isBlockOnAcknowledge();
- }
-
- public void setBlockOnAcknowledge(final Boolean blockOnAcknowledge)
- {
- mcfProperties.setBlockOnAcknowledge(blockOnAcknowledge);
- }
-
- public Boolean isBlockOnNonDurableSend()
- {
- return mcfProperties.isBlockOnNonDurableSend();
- }
-
- public void setBlockOnNonDurableSend(final Boolean blockOnNonDurableSend)
- {
- mcfProperties.setBlockOnNonDurableSend(blockOnNonDurableSend);
- }
-
- public Boolean isBlockOnDurableSend()
- {
- return mcfProperties.isBlockOnDurableSend();
- }
-
- public void setBlockOnDurableSend(final Boolean blockOnDurableSend)
- {
- mcfProperties.setBlockOnDurableSend(blockOnDurableSend);
- }
-
- public Boolean isAutoGroup()
- {
- return mcfProperties.isAutoGroup();
- }
-
- public void setAutoGroup(final Boolean autoGroup)
- {
- mcfProperties.setAutoGroup(autoGroup);
- }
-
- public Boolean isPreAcknowledge()
- {
- return mcfProperties.isPreAcknowledge();
- }
-
- public void setPreAcknowledge(final Boolean preAcknowledge)
- {
- mcfProperties.setPreAcknowledge(preAcknowledge);
- }
-
- public Long getRetryInterval()
- {
- return mcfProperties.getRetryInterval();
- }
-
- public void setRetryInterval(final Long retryInterval)
- {
- mcfProperties.setRetryInterval(retryInterval);
- }
-
- public Double getRetryIntervalMultiplier()
- {
- return mcfProperties.getRetryIntervalMultiplier();
- }
-
- public void setRetryIntervalMultiplier(final Double retryIntervalMultiplier)
- {
- mcfProperties.setRetryIntervalMultiplier(retryIntervalMultiplier);
- }
-
- public Integer getReconnectAttempts()
- {
- return mcfProperties.getReconnectAttempts();
- }
-
- public void setReconnectAttempts(final Integer reconnectAttempts)
- {
- mcfProperties.setReconnectAttempts(reconnectAttempts);
- }
-
- public Boolean isUseGlobalPools()
- {
- return mcfProperties.isUseGlobalPools();
- }
-
- public void setUseGlobalPools(final Boolean useGlobalPools)
- {
- mcfProperties.setUseGlobalPools(useGlobalPools);
- }
-
- public Integer getScheduledThreadPoolMaxSize()
- {
- return mcfProperties.getScheduledThreadPoolMaxSize();
- }
-
- public void setScheduledThreadPoolMaxSize(final Integer scheduledThreadPoolMaxSize)
- {
- mcfProperties.setScheduledThreadPoolMaxSize(scheduledThreadPoolMaxSize);
- }
-
- public Integer getThreadPoolMaxSize()
- {
- return mcfProperties.getThreadPoolMaxSize();
- }
-
- public void setThreadPoolMaxSize(final Integer threadPoolMaxSize)
- {
- mcfProperties.setThreadPoolMaxSize(threadPoolMaxSize);
- }
-
- public Boolean isHA()
- {
- return mcfProperties.isHA();
- }
-
- public void setHA(Boolean ha)
- {
- mcfProperties.setHA(ha);
- }
-
- /**
- * Get the useTryLock.
- *
- * @return the useTryLock.
- */
- public Integer getUseTryLock()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getUseTryLock()");
- }
-
- return mcfProperties.getUseTryLock();
- }
-
- /**
- * Set the useTryLock.
- *
- * @param useTryLock the useTryLock.
- */
- public void setUseTryLock(final Integer useTryLock)
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("setUseTryLock(" + useTryLock + ")");
- }
-
- mcfProperties.setUseTryLock(useTryLock);
- }
-
- /**
- * Get the connection metadata
- *
- * @return The metadata
- */
- public ConnectionMetaData getMetaData()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getMetadata()");
- }
-
- return new HornetQRAConnectionMetaData();
- }
-
- /**
- * Get the managed connection factory properties
- *
- * @return The properties
- */
- protected HornetQRAMCFProperties getProperties()
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getProperties()");
- }
-
- return mcfProperties;
- }
-
- /**
- * Get a connection request info instance
- *
- * @param info The instance that should be updated; may be <code>null</code>
- * @return The instance
- */
- private HornetQRAConnectionRequestInfo getCRI(final HornetQRAConnectionRequestInfo info)
- {
- if (HornetQRAManagedConnectionFactory.trace)
- {
- HornetQRALogger.LOGGER.trace("getCRI(" + info + ")");
- }
-
- if (info == null)
- {
- // Create a default one
- return new HornetQRAConnectionRequestInfo(ra.getProperties(), mcfProperties.getType());
- }
- else
- {
- // Fill the one with any defaults
- info.setDefaults(ra.getProperties());
- return info;
- }
- }
-
- // this should be called when HornetQResourceAdapter.stop() is called since this MCF is registered with it
- public void stop()
- {
- if (resourceRecovery != null)
- {
- ra.getRecoveryManager().unRegister(resourceRecovery);
- }
-
- if (recoveryConnectionFactory != null)
- {
- recoveryConnectionFactory.close();
- recoveryConnectionFactory = null;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMapMessage.java
----------------------------------------------------------------------
diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMapMessage.java b/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMapMessage.java
deleted file mode 100644
index 30abb59..0000000
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/HornetQRAMapMessage.java
+++ /dev/null
@@ -1,452 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-package org.apache.activemq.ra;
-
-import java.util.Arrays;
-import java.util.Enumeration;
-
-import javax.jms.JMSException;
-import javax.jms.MapMessage;
-
-
-/**
- * A wrapper for a message
- *
- * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a>
- * @author <a href="mailto:jesper.pedersen@jboss.org">Jesper Pedersen</a>
- * @version $Revision: 71554 $
- */
-public class HornetQRAMapMessage extends HornetQRAMessage implements MapMessage
-{
- /** Whether trace is enabled */
- private static boolean trace = HornetQRALogger.LOGGER.isTraceEnabled();
-
- /**
- * Create a new wrapper
- *
- * @param message the message
- * @param session the session
- */
- public HornetQRAMapMessage(final MapMessage message, final HornetQRASession session)
- {
- super(message, session);
-
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("constructor(" + message + ", " + session + ")");
- }
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public boolean getBoolean(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getBoolean(" + name + ")");
- }
-
- return ((MapMessage)message).getBoolean(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public byte getByte(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getByte(" + name + ")");
- }
-
- return ((MapMessage)message).getByte(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public byte[] getBytes(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getBytes(" + name + ")");
- }
-
- return ((MapMessage)message).getBytes(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public char getChar(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getChar(" + name + ")");
- }
-
- return ((MapMessage)message).getChar(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public double getDouble(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getDouble(" + name + ")");
- }
-
- return ((MapMessage)message).getDouble(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public float getFloat(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getFloat(" + name + ")");
- }
-
- return ((MapMessage)message).getFloat(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public int getInt(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getInt(" + name + ")");
- }
-
- return ((MapMessage)message).getInt(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public long getLong(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getLong(" + name + ")");
- }
-
- return ((MapMessage)message).getLong(name);
- }
-
- /**
- * Get the map names
- * @return The values
- * @exception JMSException Thrown if an error occurs
- */
- @SuppressWarnings("rawtypes")
- public Enumeration getMapNames() throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getMapNames()");
- }
-
- return ((MapMessage)message).getMapNames();
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public Object getObject(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getObject(" + name + ")");
- }
-
- return ((MapMessage)message).getObject(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public short getShort(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getShort(" + name + ")");
- }
-
- return ((MapMessage)message).getShort(name);
- }
-
- /**
- * Get
- * @param name The name
- * @return The value
- * @exception JMSException Thrown if an error occurs
- */
- public String getString(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("getString(" + name + ")");
- }
-
- return ((MapMessage)message).getString(name);
- }
-
- /**
- * Does the item exist
- * @param name The name
- * @return True / false
- * @exception JMSException Thrown if an error occurs
- */
- public boolean itemExists(final String name) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("itemExists(" + name + ")");
- }
-
- return ((MapMessage)message).itemExists(name);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setBoolean(final String name, final boolean value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setBoolean(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setBoolean(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setByte(final String name, final byte value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setByte(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setByte(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @param offset The offset
- * @param length The length
- * @exception JMSException Thrown if an error occurs
- */
- public void setBytes(final String name, final byte[] value, final int offset, final int length) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setBytes(" + name + ", " + Arrays.toString(value) + ", " + offset + ", " +
- length + ")");
- }
-
- ((MapMessage)message).setBytes(name, value, offset, length);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setBytes(final String name, final byte[] value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setBytes(" + name + ", " + Arrays.toString(value) + ")");
- }
-
- ((MapMessage)message).setBytes(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setChar(final String name, final char value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setChar(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setChar(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setDouble(final String name, final double value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setDouble(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setDouble(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setFloat(final String name, final float value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setFloat(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setFloat(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setInt(final String name, final int value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setInt(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setInt(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setLong(final String name, final long value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setLong(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setLong(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setObject(final String name, final Object value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setObject(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setObject(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setShort(final String name, final short value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setShort(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setShort(name, value);
- }
-
- /**
- * Set
- * @param name The name
- * @param value The value
- * @exception JMSException Thrown if an error occurs
- */
- public void setString(final String name, final String value) throws JMSException
- {
- if (HornetQRAMapMessage.trace)
- {
- HornetQRALogger.LOGGER.trace("setString(" + name + ", " + value + ")");
- }
-
- ((MapMessage)message).setString(name, value);
- }
-}