co.cask.cdap.data2.transaction.queue.inmemory

Class InMemoryQueueService

java.lang.Object

co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueueService

public final class InMemoryQueueService
extends Object

Maintains all in-memory queues in the system.

Method Summary

Methods

Modifier and Type	Method and Description
void	drop(QueueName queueName)
void	dumpInfo(PrintStream out)
boolean	exists(QueueName queueName)
void	resetQueues()
void	resetQueuesWithPrefix(String prefix)
void	resetStreams()
void	resetStreamsWithPrefix(String prefix)
void	truncate(QueueName queueName)
void	truncateAllWithPrefix(String prefix) Clear all streams or queues with a given prefix.

Methods inherited from class java.lang.Object

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

Method Detail

dumpInfo

public void dumpInfo(PrintStream out)

resetQueues

public void resetQueues()

resetQueuesWithPrefix

public void resetQueuesWithPrefix(String prefix)

resetStreams

public void resetStreams()

resetStreamsWithPrefix

public void resetStreamsWithPrefix(String prefix)

exists

public boolean exists(QueueName queueName)

truncate

public void truncate(QueueName queueName)

truncateAllWithPrefix

public void truncateAllWithPrefix(@Nonnull
                         String prefix)

Clear all streams or queues with a given prefix.

Parameters:

prefix - the prefix to match.

drop

public void drop(QueueName queueName)