You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/04/09 07:54:03 UTC
camel git commit: CAMEL-11122: camel-reactive-streams - Add more JMX
information
Repository: camel
Updated Branches:
refs/heads/master 028e810bb -> 91bb1c33e
CAMEL-11122: camel-reactive-streams - Add more JMX information
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/91bb1c33
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/91bb1c33
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/91bb1c33
Branch: refs/heads/master
Commit: 91bb1c33e8b974311c23d39b5f650268557c8aa0
Parents: 028e810
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Apr 9 09:53:52 2017 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Apr 9 09:53:52 2017 +0200
----------------------------------------------------------------------
.../reactive/streams/engine/CamelReactiveStreamsServiceImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/91bb1c33/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelReactiveStreamsServiceImpl.java
----------------------------------------------------------------------
diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelReactiveStreamsServiceImpl.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelReactiveStreamsServiceImpl.java
index c3ccc42..3d23ce7 100644
--- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelReactiveStreamsServiceImpl.java
+++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelReactiveStreamsServiceImpl.java
@@ -373,6 +373,8 @@ public class CamelReactiveStreamsServiceImpl extends ServiceSupport implements C
String name = k;
int subscribers = v.getSubscriptionSize();
+ // TODO: include more subscriber information, either as a nested table or flattern
+
CompositeType ct = publishersCompositeType();
CompositeData data = new CompositeDataSupport(ct,
new String[] {"name", "subscribers"},