co.cask.cdap.data2.queue

Interface QueueProducer

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

AbstractQueueProducer, HBaseQueueProducer, InMemoryQueueProducer, LevelDBQueueProducer

public interface QueueProducer
extends Closeable

Implementation of this interface enqueues methods should be thread safe.

Method Summary

Methods

Modifier and Type	Method and Description
void	enqueue(Iterable<QueueEntry> entries) Enqueues a list of QueueEntry.
void	enqueue(QueueEntry entry) Enqueues a QueueEntry.

Methods inherited from interface java.io.Closeable

close

Method Detail

enqueue

void enqueue(QueueEntry entry)
             throws IOException

Enqueues a QueueEntry.

Throws:

IOException

enqueue

void enqueue(Iterable<QueueEntry> entries)
             throws IOException

Enqueues a list of QueueEntry.

Throws:

IOException