This is an automated email from the ASF dual-hosted git repository. tison pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/curator-site.git
commit 51cd05b822d82544ea48bc33b393b1061cb8e76d Author: tison <[email protected]> AuthorDate: Tue Aug 15 16:22:09 2023 +0800 style: align code blocks Signed-off-by: tison <[email protected]> --- docs/recipes-distributed-delay-queue.md | 10 +++++----- docs/recipes-distributed-priority-queue.md | 12 ++++++------ docs/recipes-distributed-queue.md | 10 +++++----- docs/recipes-persistent-ttl-node.md | 2 +- 4 files changed, 17 insertions(+), 17 deletions(-) diff --git a/docs/recipes-distributed-delay-queue.md b/docs/recipes-distributed-delay-queue.md index 1e67a7a..c9fca67 100644 --- a/docs/recipes-distributed-delay-queue.md +++ b/docs/recipes-distributed-delay-queue.md @@ -24,17 +24,17 @@ An implementation of a Distributed Delay Queue. A Delay Queue is similar to a Pr ## Creating a DistributedDelayQueue ```java +// Parameters: +// client - the curator client +// consumer - message consumer +// serializer - serializer to use for items +// queuePath - path to store queue public static <T> QueueBuilder<T> builder( CuratorFramework client, QueueConsumer<T> consumer, QueueSerializer<T> serializer, java.lang.String queuePath ); -// Parameters: -// client - the curator client -// consumer - message consumer -// serializer - serializer to use for items -// queuePath - path to store queue ``` ```java diff --git a/docs/recipes-distributed-priority-queue.md b/docs/recipes-distributed-priority-queue.md index 3eaf53f..da2b4a8 100644 --- a/docs/recipes-distributed-priority-queue.md +++ b/docs/recipes-distributed-priority-queue.md @@ -24,17 +24,17 @@ An implementation of the Distributed Priority Queue ZK recipe. ## Creating a DistributedPriorityQueue ```java +// Parameters: +// client - the curator client +// consumer - message consumer +// serializer - serializer to use for items +// queuePath - path to store queue public static <T> QueueBuilder<T> builder( CuratorFramework client, QueueConsumer<T> consumer, QueueSerializer<T> serializer, java.lang.String queuePath ); -// Parameters: -// client - the curator client -// consumer - message consumer -// serializer - serializer to use for items -// queuePath - path to store queue ``` ```java @@ -44,9 +44,9 @@ DistributedPriorityQueue<MessageType> queue = builder.buildPriorityQueue(minItem ``` ```java -public DistributedPriorityQueue<T> buildPriorityQueue(int minItemsBeforeRefresh); // Parameters: // minItemsBeforeRefresh - minimum items to process before refreshing the item list +public DistributedPriorityQueue<T> buildPriorityQueue(int minItemsBeforeRefresh); ``` Build a DistributedPriorityQueue from the current builder values. diff --git a/docs/recipes-distributed-queue.md b/docs/recipes-distributed-queue.md index 01d8ab0..61f857a 100644 --- a/docs/recipes-distributed-queue.md +++ b/docs/recipes-distributed-queue.md @@ -24,17 +24,17 @@ An implementation of the Distributed Queue ZK recipe. Items put into the queue a ### Creating a DistributedQueue ```java +// Parameters: +// client - the curator client +// consumer - functor to receive messages +// serializer - serializer to use for items +// queuePath - path to store queue public static <T> QueueBuilder<T> builder( CuratorFramework client, QueueConsumer<T> consumer, QueueSerializer<T> serializer, java.lang.String queuePath ); -// Parameters: -// client - the curator client -// consumer - functor to receive messages -// serializer - serializer to use for items -// queuePath - path to store queue ``` ```java diff --git a/docs/recipes-persistent-ttl-node.md b/docs/recipes-persistent-ttl-node.md index 9371036..f01813e 100644 --- a/docs/recipes-persistent-ttl-node.md +++ b/docs/recipes-persistent-ttl-node.md @@ -15,7 +15,7 @@ PersistentTtlNode is useful when you need to create a TTL node but don't want to ## Creating a PersistentTtlNode -``` +```java // Parameters: // client - client instance // path path for the parent ZNode
