Java 类org.apache.curator.framework.recipes.queue.SimpleDistributedQueue 实例源码

@Override
public void configure(Map<String, Object> config) {
  String path = (String)config.get(ZK_PATH);
  if(path == null) {
    throw new IllegalStateException("You must specify " + ZK_PATH + " for a zk queue");
  }
  CuratorFramework client = (CuratorFramework) config.get(ZK_CLIENT);
  queue = new SimpleDistributedQueue(client, path);
}