Repository: camel Updated Branches: refs/heads/master dbdab9173 -> f4495cf9e
CAMEL-11140: add service to Camel context to expose metrics Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f4495cf9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f4495cf9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f4495cf9 Branch: refs/heads/master Commit: f4495cf9ed10e5c610c70e96c9ac94fb00432f02 Parents: d252201 Author: Nicola Ferraro <[email protected]> Authored: Fri May 12 17:19:45 2017 +0200 Committer: Nicola Ferraro <[email protected]> Committed: Fri May 12 17:20:06 2017 +0200 ---------------------------------------------------------------------- .../component/reactive/streams/ReactiveStreamsComponent.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f4495cf9/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java index 7376820..2ae3959 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsComponent.java @@ -130,8 +130,8 @@ public class ReactiveStreamsComponent extends DefaultComponent { ); try { - // Start the service - ServiceHelper.startService(service); + // Start the service and add it to the Camel context to expose managed attributes + getCamelContext().addService(service, true, true); } catch (Exception e) { throw new RuntimeCamelException(e); }
