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 <davscl...@apache.org> Authored: Sun Apr 9 09:53:52 2017 +0200 Committer: Claus Ibsen <davscl...@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"},
