de.zalando.paradox.nakadi.consumer.partitioned.zk

Class ZKGroupMember

java.lang.Object

org.apache.curator.framework.recipes.nodes.GroupMember

de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ZKGroupMember
extends org.apache.curator.framework.recipes.nodes.GroupMember

Based on org.apache.curator:curator-recipes:2.9.1 behaviour.

Constructor Summary

Constructors

Constructor and Description
ZKGroupMember(org.apache.curator.framework.CuratorFramework client, java.lang.String membershipPath, java.lang.String thisId)
ZKGroupMember(org.apache.curator.framework.CuratorFramework client, java.lang.String membershipPath, java.lang.String thisId, byte[] payload)
ZKGroupMember(org.apache.curator.framework.CuratorFramework client, java.lang.String membershipPath, java.lang.String thisId, byte[] payload, org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)

Method Summary

Modifier and Type	Method and Description
protected org.apache.curator.framework.recipes.cache.PathChildrenCache	newPathChildrenCache(org.apache.curator.framework.CuratorFramework client, java.lang.String membershipPath)
void	start()

Methods inherited from class org.apache.curator.framework.recipes.nodes.GroupMember

close, getCurrentMembers, idFromPath, newPersistentEphemeralNode, setThisData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZKGroupMember

public ZKGroupMember(org.apache.curator.framework.CuratorFramework client,
                     java.lang.String membershipPath,
                     java.lang.String thisId)

ZKGroupMember

public ZKGroupMember(org.apache.curator.framework.CuratorFramework client,
                     java.lang.String membershipPath,
                     java.lang.String thisId,
                     byte[] payload)

ZKGroupMember

public ZKGroupMember(org.apache.curator.framework.CuratorFramework client,
                     java.lang.String membershipPath,
                     java.lang.String thisId,
                     byte[] payload,
                     org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)

Method Detail

start

public void start()

Overrides:

start in class org.apache.curator.framework.recipes.nodes.GroupMember

newPathChildrenCache

protected org.apache.curator.framework.recipes.cache.PathChildrenCache newPathChildrenCache(org.apache.curator.framework.CuratorFramework client,
                                                                                            java.lang.String membershipPath)

Overrides:

newPathChildrenCache in class org.apache.curator.framework.recipes.nodes.GroupMember