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

NO-JIRA Traces on the Resource Adapter

This commit is contained in:
Clebert Suconic 2017-07-25 17:46:22 -04:00
parent 1796e5935f
commit b6b48a5896
3 changed files with 296 additions and 302 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,6 +60,7 @@ import org.apache.activemq.artemis.ra.recovery.RecoveryManager;
import org.apache.activemq.artemis.service.extensions.ServiceUtils; import org.apache.activemq.artemis.service.extensions.ServiceUtils;
import org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig; import org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig;
import org.apache.activemq.artemis.utils.SensitiveDataCodec; import org.apache.activemq.artemis.utils.SensitiveDataCodec;
import org.jboss.logging.Logger;
import org.jgroups.JChannel; import org.jgroups.JChannel;
/** /**
@ -67,6 +68,8 @@ import org.jgroups.JChannel;
*/ */
public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable { public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
private static final Logger logger = Logger.getLogger(ActiveMQResourceAdapter.class);
private static final long serialVersionUID = 4756893709825838770L; private static final long serialVersionUID = 4756893709825838770L;
/** /**
@ -74,11 +77,6 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
public static final String PRODUCT_NAME = "ActiveMQ Artemis"; public static final String PRODUCT_NAME = "ActiveMQ Artemis";
/**
* Trace enabled
*/
private static boolean trace = ActiveMQRALogger.LOGGER.isTraceEnabled();
/** /**
* The bootstrap context * The bootstrap context
*/ */
@ -136,8 +134,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* Constructor * Constructor
*/ */
public ActiveMQResourceAdapter() { public ActiveMQResourceAdapter() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("constructor()"); logger.trace("constructor()");
} }
raProperties = new ActiveMQRAProperties(); raProperties = new ActiveMQRAProperties();
@ -170,8 +168,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
throw new ResourceException("Unable to create activation", e); throw new ResourceException("Unable to create activation", e);
} }
} }
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("endpointActivation(" + endpointFactory + ", " + spec + ")"); logger.trace("endpointActivation(" + endpointFactory + ", " + spec + ")");
} }
ActiveMQActivation activation = new ActiveMQActivation(this, endpointFactory, (ActiveMQActivationSpec) spec); ActiveMQActivation activation = new ActiveMQActivation(this, endpointFactory, (ActiveMQActivationSpec) spec);
@ -187,8 +185,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public void endpointDeactivation(final MessageEndpointFactory endpointFactory, final ActivationSpec spec) { public void endpointDeactivation(final MessageEndpointFactory endpointFactory, final ActivationSpec spec) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("endpointDeactivation(" + endpointFactory + ", " + spec + ")"); logger.trace("endpointDeactivation(" + endpointFactory + ", " + spec + ")");
} }
ActiveMQActivation activation = activations.remove(spec); ActiveMQActivation activation = activations.remove(spec);
@ -206,8 +204,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public XAResource[] getXAResources(final ActivationSpec[] specs) throws ResourceException { public XAResource[] getXAResources(final ActivationSpec[] specs) throws ResourceException {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getXAResources(" + Arrays.toString(specs) + ")"); logger.trace("getXAResources(" + Arrays.toString(specs) + ")");
} }
if (useAutoRecovery) { if (useAutoRecovery) {
@ -233,8 +231,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public void start(final BootstrapContext ctx) throws ResourceAdapterInternalException { public void start(final BootstrapContext ctx) throws ResourceAdapterInternalException {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("start(" + ctx + ")"); logger.trace("start(" + ctx + ")");
} }
tm = ServiceUtils.getTransactionManager(); tm = ServiceUtils.getTransactionManager();
@ -259,8 +257,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public void stop() { public void stop() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("stop()"); logger.trace("stop()");
} }
for (Map.Entry<ActivationSpec, ActiveMQActivation> entry : activations.entrySet()) { for (Map.Entry<ActivationSpec, ActiveMQActivation> entry : activations.entrySet()) {
@ -322,8 +320,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
} }
public void setConnectorClassName(final String connectorClassName) { public void setConnectorClassName(final String connectorClassName) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setTransportType(" + connectorClassName + ")"); logger.trace("setTransportType(" + connectorClassName + ")");
} }
unparsedConnectors = connectorClassName; unparsedConnectors = connectorClassName;
@ -377,8 +375,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public String getDiscoveryAddress() { public String getDiscoveryAddress() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDiscoveryGroupAddress()"); logger.trace("getDiscoveryGroupAddress()");
} }
return raProperties.getDiscoveryAddress(); return raProperties.getDiscoveryAddress();
@ -406,8 +404,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param dgn The value * @param dgn The value
*/ */
public void setDiscoveryAddress(final String dgn) { public void setDiscoveryAddress(final String dgn) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDiscoveryGroupAddress(" + dgn + ")"); logger.trace("setDiscoveryGroupAddress(" + dgn + ")");
} }
raProperties.setDiscoveryAddress(dgn); raProperties.setDiscoveryAddress(dgn);
@ -419,8 +417,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getDiscoveryPort() { public Integer getDiscoveryPort() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDiscoveryGroupPort()"); logger.trace("getDiscoveryGroupPort()");
} }
return raProperties.getDiscoveryPort(); return raProperties.getDiscoveryPort();
@ -432,8 +430,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param discoveryLocalBindAddress the address value * @param discoveryLocalBindAddress the address value
*/ */
public void setDiscoveryLocalBindAddress(final String discoveryLocalBindAddress) { public void setDiscoveryLocalBindAddress(final String discoveryLocalBindAddress) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDiscoveryLocalBindAddress(" + discoveryLocalBindAddress + ")"); logger.trace("setDiscoveryLocalBindAddress(" + discoveryLocalBindAddress + ")");
} }
raProperties.setDiscoveryLocalBindAddress(discoveryLocalBindAddress); raProperties.setDiscoveryLocalBindAddress(discoveryLocalBindAddress);
@ -445,8 +443,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return the address value * @return the address value
*/ */
public String getDiscoveryLocalBindAddress() { public String getDiscoveryLocalBindAddress() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDiscoveryLocalBindAddress()"); logger.trace("getDiscoveryLocalBindAddress()");
} }
return raProperties.getDiscoveryLocalBindAddress(); return raProperties.getDiscoveryLocalBindAddress();
@ -458,8 +456,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param dgp The value * @param dgp The value
*/ */
public void setDiscoveryPort(final Integer dgp) { public void setDiscoveryPort(final Integer dgp) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDiscoveryGroupPort(" + dgp + ")"); logger.trace("setDiscoveryGroupPort(" + dgp + ")");
} }
raProperties.setDiscoveryPort(dgp); raProperties.setDiscoveryPort(dgp);
@ -471,8 +469,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getDiscoveryRefreshTimeout() { public Long getDiscoveryRefreshTimeout() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDiscoveryRefreshTimeout()"); logger.trace("getDiscoveryRefreshTimeout()");
} }
return raProperties.getDiscoveryRefreshTimeout(); return raProperties.getDiscoveryRefreshTimeout();
@ -484,8 +482,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param discoveryRefreshTimeout The value * @param discoveryRefreshTimeout The value
*/ */
public void setDiscoveryRefreshTimeout(final Long discoveryRefreshTimeout) { public void setDiscoveryRefreshTimeout(final Long discoveryRefreshTimeout) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDiscoveryRefreshTimeout(" + discoveryRefreshTimeout + ")"); logger.trace("setDiscoveryRefreshTimeout(" + discoveryRefreshTimeout + ")");
} }
raProperties.setDiscoveryRefreshTimeout(discoveryRefreshTimeout); raProperties.setDiscoveryRefreshTimeout(discoveryRefreshTimeout);
@ -497,8 +495,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getDiscoveryInitialWaitTimeout() { public Long getDiscoveryInitialWaitTimeout() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDiscoveryInitialWaitTimeout()"); logger.trace("getDiscoveryInitialWaitTimeout()");
} }
return raProperties.getDiscoveryInitialWaitTimeout(); return raProperties.getDiscoveryInitialWaitTimeout();
@ -510,8 +508,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param discoveryInitialWaitTimeout The value * @param discoveryInitialWaitTimeout The value
*/ */
public void setDiscoveryInitialWaitTimeout(final Long discoveryInitialWaitTimeout) { public void setDiscoveryInitialWaitTimeout(final Long discoveryInitialWaitTimeout) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDiscoveryInitialWaitTimeout(" + discoveryInitialWaitTimeout + ")"); logger.trace("setDiscoveryInitialWaitTimeout(" + discoveryInitialWaitTimeout + ")");
} }
raProperties.setDiscoveryInitialWaitTimeout(discoveryInitialWaitTimeout); raProperties.setDiscoveryInitialWaitTimeout(discoveryInitialWaitTimeout);
@ -523,8 +521,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getClientFailureCheckPeriod() { public Long getClientFailureCheckPeriod() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getClientFailureCheckPeriod()"); logger.trace("getClientFailureCheckPeriod()");
} }
return raProperties.getClientFailureCheckPeriod(); return raProperties.getClientFailureCheckPeriod();
@ -536,8 +534,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param clientFailureCheckPeriod The value * @param clientFailureCheckPeriod The value
*/ */
public void setClientFailureCheckPeriod(final Long clientFailureCheckPeriod) { public void setClientFailureCheckPeriod(final Long clientFailureCheckPeriod) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setClientFailureCheckPeriod(" + clientFailureCheckPeriod + ")"); logger.trace("setClientFailureCheckPeriod(" + clientFailureCheckPeriod + ")");
} }
raProperties.setClientFailureCheckPeriod(clientFailureCheckPeriod); raProperties.setClientFailureCheckPeriod(clientFailureCheckPeriod);
@ -549,8 +547,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getConnectionTTL() { public Long getConnectionTTL() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getConnectionTTL()"); logger.trace("getConnectionTTL()");
} }
return raProperties.getConnectionTTL(); return raProperties.getConnectionTTL();
@ -562,8 +560,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param connectionTTL The value * @param connectionTTL The value
*/ */
public void setConnectionTTL(final Long connectionTTL) { public void setConnectionTTL(final Long connectionTTL) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConnectionTTL(" + connectionTTL + ")"); logger.trace("setConnectionTTL(" + connectionTTL + ")");
} }
raProperties.setConnectionTTL(connectionTTL); raProperties.setConnectionTTL(connectionTTL);
@ -575,8 +573,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean isCacheLargeMessagesClient() { public Boolean isCacheLargeMessagesClient() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isCacheLargeMessagesClient()"); logger.trace("isCacheLargeMessagesClient()");
} }
return raProperties.isCacheLargeMessagesClient(); return raProperties.isCacheLargeMessagesClient();
@ -588,8 +586,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param cacheLargeMessagesClient The value * @param cacheLargeMessagesClient The value
*/ */
public void setCacheLargeMessagesClient(final Boolean cacheLargeMessagesClient) { public void setCacheLargeMessagesClient(final Boolean cacheLargeMessagesClient) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setCacheLargeMessagesClient(" + cacheLargeMessagesClient + ")"); logger.trace("setCacheLargeMessagesClient(" + cacheLargeMessagesClient + ")");
} }
raProperties.setCacheLargeMessagesClient(cacheLargeMessagesClient); raProperties.setCacheLargeMessagesClient(cacheLargeMessagesClient);
@ -601,8 +599,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean isCompressLargeMessage() { public Boolean isCompressLargeMessage() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isCompressLargeMessage()"); logger.trace("isCompressLargeMessage()");
} }
return raProperties.isCompressLargeMessage(); return raProperties.isCompressLargeMessage();
@ -614,8 +612,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param failoverOnInitialConnection The value * @param failoverOnInitialConnection The value
*/ */
public void setFailoverOnInitialConnection(final Boolean failoverOnInitialConnection) { public void setFailoverOnInitialConnection(final Boolean failoverOnInitialConnection) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setFailoverOnInitialConnection(" + failoverOnInitialConnection + ")"); logger.trace("setFailoverOnInitialConnection(" + failoverOnInitialConnection + ")");
} }
raProperties.setFailoverOnInitialConnection(failoverOnInitialConnection); raProperties.setFailoverOnInitialConnection(failoverOnInitialConnection);
@ -627,8 +625,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean isFailoverOnInitialConnection() { public Boolean isFailoverOnInitialConnection() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isFailoverOnInitialConnection()"); logger.trace("isFailoverOnInitialConnection()");
} }
return raProperties.isFailoverOnInitialConnection(); return raProperties.isFailoverOnInitialConnection();
@ -666,8 +664,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param compressLargeMessage The value * @param compressLargeMessage The value
*/ */
public void setCompressLargeMessage(final Boolean compressLargeMessage) { public void setCompressLargeMessage(final Boolean compressLargeMessage) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setCompressLargeMessage(" + compressLargeMessage + ")"); logger.trace("setCompressLargeMessage(" + compressLargeMessage + ")");
} }
raProperties.setCompressLargeMessage(compressLargeMessage); raProperties.setCompressLargeMessage(compressLargeMessage);
@ -679,8 +677,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getCallTimeout() { public Long getCallTimeout() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getCallTimeout()"); logger.trace("getCallTimeout()");
} }
return raProperties.getCallTimeout(); return raProperties.getCallTimeout();
@ -692,8 +690,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param callTimeout The value * @param callTimeout The value
*/ */
public void setCallTimeout(final Long callTimeout) { public void setCallTimeout(final Long callTimeout) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setCallTimeout(" + callTimeout + ")"); logger.trace("setCallTimeout(" + callTimeout + ")");
} }
raProperties.setCallTimeout(callTimeout); raProperties.setCallTimeout(callTimeout);
@ -705,8 +703,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getCallFailoverTimeout() { public Long getCallFailoverTimeout() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getCallFailoverTimeout()"); logger.trace("getCallFailoverTimeout()");
} }
return raProperties.getCallFailoverTimeout(); return raProperties.getCallFailoverTimeout();
@ -718,8 +716,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param callFailoverTimeout The value * @param callFailoverTimeout The value
*/ */
public void setCallFailoverTimeout(final Long callFailoverTimeout) { public void setCallFailoverTimeout(final Long callFailoverTimeout) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setCallFailoverTimeout(" + callFailoverTimeout + ")"); logger.trace("setCallFailoverTimeout(" + callFailoverTimeout + ")");
} }
raProperties.setCallFailoverTimeout(callFailoverTimeout); raProperties.setCallFailoverTimeout(callFailoverTimeout);
@ -731,8 +729,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getDupsOKBatchSize() { public Integer getDupsOKBatchSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDupsOKBatchSize()"); logger.trace("getDupsOKBatchSize()");
} }
return raProperties.getDupsOKBatchSize(); return raProperties.getDupsOKBatchSize();
@ -744,8 +742,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param dupsOKBatchSize The value * @param dupsOKBatchSize The value
*/ */
public void setDupsOKBatchSize(final Integer dupsOKBatchSize) { public void setDupsOKBatchSize(final Integer dupsOKBatchSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDupsOKBatchSize(" + dupsOKBatchSize + ")"); logger.trace("setDupsOKBatchSize(" + dupsOKBatchSize + ")");
} }
raProperties.setDupsOKBatchSize(dupsOKBatchSize); raProperties.setDupsOKBatchSize(dupsOKBatchSize);
@ -757,8 +755,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getTransactionBatchSize() { public Integer getTransactionBatchSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getTransactionBatchSize()"); logger.trace("getTransactionBatchSize()");
} }
return raProperties.getTransactionBatchSize(); return raProperties.getTransactionBatchSize();
@ -770,8 +768,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param transactionBatchSize The value * @param transactionBatchSize The value
*/ */
public void setTransactionBatchSize(final Integer transactionBatchSize) { public void setTransactionBatchSize(final Integer transactionBatchSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setTransactionBatchSize(" + transactionBatchSize + ")"); logger.trace("setTransactionBatchSize(" + transactionBatchSize + ")");
} }
raProperties.setTransactionBatchSize(transactionBatchSize); raProperties.setTransactionBatchSize(transactionBatchSize);
@ -783,8 +781,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getConsumerWindowSize() { public Integer getConsumerWindowSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getConsumerWindowSize()"); logger.trace("getConsumerWindowSize()");
} }
return raProperties.getConsumerWindowSize(); return raProperties.getConsumerWindowSize();
@ -796,8 +794,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param consumerWindowSize The value * @param consumerWindowSize The value
*/ */
public void setConsumerWindowSize(final Integer consumerWindowSize) { public void setConsumerWindowSize(final Integer consumerWindowSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConsumerWindowSize(" + consumerWindowSize + ")"); logger.trace("setConsumerWindowSize(" + consumerWindowSize + ")");
} }
raProperties.setConsumerWindowSize(consumerWindowSize); raProperties.setConsumerWindowSize(consumerWindowSize);
@ -809,8 +807,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getConsumerMaxRate() { public Integer getConsumerMaxRate() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getConsumerMaxRate()"); logger.trace("getConsumerMaxRate()");
} }
return raProperties.getConsumerMaxRate(); return raProperties.getConsumerMaxRate();
@ -822,8 +820,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param consumerMaxRate The value * @param consumerMaxRate The value
*/ */
public void setConsumerMaxRate(final Integer consumerMaxRate) { public void setConsumerMaxRate(final Integer consumerMaxRate) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConsumerMaxRate(" + consumerMaxRate + ")"); logger.trace("setConsumerMaxRate(" + consumerMaxRate + ")");
} }
raProperties.setConsumerMaxRate(consumerMaxRate); raProperties.setConsumerMaxRate(consumerMaxRate);
@ -835,8 +833,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getConfirmationWindowSize() { public Integer getConfirmationWindowSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getConfirmationWindowSize()"); logger.trace("getConfirmationWindowSize()");
} }
return raProperties.getConfirmationWindowSize(); return raProperties.getConfirmationWindowSize();
@ -848,8 +846,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param confirmationWindowSize The value * @param confirmationWindowSize The value
*/ */
public void setConfirmationWindowSize(final Integer confirmationWindowSize) { public void setConfirmationWindowSize(final Integer confirmationWindowSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConfirmationWindowSize(" + confirmationWindowSize + ")"); logger.trace("setConfirmationWindowSize(" + confirmationWindowSize + ")");
} }
raProperties.setConfirmationWindowSize(confirmationWindowSize); raProperties.setConfirmationWindowSize(confirmationWindowSize);
@ -861,8 +859,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getProducerMaxRate() { public Integer getProducerMaxRate() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getProducerMaxRate()"); logger.trace("getProducerMaxRate()");
} }
return raProperties.getProducerMaxRate(); return raProperties.getProducerMaxRate();
@ -874,8 +872,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param producerMaxRate The value * @param producerMaxRate The value
*/ */
public void setProducerMaxRate(final Integer producerMaxRate) { public void setProducerMaxRate(final Integer producerMaxRate) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setProducerMaxRate(" + producerMaxRate + ")"); logger.trace("setProducerMaxRate(" + producerMaxRate + ")");
} }
raProperties.setProducerMaxRate(producerMaxRate); raProperties.setProducerMaxRate(producerMaxRate);
@ -887,8 +885,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getProducerWindowSize() { public Integer getProducerWindowSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getProducerWindowSize()"); logger.trace("getProducerWindowSize()");
} }
return raProperties.getProducerWindowSize(); return raProperties.getProducerWindowSize();
@ -900,54 +898,54 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param producerWindowSize The value * @param producerWindowSize The value
*/ */
public void setProducerWindowSize(final Integer producerWindowSize) { public void setProducerWindowSize(final Integer producerWindowSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setProducerWindowSize(" + producerWindowSize + ")"); logger.trace("setProducerWindowSize(" + producerWindowSize + ")");
} }
raProperties.setProducerWindowSize(producerWindowSize); raProperties.setProducerWindowSize(producerWindowSize);
} }
public String getProtocolManagerFactoryStr() { public String getProtocolManagerFactoryStr() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getProtocolManagerFactoryStr()"); logger.trace("getProtocolManagerFactoryStr()");
} }
return raProperties.getProtocolManagerFactoryStr(); return raProperties.getProtocolManagerFactoryStr();
} }
public void setProtocolManagerFactoryStr(final String protocolManagerFactoryStr) { public void setProtocolManagerFactoryStr(final String protocolManagerFactoryStr) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setProtocolManagerFactoryStr(" + protocolManagerFactoryStr + ")"); logger.trace("setProtocolManagerFactoryStr(" + protocolManagerFactoryStr + ")");
} }
raProperties.setProtocolManagerFactoryStr(protocolManagerFactoryStr); raProperties.setProtocolManagerFactoryStr(protocolManagerFactoryStr);
} }
public String getDeserializationBlackList() { public String getDeserializationBlackList() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDeserializationBlackList()"); logger.trace("getDeserializationBlackList()");
} }
return raProperties.getDeserializationBlackList(); return raProperties.getDeserializationBlackList();
} }
public void setDeserializationBlackList(String deserializationBlackList) { public void setDeserializationBlackList(String deserializationBlackList) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDeserializationBlackList(" + deserializationBlackList + ")"); logger.trace("setDeserializationBlackList(" + deserializationBlackList + ")");
} }
raProperties.setDeserializationBlackList(deserializationBlackList); raProperties.setDeserializationBlackList(deserializationBlackList);
} }
public String getDeserializationWhiteList() { public String getDeserializationWhiteList() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDeserializationWhiteList()"); logger.trace("getDeserializationWhiteList()");
} }
return raProperties.getDeserializationWhiteList(); return raProperties.getDeserializationWhiteList();
} }
public void setDeserializationWhiteList(String deserializationWhiteList) { public void setDeserializationWhiteList(String deserializationWhiteList) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDeserializationWhiteList(" + deserializationWhiteList + ")"); logger.trace("setDeserializationWhiteList(" + deserializationWhiteList + ")");
} }
raProperties.setDeserializationWhiteList(deserializationWhiteList); raProperties.setDeserializationWhiteList(deserializationWhiteList);
@ -959,8 +957,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getMinLargeMessageSize() { public Integer getMinLargeMessageSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getMinLargeMessageSize()"); logger.trace("getMinLargeMessageSize()");
} }
return raProperties.getMinLargeMessageSize(); return raProperties.getMinLargeMessageSize();
@ -972,8 +970,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param minLargeMessageSize The value * @param minLargeMessageSize The value
*/ */
public void setMinLargeMessageSize(final Integer minLargeMessageSize) { public void setMinLargeMessageSize(final Integer minLargeMessageSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setMinLargeMessageSize(" + minLargeMessageSize + ")"); logger.trace("setMinLargeMessageSize(" + minLargeMessageSize + ")");
} }
raProperties.setMinLargeMessageSize(minLargeMessageSize); raProperties.setMinLargeMessageSize(minLargeMessageSize);
@ -985,8 +983,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getBlockOnAcknowledge() { public Boolean getBlockOnAcknowledge() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getBlockOnAcknowledge()"); logger.trace("getBlockOnAcknowledge()");
} }
return raProperties.isBlockOnAcknowledge(); return raProperties.isBlockOnAcknowledge();
@ -998,8 +996,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param blockOnAcknowledge The value * @param blockOnAcknowledge The value
*/ */
public void setBlockOnAcknowledge(final Boolean blockOnAcknowledge) { public void setBlockOnAcknowledge(final Boolean blockOnAcknowledge) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setBlockOnAcknowledge(" + blockOnAcknowledge + ")"); logger.trace("setBlockOnAcknowledge(" + blockOnAcknowledge + ")");
} }
raProperties.setBlockOnAcknowledge(blockOnAcknowledge); raProperties.setBlockOnAcknowledge(blockOnAcknowledge);
@ -1011,8 +1009,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getBlockOnNonDurableSend() { public Boolean getBlockOnNonDurableSend() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getBlockOnNonDurableSend()"); logger.trace("getBlockOnNonDurableSend()");
} }
return raProperties.isBlockOnNonDurableSend(); return raProperties.isBlockOnNonDurableSend();
@ -1024,8 +1022,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param blockOnNonDurableSend The value * @param blockOnNonDurableSend The value
*/ */
public void setBlockOnNonDurableSend(final Boolean blockOnNonDurableSend) { public void setBlockOnNonDurableSend(final Boolean blockOnNonDurableSend) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setBlockOnNonDurableSend(" + blockOnNonDurableSend + ")"); logger.trace("setBlockOnNonDurableSend(" + blockOnNonDurableSend + ")");
} }
raProperties.setBlockOnNonDurableSend(blockOnNonDurableSend); raProperties.setBlockOnNonDurableSend(blockOnNonDurableSend);
@ -1037,8 +1035,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getBlockOnDurableSend() { public Boolean getBlockOnDurableSend() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getBlockOnDurableSend()"); logger.trace("getBlockOnDurableSend()");
} }
return raProperties.isBlockOnDurableSend(); return raProperties.isBlockOnDurableSend();
@ -1050,8 +1048,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param blockOnDurableSend The value * @param blockOnDurableSend The value
*/ */
public void setBlockOnDurableSend(final Boolean blockOnDurableSend) { public void setBlockOnDurableSend(final Boolean blockOnDurableSend) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setBlockOnDurableSend(" + blockOnDurableSend + ")"); logger.trace("setBlockOnDurableSend(" + blockOnDurableSend + ")");
} }
raProperties.setBlockOnDurableSend(blockOnDurableSend); raProperties.setBlockOnDurableSend(blockOnDurableSend);
@ -1063,8 +1061,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getAutoGroup() { public Boolean getAutoGroup() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getAutoGroup()"); logger.trace("getAutoGroup()");
} }
return raProperties.isAutoGroup(); return raProperties.isAutoGroup();
@ -1076,8 +1074,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param autoGroup The value * @param autoGroup The value
*/ */
public void setAutoGroup(final Boolean autoGroup) { public void setAutoGroup(final Boolean autoGroup) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setAutoGroup(" + autoGroup + ")"); logger.trace("setAutoGroup(" + autoGroup + ")");
} }
raProperties.setAutoGroup(autoGroup); raProperties.setAutoGroup(autoGroup);
@ -1089,8 +1087,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getPreAcknowledge() { public Boolean getPreAcknowledge() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getPreAcknowledge()"); logger.trace("getPreAcknowledge()");
} }
return raProperties.isPreAcknowledge(); return raProperties.isPreAcknowledge();
@ -1102,8 +1100,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param preAcknowledge The value * @param preAcknowledge The value
*/ */
public void setPreAcknowledge(final Boolean preAcknowledge) { public void setPreAcknowledge(final Boolean preAcknowledge) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setPreAcknowledge(" + preAcknowledge + ")"); logger.trace("setPreAcknowledge(" + preAcknowledge + ")");
} }
raProperties.setPreAcknowledge(preAcknowledge); raProperties.setPreAcknowledge(preAcknowledge);
@ -1115,8 +1113,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getInitialConnectAttempts() { public Integer getInitialConnectAttempts() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getInitialConnectAttempts()"); logger.trace("getInitialConnectAttempts()");
} }
return raProperties.getInitialConnectAttempts(); return raProperties.getInitialConnectAttempts();
@ -1128,8 +1126,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param initialConnectAttempts The value * @param initialConnectAttempts The value
*/ */
public void setInitialConnectAttempts(final Integer initialConnectAttempts) { public void setInitialConnectAttempts(final Integer initialConnectAttempts) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setInitialConnectionAttempts(" + initialConnectAttempts + ")"); logger.trace("setInitialConnectionAttempts(" + initialConnectAttempts + ")");
} }
raProperties.setInitialConnectAttempts(initialConnectAttempts); raProperties.setInitialConnectAttempts(initialConnectAttempts);
@ -1141,8 +1139,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getInitialMessagePacketSize() { public Integer getInitialMessagePacketSize() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getInitialMessagePacketSize()"); logger.trace("getInitialMessagePacketSize()");
} }
return raProperties.getInitialMessagePacketSize(); return raProperties.getInitialMessagePacketSize();
@ -1154,8 +1152,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param initialMessagePacketSize The value * @param initialMessagePacketSize The value
*/ */
public void setInitialMessagePacketSize(final Integer initialMessagePacketSize) { public void setInitialMessagePacketSize(final Integer initialMessagePacketSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setInitialMessagePacketSize(" + initialMessagePacketSize + ")"); logger.trace("setInitialMessagePacketSize(" + initialMessagePacketSize + ")");
} }
raProperties.setInitialMessagePacketSize(initialMessagePacketSize); raProperties.setInitialMessagePacketSize(initialMessagePacketSize);
@ -1167,8 +1165,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getRetryInterval() { public Long getRetryInterval() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getRetryInterval()"); logger.trace("getRetryInterval()");
} }
return raProperties.getRetryInterval(); return raProperties.getRetryInterval();
@ -1180,8 +1178,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param retryInterval The value * @param retryInterval The value
*/ */
public void setRetryInterval(final Long retryInterval) { public void setRetryInterval(final Long retryInterval) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setRetryInterval(" + retryInterval + ")"); logger.trace("setRetryInterval(" + retryInterval + ")");
} }
raProperties.setRetryInterval(retryInterval); raProperties.setRetryInterval(retryInterval);
@ -1193,8 +1191,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Double getRetryIntervalMultiplier() { public Double getRetryIntervalMultiplier() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getRetryIntervalMultiplier()"); logger.trace("getRetryIntervalMultiplier()");
} }
return raProperties.getRetryIntervalMultiplier(); return raProperties.getRetryIntervalMultiplier();
@ -1206,8 +1204,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param retryIntervalMultiplier The value * @param retryIntervalMultiplier The value
*/ */
public void setRetryIntervalMultiplier(final Double retryIntervalMultiplier) { public void setRetryIntervalMultiplier(final Double retryIntervalMultiplier) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setRetryIntervalMultiplier(" + retryIntervalMultiplier + ")"); logger.trace("setRetryIntervalMultiplier(" + retryIntervalMultiplier + ")");
} }
raProperties.setRetryIntervalMultiplier(retryIntervalMultiplier); raProperties.setRetryIntervalMultiplier(retryIntervalMultiplier);
@ -1219,8 +1217,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Long getMaxRetryInterval() { public Long getMaxRetryInterval() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getMaxRetryInterval()"); logger.trace("getMaxRetryInterval()");
} }
return raProperties.getMaxRetryInterval(); return raProperties.getMaxRetryInterval();
@ -1232,8 +1230,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param maxRetryInterval The value * @param maxRetryInterval The value
*/ */
public void setMaxRetryInterval(final Long maxRetryInterval) { public void setMaxRetryInterval(final Long maxRetryInterval) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setMaxRetryInterval(" + maxRetryInterval + ")"); logger.trace("setMaxRetryInterval(" + maxRetryInterval + ")");
} }
raProperties.setMaxRetryInterval(maxRetryInterval); raProperties.setMaxRetryInterval(maxRetryInterval);
@ -1245,8 +1243,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Integer getReconnectAttempts() { public Integer getReconnectAttempts() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getReconnectAttempts()"); logger.trace("getReconnectAttempts()");
} }
return raProperties.getReconnectAttempts(); return raProperties.getReconnectAttempts();
@ -1258,8 +1256,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param reconnectAttempts The value * @param reconnectAttempts The value
*/ */
public void setReconnectAttempts(final Integer reconnectAttempts) { public void setReconnectAttempts(final Integer reconnectAttempts) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setReconnectAttempts(" + reconnectAttempts + ")"); logger.trace("setReconnectAttempts(" + reconnectAttempts + ")");
} }
raProperties.setReconnectAttempts(reconnectAttempts); raProperties.setReconnectAttempts(reconnectAttempts);
@ -1270,8 +1268,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
} }
public void setConnectionLoadBalancingPolicyClassName(final String connectionLoadBalancingPolicyClassName) { public void setConnectionLoadBalancingPolicyClassName(final String connectionLoadBalancingPolicyClassName) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setFailoverOnServerShutdown(" + connectionLoadBalancingPolicyClassName + ")"); logger.trace("setFailoverOnServerShutdown(" + connectionLoadBalancingPolicyClassName + ")");
} }
raProperties.setConnectionLoadBalancingPolicyClassName(connectionLoadBalancingPolicyClassName); raProperties.setConnectionLoadBalancingPolicyClassName(connectionLoadBalancingPolicyClassName);
} }
@ -1281,8 +1279,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
} }
public void setScheduledThreadPoolMaxSize(final Integer scheduledThreadPoolMaxSize) { public void setScheduledThreadPoolMaxSize(final Integer scheduledThreadPoolMaxSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setFailoverOnServerShutdown(" + scheduledThreadPoolMaxSize + ")"); logger.trace("setFailoverOnServerShutdown(" + scheduledThreadPoolMaxSize + ")");
} }
raProperties.setScheduledThreadPoolMaxSize(scheduledThreadPoolMaxSize); raProperties.setScheduledThreadPoolMaxSize(scheduledThreadPoolMaxSize);
} }
@ -1292,8 +1290,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
} }
public void setThreadPoolMaxSize(final Integer threadPoolMaxSize) { public void setThreadPoolMaxSize(final Integer threadPoolMaxSize) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setFailoverOnServerShutdown(" + threadPoolMaxSize + ")"); logger.trace("setFailoverOnServerShutdown(" + threadPoolMaxSize + ")");
} }
raProperties.setThreadPoolMaxSize(threadPoolMaxSize); raProperties.setThreadPoolMaxSize(threadPoolMaxSize);
} }
@ -1303,8 +1301,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
} }
public void setUseGlobalPools(final Boolean useGlobalPools) { public void setUseGlobalPools(final Boolean useGlobalPools) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setFailoverOnServerShutdown(" + useGlobalPools + ")"); logger.trace("setFailoverOnServerShutdown(" + useGlobalPools + ")");
} }
raProperties.setUseGlobalPools(useGlobalPools); raProperties.setUseGlobalPools(useGlobalPools);
} }
@ -1315,8 +1313,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public String getUserName() { public String getUserName() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getUserName()"); logger.trace("getUserName()");
} }
return raProperties.getUserName(); return raProperties.getUserName();
@ -1328,8 +1326,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param userName The value * @param userName The value
*/ */
public void setUserName(final String userName) { public void setUserName(final String userName) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setUserName(" + userName + ")"); logger.trace("setUserName(" + userName + ")");
} }
raProperties.setUserName(userName); raProperties.setUserName(userName);
@ -1341,8 +1339,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public String getPassword() { public String getPassword() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getPassword()"); logger.trace("getPassword()");
} }
return raProperties.getPassword(); return raProperties.getPassword();
@ -1354,8 +1352,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param password The value * @param password The value
*/ */
public void setPassword(final String password) { public void setPassword(final String password) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setPassword(****)"); logger.trace("setPassword(****)");
} }
raProperties.setPassword(password); raProperties.setPassword(password);
@ -1397,8 +1395,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public String getClientID() { public String getClientID() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getClientID()"); logger.trace("getClientID()");
} }
return raProperties.getClientID(); return raProperties.getClientID();
@ -1410,8 +1408,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param clientID The client id * @param clientID The client id
*/ */
public void setClientID(final String clientID) { public void setClientID(final String clientID) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setClientID(" + clientID + ")"); logger.trace("setClientID(" + clientID + ")");
} }
raProperties.setClientID(clientID); raProperties.setClientID(clientID);
@ -1423,8 +1421,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public String getGroupID() { public String getGroupID() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getGroupID()"); logger.trace("getGroupID()");
} }
return raProperties.getGroupID(); return raProperties.getGroupID();
@ -1436,8 +1434,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param groupID The group id * @param groupID The group id
*/ */
public void setGroupID(final String groupID) { public void setGroupID(final String groupID) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setGroupID(" + groupID + ")"); logger.trace("setGroupID(" + groupID + ")");
} }
raProperties.setGroupID(groupID); raProperties.setGroupID(groupID);
@ -1449,8 +1447,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The value * @return The value
*/ */
public Boolean getUseLocalTx() { public Boolean getUseLocalTx() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getUseLocalTx()"); logger.trace("getUseLocalTx()");
} }
return raProperties.getUseLocalTx(); return raProperties.getUseLocalTx();
@ -1462,37 +1460,37 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @param localTx The value * @param localTx The value
*/ */
public void setUseLocalTx(final Boolean localTx) { public void setUseLocalTx(final Boolean localTx) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setUseXA(" + localTx + ")"); logger.trace("setUseXA(" + localTx + ")");
} }
raProperties.setUseLocalTx(localTx); raProperties.setUseLocalTx(localTx);
} }
public int getSetupAttempts() { public int getSetupAttempts() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSetupAttempts()"); logger.trace("getSetupAttempts()");
} }
return raProperties.getSetupAttempts(); return raProperties.getSetupAttempts();
} }
public void setSetupAttempts(Integer setupAttempts) { public void setSetupAttempts(Integer setupAttempts) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSetupAttempts(" + setupAttempts + ")"); logger.trace("setSetupAttempts(" + setupAttempts + ")");
} }
raProperties.setSetupAttempts(setupAttempts); raProperties.setSetupAttempts(setupAttempts);
} }
public long getSetupInterval() { public long getSetupInterval() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSetupInterval()"); logger.trace("getSetupInterval()");
} }
return raProperties.getSetupInterval(); return raProperties.getSetupInterval();
} }
public void setSetupInterval(Long interval) { public void setSetupInterval(Long interval) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSetupInterval(" + interval + ")"); logger.trace("setSetupInterval(" + interval + ")");
} }
raProperties.setSetupInterval(interval); raProperties.setSetupInterval(interval);
} }
@ -1505,8 +1503,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public boolean equals(final Object obj) { public boolean equals(final Object obj) {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("equals(" + obj + ")"); logger.trace("equals(" + obj + ")");
} }
if (obj == null) { if (obj == null) {
@ -1526,8 +1524,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
*/ */
@Override @Override
public int hashCode() { public int hashCode() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("hashCode()"); logger.trace("hashCode()");
} }
return raProperties.hashCode(); return raProperties.hashCode();
@ -1539,8 +1537,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The manager * @return The manager
*/ */
public WorkManager getWorkManager() { public WorkManager getWorkManager() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getWorkManager()"); logger.trace("getWorkManager()");
} }
if (ctx == null) { if (ctx == null) {
@ -1608,8 +1606,8 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable {
* @return The properties * @return The properties
*/ */
protected ActiveMQRAProperties getProperties() { protected ActiveMQRAProperties getProperties() {
if (ActiveMQResourceAdapter.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getProperties()"); logger.trace("getProperties()");
} }
return raProperties; return raProperties;

54
artemis-ra/src/main/java/org/apache/activemq/artemis/ra/inflow/ActiveMQActivation.java
View File

@ -58,16 +58,14 @@ import org.apache.activemq.artemis.ra.ActiveMQResourceAdapter;
import org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig; import org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig;
import org.apache.activemq.artemis.utils.FutureLatch; import org.apache.activemq.artemis.utils.FutureLatch;
import org.apache.activemq.artemis.utils.SensitiveDataCodec; import org.apache.activemq.artemis.utils.SensitiveDataCodec;
import org.jboss.logging.Logger;
/** /**
* The activation. * The activation.
*/ */
public class ActiveMQActivation { public class ActiveMQActivation {
/** private static final Logger logger = Logger.getLogger(ActiveMQActivation.class);
* Trace enabled
*/
private static boolean trace = ActiveMQRALogger.LOGGER.isTraceEnabled();
/** /**
* The onMessage method * The onMessage method
@ -146,8 +144,8 @@ public class ActiveMQActivation {
final ActiveMQActivationSpec spec) throws ResourceException { final ActiveMQActivationSpec spec) throws ResourceException {
spec.validate(); spec.validate();
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("constructor(" + ra + ", " + endpointFactory + ", " + spec + ")"); logger.trace("constructor(" + ra + ", " + endpointFactory + ", " + spec + ")");
} }
if (ra.isUseMaskedPassword()) { if (ra.isUseMaskedPassword()) {
@ -179,8 +177,8 @@ public class ActiveMQActivation {
* @return The value * @return The value
*/ */
public ActiveMQActivationSpec getActivationSpec() { public ActiveMQActivationSpec getActivationSpec() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getActivationSpec()"); logger.trace("getActivationSpec()");
} }
return spec; return spec;
@ -192,8 +190,8 @@ public class ActiveMQActivation {
* @return The value * @return The value
*/ */
public MessageEndpointFactory getMessageEndpointFactory() { public MessageEndpointFactory getMessageEndpointFactory() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getMessageEndpointFactory()"); logger.trace("getMessageEndpointFactory()");
} }
return endpointFactory; return endpointFactory;
@ -205,8 +203,8 @@ public class ActiveMQActivation {
* @return The value * @return The value
*/ */
public boolean isDeliveryTransacted() { public boolean isDeliveryTransacted() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isDeliveryTransacted()"); logger.trace("isDeliveryTransacted()");
} }
return isDeliveryTransacted; return isDeliveryTransacted;
@ -218,8 +216,8 @@ public class ActiveMQActivation {
* @return The value * @return The value
*/ */
public WorkManager getWorkManager() { public WorkManager getWorkManager() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getWorkManager()"); logger.trace("getWorkManager()");
} }
return ra.getWorkManager(); return ra.getWorkManager();
@ -231,8 +229,8 @@ public class ActiveMQActivation {
* @return The value * @return The value
*/ */
public boolean isTopic() { public boolean isTopic() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isTopic()"); logger.trace("isTopic()");
} }
return isTopic; return isTopic;
@ -244,8 +242,8 @@ public class ActiveMQActivation {
* @throws ResourceException Thrown if an error occurs * @throws ResourceException Thrown if an error occurs
*/ */
public void start() throws ResourceException { public void start() throws ResourceException {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("start()"); logger.trace("start()");
} }
deliveryActive.set(true); deliveryActive.set(true);
ra.getWorkManager().scheduleWork(new SetupActivation()); ra.getWorkManager().scheduleWork(new SetupActivation());
@ -283,8 +281,8 @@ public class ActiveMQActivation {
* Stop the activation * Stop the activation
*/ */
public void stop() { public void stop() {
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("stop()"); logger.trace("stop()");
} }
deliveryActive.set(false); deliveryActive.set(false);
@ -497,7 +495,7 @@ public class ActiveMQActivation {
result.close(); result.close();
} }
} catch (Exception e) { } catch (Exception e) {
ActiveMQRALogger.LOGGER.trace("Ignored error closing connection", e); logger.trace("Ignored error closing connection", e);
} }
if (t instanceof Exception) { if (t instanceof Exception) {
throw (Exception) t; throw (Exception) t;
@ -522,8 +520,8 @@ public class ActiveMQActivation {
ctx = new InitialContext(spec.getParsedJndiParams()); ctx = new InitialContext(spec.getParsedJndiParams());
} }
ActiveMQRALogger.LOGGER.debug("Using context " + ctx.getEnvironment() + " for " + spec); ActiveMQRALogger.LOGGER.debug("Using context " + ctx.getEnvironment() + " for " + spec);
if (ActiveMQActivation.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setupDestination(" + ctx + ")"); logger.trace("setupDestination(" + ctx + ")");
} }
String destinationTypeString = spec.getDestinationType(); String destinationTypeString = spec.getDestinationType();
@ -602,8 +600,8 @@ public class ActiveMQActivation {
} }
public void startReconnectThread(final String threadName) { public void startReconnectThread(final String threadName) {
if (trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("Starting reconnect Thread " + threadName + " on MDB activation " + this); logger.trace("Starting reconnect Thread " + threadName + " on MDB activation " + this);
} }
Runnable runnable = new Runnable() { Runnable runnable = new Runnable() {
@Override @Override
@ -621,8 +619,8 @@ public class ActiveMQActivation {
* @param failure if reconnecting in the event of a failure * @param failure if reconnecting in the event of a failure
*/ */
public void reconnect(Throwable failure) { public void reconnect(Throwable failure) {
if (trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("reconnecting activation " + this); logger.trace("reconnecting activation " + this);
} }
if (failure != null) { if (failure != null) {
if (failure instanceof ActiveMQException && ((ActiveMQException) failure).getType() == ActiveMQExceptionType.QUEUE_DOES_NOT_EXIST) { if (failure instanceof ActiveMQException && ((ActiveMQException) failure).getType() == ActiveMQExceptionType.QUEUE_DOES_NOT_EXIST) {

148
artemis-ra/src/main/java/org/apache/activemq/artemis/ra/inflow/ActiveMQActivationSpec.java
View File

@ -34,6 +34,7 @@ import org.apache.activemq.artemis.ra.ActiveMQRALogger;
import org.apache.activemq.artemis.ra.ActiveMQRaUtils; import org.apache.activemq.artemis.ra.ActiveMQRaUtils;
import org.apache.activemq.artemis.ra.ActiveMQResourceAdapter; import org.apache.activemq.artemis.ra.ActiveMQResourceAdapter;
import org.apache.activemq.artemis.ra.ConnectionFactoryProperties; import org.apache.activemq.artemis.ra.ConnectionFactoryProperties;
import org.jboss.logging.Logger;
/** /**
* The activation spec * The activation spec
@ -41,15 +42,12 @@ import org.apache.activemq.artemis.ra.ConnectionFactoryProperties;
*/ */
public class ActiveMQActivationSpec extends ConnectionFactoryProperties implements ActivationSpec, Serializable { public class ActiveMQActivationSpec extends ConnectionFactoryProperties implements ActivationSpec, Serializable {
private static final Logger logger = Logger.getLogger(ActiveMQActivationSpec.class);
private static final long serialVersionUID = -7997041053897964654L; private static final long serialVersionUID = -7997041053897964654L;
private static final int DEFAULT_MAX_SESSION = 15; private static final int DEFAULT_MAX_SESSION = 15;
/**
* Whether trace is enabled
*/
private static boolean trace = ActiveMQRALogger.LOGGER.isTraceEnabled();
public String strConnectorClassName; public String strConnectorClassName;
public String strConnectionParameters; public String strConnectionParameters;
@ -141,8 +139,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* Constructor * Constructor
*/ */
public ActiveMQActivationSpec() { public ActiveMQActivationSpec() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("constructor()"); logger.trace("constructor()");
} }
ra = null; ra = null;
@ -165,8 +163,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
*/ */
@Override @Override
public ResourceAdapter getResourceAdapter() { public ResourceAdapter getResourceAdapter() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getResourceAdapter()"); logger.trace("getResourceAdapter()");
} }
return ra; return ra;
@ -219,8 +217,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
*/ */
@Override @Override
public void setResourceAdapter(final ResourceAdapter ra) throws ResourceException { public void setResourceAdapter(final ResourceAdapter ra) throws ResourceException {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setResourceAdapter(" + ra + ")"); logger.trace("setResourceAdapter(" + ra + ")");
} }
if (ra == null || !(ra instanceof ActiveMQResourceAdapter)) { if (ra == null || !(ra instanceof ActiveMQResourceAdapter)) {
@ -236,8 +234,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getConnectionFactoryLookup() { public String getConnectionFactoryLookup() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getConnectionFactoryLookup() ->" + connectionFactoryLookup); logger.trace("getConnectionFactoryLookup() ->" + connectionFactoryLookup);
} }
return connectionFactoryLookup; return connectionFactoryLookup;
@ -249,8 +247,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setConnectionFactoryLookup(final String value) { public void setConnectionFactoryLookup(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConnectionFactoryLookup(" + value + ")"); logger.trace("setConnectionFactoryLookup(" + value + ")");
} }
connectionFactoryLookup = value; connectionFactoryLookup = value;
@ -262,8 +260,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getDestination() { public String getDestination() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDestination()"); logger.trace("getDestination()");
} }
return destination; return destination;
@ -275,8 +273,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setDestination(final String value) { public void setDestination(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDestination(" + value + ")"); logger.trace("setDestination(" + value + ")");
} }
destination = value; destination = value;
@ -307,8 +305,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getDestinationType() { public String getDestinationType() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getDestinationType()"); logger.trace("getDestinationType()");
} }
return destinationType; return destinationType;
@ -320,8 +318,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setDestinationType(final String value) { public void setDestinationType(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setDestinationType(" + value + ")"); logger.trace("setDestinationType(" + value + ")");
} }
destinationType = value; destinationType = value;
@ -333,8 +331,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getMessageSelector() { public String getMessageSelector() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getMessageSelector()"); logger.trace("getMessageSelector()");
} }
return messageSelector; return messageSelector;
@ -346,8 +344,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setMessageSelector(final String value) { public void setMessageSelector(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setMessageSelector(" + value + ")"); logger.trace("setMessageSelector(" + value + ")");
} }
messageSelector = value; messageSelector = value;
@ -359,8 +357,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getAcknowledgeMode() { public String getAcknowledgeMode() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getAcknowledgeMode()"); logger.trace("getAcknowledgeMode()");
} }
if (Session.DUPS_OK_ACKNOWLEDGE == acknowledgeMode) { if (Session.DUPS_OK_ACKNOWLEDGE == acknowledgeMode) {
@ -376,8 +374,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setAcknowledgeMode(final String value) { public void setAcknowledgeMode(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setAcknowledgeMode(" + value + ")"); logger.trace("setAcknowledgeMode(" + value + ")");
} }
if ("DUPS_OK_ACKNOWLEDGE".equalsIgnoreCase(value) || "Dups-ok-acknowledge".equalsIgnoreCase(value)) { if ("DUPS_OK_ACKNOWLEDGE".equalsIgnoreCase(value) || "Dups-ok-acknowledge".equalsIgnoreCase(value)) {
@ -393,8 +391,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return the acknowledgement mode * @return the acknowledgement mode
*/ */
public Integer getAcknowledgeModeInt() { public Integer getAcknowledgeModeInt() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getAcknowledgeMode()"); logger.trace("getAcknowledgeMode()");
} }
return acknowledgeMode; return acknowledgeMode;
@ -406,8 +404,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getSubscriptionDurability() { public String getSubscriptionDurability() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSubscriptionDurability()"); logger.trace("getSubscriptionDurability()");
} }
if (subscriptionDurability) { if (subscriptionDurability) {
@ -423,8 +421,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setSubscriptionDurability(final String value) { public void setSubscriptionDurability(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSubscriptionDurability(" + value + ")"); logger.trace("setSubscriptionDurability(" + value + ")");
} }
subscriptionDurability = "Durable".equals(value); subscriptionDurability = "Durable".equals(value);
@ -436,8 +434,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public Boolean isSubscriptionDurable() { public Boolean isSubscriptionDurable() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isSubscriptionDurable()"); logger.trace("isSubscriptionDurable()");
} }
return subscriptionDurability; return subscriptionDurability;
@ -449,8 +447,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getSubscriptionName() { public String getSubscriptionName() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSubscriptionName()"); logger.trace("getSubscriptionName()");
} }
return subscriptionName; return subscriptionName;
@ -462,8 +460,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setSubscriptionName(final String value) { public void setSubscriptionName(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSubscriptionName(" + value + ")"); logger.trace("setSubscriptionName(" + value + ")");
} }
subscriptionName = value; subscriptionName = value;
@ -473,8 +471,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return the shareDurableSubscriptions * @return the shareDurableSubscriptions
*/ */
public Boolean isShareSubscriptions() { public Boolean isShareSubscriptions() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("isShareSubscriptions() = " + shareSubscriptions); logger.trace("isShareSubscriptions() = " + shareSubscriptions);
} }
return shareSubscriptions; return shareSubscriptions;
@ -484,8 +482,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param shareSubscriptions the shareDurableSubscriptions to set * @param shareSubscriptions the shareDurableSubscriptions to set
*/ */
public void setShareSubscriptions(final Boolean shareSubscriptions) { public void setShareSubscriptions(final Boolean shareSubscriptions) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setShareSubscriptions(" + shareSubscriptions + ")"); logger.trace("setShareSubscriptions(" + shareSubscriptions + ")");
} }
this.shareSubscriptions = shareSubscriptions; this.shareSubscriptions = shareSubscriptions;
@ -497,8 +495,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getUser() { public String getUser() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getUser()"); logger.trace("getUser()");
} }
if (user == null) { if (user == null) {
@ -514,8 +512,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setUser(final String value) { public void setUser(final String value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setUser(" + value + ")"); logger.trace("setUser(" + value + ")");
} }
user = value; user = value;
@ -527,8 +525,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public String getPassword() { public String getPassword() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getPassword()"); logger.trace("getPassword()");
} }
if (password == null) { if (password == null) {
@ -548,8 +546,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setPassword(final String value) throws Exception { public void setPassword(final String value) throws Exception {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setPassword(****)"); logger.trace("setPassword(****)");
} }
password = value; password = value;
@ -561,8 +559,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public Integer getMaxSession() { public Integer getMaxSession() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getMaxSession()"); logger.trace("getMaxSession()");
} }
if (maxSession == null) { if (maxSession == null) {
@ -578,8 +576,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setMaxSession(final Integer value) { public void setMaxSession(final Integer value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setMaxSession(" + value + ")"); logger.trace("setMaxSession(" + value + ")");
} }
maxSession = value; maxSession = value;
@ -591,8 +589,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @return The value * @return The value
*/ */
public Integer getTransactionTimeout() { public Integer getTransactionTimeout() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getTransactionTimeout()"); logger.trace("getTransactionTimeout()");
} }
return transactionTimeout; return transactionTimeout;
@ -604,8 +602,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
* @param value The value * @param value The value
*/ */
public void setTransactionTimeout(final Integer value) { public void setTransactionTimeout(final Integer value) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setTransactionTimeout(" + value + ")"); logger.trace("setTransactionTimeout(" + value + ")");
} }
transactionTimeout = value; transactionTimeout = value;
@ -632,8 +630,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
} }
public Integer getSetupAttempts() { public Integer getSetupAttempts() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSetupAttempts()"); logger.trace("getSetupAttempts()");
} }
if (setupAttempts == null) { if (setupAttempts == null) {
@ -644,16 +642,16 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
} }
public void setSetupAttempts(final Integer setupAttempts) { public void setSetupAttempts(final Integer setupAttempts) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSetupAttempts(" + setupAttempts + ")"); logger.trace("setSetupAttempts(" + setupAttempts + ")");
} }
this.setupAttempts = setupAttempts; this.setupAttempts = setupAttempts;
} }
public Long getSetupInterval() { public Long getSetupInterval() {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("getSetupInterval()"); logger.trace("getSetupInterval()");
} }
if (setupInterval == null) { if (setupInterval == null) {
@ -664,8 +662,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
} }
public void setSetupInterval(final Long setupInterval) { public void setSetupInterval(final Long setupInterval) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setSetupInterval(" + setupInterval + ")"); logger.trace("setSetupInterval(" + setupInterval + ")");
} }
this.setupInterval = setupInterval; this.setupInterval = setupInterval;
@ -683,8 +681,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
*/ */
@Override @Override
public void validate() throws InvalidPropertyException { public void validate() throws InvalidPropertyException {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("validate()"); logger.trace("validate()");
} }
List<String> errorMessages = new ArrayList<>(); List<String> errorMessages = new ArrayList<>();
@ -728,8 +726,8 @@ public class ActiveMQActivationSpec extends ConnectionFactoryProperties implemen
} }
public void setConnectorClassName(final String connectorClassName) { public void setConnectorClassName(final String connectorClassName) {
if (ActiveMQActivationSpec.trace) { if (logger.isTraceEnabled()) {
ActiveMQRALogger.LOGGER.trace("setConnectorClassName(" + connectorClassName + ")"); logger.trace("setConnectorClassName(" + connectorClassName + ")");
} }
strConnectorClassName = connectorClassName; strConnectorClassName = connectorClassName;