camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/3] camel git commit: CAMEL-11122: camel-reactive-streams - Add more JMX information
Date Sat, 08 Apr 2017 13:41:49 GMT
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/5b9cf7c8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5b9cf7c8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5b9cf7c8

Branch: refs/heads/master
Commit: 5b9cf7c8b298c08fbec2564c70ecb3d078f6b4ab
Parents: db7cd8e1
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sat Apr 8 14:30:17 2017 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sat Apr 8 15:41:40 2017 +0200

----------------------------------------------------------------------
 .../component/reactive/streams/ReactiveStreamsEndpoint.java  | 8 ++++++++
 1 file changed, 8 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/5b9cf7c8/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
index e7edf8a..461913b 100644
--- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
+++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
@@ -19,6 +19,8 @@ package org.apache.camel.component.reactive.streams;
 import org.apache.camel.Consumer;
 import org.apache.camel.Processor;
 import org.apache.camel.Producer;
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedResource;
 import org.apache.camel.impl.DefaultEndpoint;
 import org.apache.camel.spi.UriEndpoint;
 import org.apache.camel.spi.UriParam;
@@ -29,6 +31,7 @@ import org.apache.camel.spi.UriPath;
  */
 @UriEndpoint(firstVersion = "2.19.0", scheme = "reactive-streams", title = "Reactive Streams",
syntax = "reactive-streams:stream",
         consumerClass = ReactiveStreamsConsumer.class, label = "reactive,streams")
+@ManagedResource(description = "Managed ReactiveStreamsEndpoint")
 public class ReactiveStreamsEndpoint extends DefaultEndpoint {
 
     @UriPath
@@ -71,6 +74,7 @@ public class ReactiveStreamsEndpoint extends DefaultEndpoint {
         return new ReactiveStreamsConsumer(this, processor);
     }
 
+    @ManagedAttribute(description = "Name of the stream channel used by the endpoint to exchange
messages")
     public String getStream() {
         return stream;
     }
@@ -82,6 +86,7 @@ public class ReactiveStreamsEndpoint extends DefaultEndpoint {
         this.stream = stream;
     }
 
+    @ManagedAttribute(description = "Maximum number of exchanges concurrently being processed
by Camel")
     public Integer getMaxInflightExchanges() {
         return maxInflightExchanges;
     }
@@ -102,6 +107,7 @@ public class ReactiveStreamsEndpoint extends DefaultEndpoint {
     /**
      * Number of threads used to process exchanges in the Camel route.
      */
+    @ManagedAttribute(description = "Number of threads used to process exchanges in the Camel
route")
     public void setConcurrentConsumers(int concurrentConsumers) {
         this.concurrentConsumers = concurrentConsumers;
     }
@@ -128,6 +134,7 @@ public class ReactiveStreamsEndpoint extends DefaultEndpoint {
         this.backpressureStrategy = backpressureStrategy;
     }
 
+    @ManagedAttribute(description = "Determines if onComplete events should be pushed to
the Camel route")
     public boolean isForwardOnComplete() {
         return forwardOnComplete;
     }
@@ -139,6 +146,7 @@ public class ReactiveStreamsEndpoint extends DefaultEndpoint {
         this.forwardOnComplete = forwardOnComplete;
     }
 
+    @ManagedAttribute(description = "Determines if onError events should be pushed to the
Camel route")
     public boolean isForwardOnError() {
         return forwardOnError;
     }


Mime
View raw message