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 2016/05/31 22:27:20 UTC
[1/2] activemq-artemis git commit: Traces on producer.send
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 <cl...@apache.org>
Authored: Tue May 31 18:14:38 2016 -0400
Committer: Clebert Suconic <cl...@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) {
[2/2] activemq-artemis git commit: This closes #547
Posted by cl...@apache.org.
This closes #547
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ae730014
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ae730014
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ae730014
Branch: refs/heads/master
Commit: ae73001427ed5904fb224e5975ec44614b1912ea
Parents: 48ad510 242730a
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue May 31 18:27:03 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue May 31 18:27:03 2016 -0400
----------------------------------------------------------------------
.../activemq/artemis/core/client/impl/ClientProducerImpl.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------