Repository: qpid-jms Updated Branches: refs/heads/master a4810fe1b -> d35be9992
Reduce logging levels for TX events to debug. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d35be999 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d35be999 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d35be999 Branch: refs/heads/master Commit: d35be9992c64770e2a524bf8dcb388dfe77e3922 Parents: a4810fe Author: Timothy Bish <[email protected]> Authored: Tue May 5 11:12:26 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue May 5 11:12:26 2015 -0400 ---------------------------------------------------------------------- .../apache/qpid/jms/provider/amqp/AmqpTransactionContext.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d35be999/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java index 184de9d..c150bb5 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java @@ -87,13 +87,13 @@ public class AmqpTransactionContext extends AmqpAbstractResource<JmsSessionInfo, Declared declared = (Declared) state; current.setProviderHint(declared.getTxnId()); pendingDelivery.settle(); - LOG.info("New TX started: {}", current.getProviderHint()); + LOG.debug("New TX started: {}", current.getProviderHint()); AsyncResult request = this.pendingRequest; this.pendingRequest = null; this.pendingDelivery = null; request.onSuccess(); } else if (state instanceof Rejected) { - LOG.info("Last TX request failed: {}", current.getProviderHint()); + LOG.debug("Last TX request failed: {}", current.getProviderHint()); pendingDelivery.settle(); Rejected rejected = (Rejected) state; TransactionRolledBackException ex = @@ -105,7 +105,7 @@ public class AmqpTransactionContext extends AmqpAbstractResource<JmsSessionInfo, postRollback(); request.onFailure(ex); } else { - LOG.info("Last TX request succeeded: {}", current.getProviderHint()); + LOG.debug("Last TX request succeeded: {}", current.getProviderHint()); pendingDelivery.settle(); AsyncResult request = this.pendingRequest; if (pendingDelivery.getContext() != null) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
