CAMEL-11685 - Fixed docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f96385a5 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f96385a5 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f96385a5 Branch: refs/heads/master Commit: f96385a50bd04190148b78d95abad4a670f0752b Parents: 7269406 Author: Andrea Cosentino <anco...@gmail.com> Authored: Mon Aug 21 14:41:16 2017 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Mon Aug 21 14:41:16 2017 +0200 ---------------------------------------------------------------------- .../main/docs/hazelcast-queue-component.adoc | 40 +++++++++++++++++++- 1 file changed, 38 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f96385a5/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc ---------------------------------------------------------------------- diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc index 5a4d2d3..3389551 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc @@ -59,13 +59,17 @@ with the following path and query parameters: ### Queue producer â to(âhazelcast-queue:fooâ) -The queue producer provides 6 operations: +The queue producer provides 10 operations: * add * put * poll * peek * offer -* removevalue +* remove value +* remaining capacity +* remove all +* remove if +* drain to #### Sample for *add*: @@ -121,6 +125,38 @@ from("direct:removevalue") .toF("hazelcast-%sbar", HazelcastConstants.QUEUE_PREFIX); -------------------------------------------------------------------------------------------- +#### Sample for *remaining capacity*: + +[source,java] +-------------------------------------------------------------------------------------------- +from("direct:remaining-capacity").setHeader(HazelcastConstants.OPERATION, constant(HazelcastOperation.REMAINING_CAPACITY)).to( +String.format("hazelcast-%sbar", HazelcastConstants.QUEUE_PREFIX)); +-------------------------------------------------------------------------------------------- + +#### Sample for *remove all*: + +[source,java] +-------------------------------------------------------------------------------------------- +from("direct:removeAll").setHeader(HazelcastConstants.OPERATION, constant(HazelcastOperation.REMOVE_ALL)).to( +String.format("hazelcast-%sbar", HazelcastConstants.QUEUE_PREFIX)); +-------------------------------------------------------------------------------------------- + +#### Sample for *remove if*: + +[source,java] +-------------------------------------------------------------------------------------------- +from("direct:removeIf").setHeader(HazelcastConstants.OPERATION, constant(HazelcastOperation.REMOVE_IF)).to( +String.format("hazelcast-%sbar", HazelcastConstants.QUEUE_PREFIX)); +-------------------------------------------------------------------------------------------- + +#### Sample for *drain to*: + +[source,java] +-------------------------------------------------------------------------------------------- +from("direct:drainTo").setHeader(HazelcastConstants.OPERATION, constant(HazelcastOperation.DRAIN_TO)).to( +String.format("hazelcast-%sbar", HazelcastConstants.QUEUE_PREFIX)); +-------------------------------------------------------------------------------------------- + ### Queue consumer â from(âhazelcast-queue:fooâ) The queue consumer provides 2 operations:
