public class ZkWorkItemRepository extends BaseWorkItemRepository implements org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
Constructor and Description |
---|
ZkWorkItemRepository(org.apache.curator.framework.CuratorFramework curator,
String partitionsPath) |
Modifier and Type | Method and Description |
---|---|
void |
childEvent(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event) |
void |
close()
Completely shuts down the repository.
|
List<String> |
listWorkItemLocations() |
String |
readContent(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, 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 List<String> listWorkItemLocations()
listWorkItemLocations
in interface WorkItemRepository
public String readContent(String location)
readContent
in class BaseWorkItemRepository
public void childEvent(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event) throws Exception
childEvent
in interface org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
Exception
Copyright © 2011–2014 Red Hat. All rights reserved.