public class ZkWorkItemRepository extends BaseWorkItemRepository implements PathChildrenCacheListener
Constructor and Description |
---|
ZkWorkItemRepository(org.apache.curator.framework.CuratorFramework curator,
java.lang.String partitionsPath) |
Modifier and Type | Method and Description |
---|---|
void |
childEvent(org.apache.curator.framework.CuratorFramework client,
PathChildrenCacheEvent event) |
void |
close()
Completely shuts down the repository.
|
java.util.List<java.lang.String> |
listWorkItemLocations() |
java.lang.String |
readContent(java.lang.String location) |
void |
start()
Start or resume the repository.
|
void |
stop()
Suspends the repository.
|
addListener, notifyListeners, readWorkItem, removeListener
public ZkWorkItemRepository(org.apache.curator.framework.CuratorFramework curator, java.lang.String partitionsPath)
public void start()
WorkItemRepository
start
in interface WorkItemRepository
public void stop()
WorkItemRepository
stop
in interface WorkItemRepository
public void close()
WorkItemRepository
close
in interface WorkItemRepository
public java.util.List<java.lang.String> listWorkItemLocations()
listWorkItemLocations
in interface WorkItemRepository
public java.lang.String readContent(java.lang.String location)
readContent
in class BaseWorkItemRepository
public void childEvent(org.apache.curator.framework.CuratorFramework client, PathChildrenCacheEvent event) throws java.lang.Exception
childEvent
in interface PathChildrenCacheListener
java.lang.Exception
Copyright © 2014 Red Hat. All Rights Reserved.