org.apache.solr.cloud

Class ZkDistributedQueueFactory

java.lang.Object

org.apache.solr.cloud.ZkDistributedQueueFactory

All Implemented Interfaces:

DistributedQueueFactory

public class ZkDistributedQueueFactory
extends Object
implements DistributedQueueFactory

Implementation of DistributedQueueFactory that uses ZooKeeper.

Constructor Summary

Constructors

Constructor and Description
ZkDistributedQueueFactory(SolrZkClient zkClient)

Method Summary

Modifier and Type	Method and Description
DistributedQueue	makeQueue(String path)
void	removeQueue(String path)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkDistributedQueueFactory

public ZkDistributedQueueFactory(SolrZkClient zkClient)

Method Detail

makeQueue

public DistributedQueue makeQueue(String path)
                           throws IOException

Specified by:

makeQueue in interface DistributedQueueFactory

Throws:

IOException

removeQueue

public void removeQueue(String path)
                 throws IOException

Specified by:

removeQueue in interface DistributedQueueFactory

Throws:

IOException