activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: Traces on producer.send
Date Tue, 31 May 2016 22:27:20 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 48ad51001 -> ae7300142


Traces on producer.send


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/242730a2
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/242730a2
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/242730a2

Branch: refs/heads/master
Commit: 242730a278033362cf0e5fcaa74603ae5790f1ee
Parents: 48ad510
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Tue May 31 18:14:38 2016 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue May 31 18:14:38 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/core/client/impl/ClientProducerImpl.java | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/242730a2/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java
index b4aa196..392454e 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientProducerImpl.java
@@ -34,12 +34,15 @@ import org.apache.activemq.artemis.utils.DeflaterReader;
 import org.apache.activemq.artemis.utils.ActiveMQBufferInputStream;
 import org.apache.activemq.artemis.utils.TokenBucketLimiter;
 import org.apache.activemq.artemis.utils.UUIDGenerator;
+import org.jboss.logging.Logger;
 
 /**
  * The client-side Producer.
  */
 public class ClientProducerImpl implements ClientProducerInternal {
 
+   private static final Logger logger = Logger.getLogger(ClientProducerImpl.class);
+
    private final SimpleString address;
 
    private final ClientSessionInternal session;
@@ -290,6 +293,8 @@ public class ClientProducerImpl implements ClientProducerInternal {
       // Not the continuations, but this is ok since we are only interested in limiting the
amount of
       // data in *memory* and continuations go straight to the disk
 
+      logger.tracef("sendRegularMessage::%s, Blocking=%s", msgI, sendBlocking);
+
       int creditSize = sessionContext.getCreditsOnSendingFull(msgI);
 
       theCredits.acquireCredits(creditSize);
@@ -314,6 +319,8 @@ public class ClientProducerImpl implements ClientProducerInternal {
                                  final MessageInternal msgI,
                                  final ClientProducerCredits credits,
                                  SendAcknowledgementHandler handler) throws ActiveMQException
{
+      logger.tracef("largeMessageSend::%s, Blocking=%s", msgI, sendBlocking);
+
       int headerSize = msgI.getHeadersAndPropertiesEncodeSize();
 
       if (msgI.getHeadersAndPropertiesEncodeSize() >= minLargeMessageSize) {


Mime
View raw message