Updated Branches: refs/heads/master 2afd1e543 -> e08f7ca58
CAMEL-6304: Added more @UriParam to components in camel-core Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e08f7ca5 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e08f7ca5 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e08f7ca5 Branch: refs/heads/master Commit: e08f7ca58de351fd39117e4421f85368c62d6792 Parents: 9e9f575 Author: Claus Ibsen <[email protected]> Authored: Wed Jun 5 15:54:37 2013 +0200 Committer: Claus Ibsen <[email protected]> Committed: Wed Jun 5 15:55:25 2013 +0200 ---------------------------------------------------------------------- .../camel/component/direct/DirectEndpoint.java | 3 +++ .../camel/component/directvm/DirectVmEndpoint.java | 3 +++ 2 files changed, 6 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e08f7ca5/camel-core/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java index 844a74b..026d1dc 100644 --- a/camel-core/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java @@ -24,6 +24,7 @@ import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.impl.DefaultEndpoint; +import org.apache.camel.spi.UriParam; import org.apache.camel.util.ObjectHelper; /** @@ -35,7 +36,9 @@ import org.apache.camel.util.ObjectHelper; public class DirectEndpoint extends DefaultEndpoint { private volatile Map<String, DirectConsumer> consumers; + @UriParam private boolean block; + @UriParam private long timeout = 30000L; public DirectEndpoint() { http://git-wip-us.apache.org/repos/asf/camel/blob/e08f7ca5/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmEndpoint.java index d5a9885..3f67bc2 100644 --- a/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmEndpoint.java @@ -20,13 +20,16 @@ import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.impl.DefaultEndpoint; +import org.apache.camel.spi.UriParam; /** * The direct-vm endpoint. */ public class DirectVmEndpoint extends DefaultEndpoint { + @UriParam private boolean block; + @UriParam private long timeout = 30000L; public DirectVmEndpoint(String endpointUri, DirectVmComponent component) {
