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/08 13:41:49 UTC
[3/3] camel git commit: CAMEL-11122: camel-reactive-streams - Add
more JMX information
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 <da...@apache.org>
Authored: Sat Apr 8 14:30:17 2017 +0200
Committer: Claus Ibsen <da...@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;
}