You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2017/07/07 15:02:34 UTC
activemq git commit: [no jira] make networkConsumerIds visible in
toString of consumerinfo to aid tracing consumers in a network via transport
trace logging
Repository: activemq
Updated Branches:
refs/heads/master 1f4831439 -> 499347542
[no jira] make networkConsumerIds visible in toString of consumerinfo to aid tracing consumers in a network via transport trace logging
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/49934754
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/49934754
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/49934754
Branch: refs/heads/master
Commit: 499347542c91774f0bd4a4e2a1a3932e286a7934
Parents: 1f48314
Author: gtully <ga...@gmail.com>
Authored: Fri Jul 7 16:01:49 2017 +0100
Committer: gtully <ga...@gmail.com>
Committed: Fri Jul 7 16:01:49 2017 +0100
----------------------------------------------------------------------
.../main/java/org/apache/activemq/command/ConsumerInfo.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/49934754/activemq-client/src/main/java/org/apache/activemq/command/ConsumerInfo.java
----------------------------------------------------------------------
diff --git a/activemq-client/src/main/java/org/apache/activemq/command/ConsumerInfo.java b/activemq-client/src/main/java/org/apache/activemq/command/ConsumerInfo.java
index 5ccafab..eec3c5c 100644
--- a/activemq-client/src/main/java/org/apache/activemq/command/ConsumerInfo.java
+++ b/activemq-client/src/main/java/org/apache/activemq/command/ConsumerInfo.java
@@ -17,6 +17,7 @@
package org.apache.activemq.command;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@@ -532,4 +533,11 @@ public class ConsumerInfo extends BaseCommand implements TransientInitializer {
lastDeliveredSequenceId = RemoveInfo.LAST_DELIVERED_UNSET;
}
+ @Override
+ public String toString() {
+ HashMap<String, Object> overrideFields = new HashMap<String, Object>();
+ overrideFields.put("networkConsumerIds", networkConsumerIds);
+ return super.toString(overrideFields);
+ }
+
}