CAMEL-7999: More components include documentation
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5aa0052f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5aa0052f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5aa0052f Branch: refs/heads/master Commit: 5aa0052f857981d013e5d0f6ad672dc16ca38b71 Parents: ef88dcd Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Jan 6 09:12:52 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Jan 6 09:12:52 2015 +0100 ---------------------------------------------------------------------- .../component/disruptor/DisruptorComponent.java | 2 ++ .../component/disruptor/DisruptorEndpoint.java | 20 ++++++++++++++++++++ 2 files changed, 22 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/5aa0052f/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorComponent.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorComponent.java index 85db091..112c158 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorComponent.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorComponent.java @@ -92,6 +92,8 @@ public class DisruptorComponent extends UriEndpointComponent { final DisruptorReference disruptorReference = getOrCreateDisruptor(uri, remaining, size, producerType, waitStrategy); final DisruptorEndpoint disruptorEndpoint = new DisruptorEndpoint(uri, this, disruptorReference, concurrentConsumers, multipleConsumers, blockWhenFull); + disruptorEndpoint.setWaitStrategy(waitStrategy); + disruptorEndpoint.setProducerType(producerType); disruptorEndpoint.configureProperties(parameters); return disruptorEndpoint; http://git-wip-us.apache.org/repos/asf/camel/blob/5aa0052f/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java index e2973e1..4c568ac 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java @@ -64,6 +64,10 @@ public class DisruptorEndpoint extends DefaultEndpoint implements MultipleConsum private long timeout = 30000; @UriParam(defaultValue = "false") private boolean blockWhenFull; + @UriParam(defaultValue = "Blocking") + private DisruptorWaitStrategy waitStrategy; + @UriParam(defaultValue = "Multi") + private DisruptorProducerType producerType; private final Set<DisruptorProducer> producers = new CopyOnWriteArraySet<DisruptorProducer>(); private final Set<DisruptorConsumer> consumers = new CopyOnWriteArraySet<DisruptorConsumer>(); @@ -182,6 +186,22 @@ public class DisruptorEndpoint extends DefaultEndpoint implements MultipleConsum this.blockWhenFull = blockWhenFull; } + public DisruptorWaitStrategy getWaitStrategy() { + return waitStrategy; + } + + public void setWaitStrategy(DisruptorWaitStrategy waitStrategy) { + this.waitStrategy = waitStrategy; + } + + public DisruptorProducerType getProducerType() { + return producerType; + } + + public void setProducerType(DisruptorProducerType producerType) { + this.producerType = producerType; + } + @Override public boolean isSingleton() { return true;
