Package org.apache.jackrabbit.oak.segment.remote.queue

Class SegmentWriteQueue

java.lang.Object

org.apache.jackrabbit.oak.segment.remote.queue.SegmentWriteQueue

All Implemented Interfaces:

Closeable, AutoCloseable

public class SegmentWriteQueue
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SegmentWriteQueue.SegmentConsumeException
static interface	SegmentWriteQueue.SegmentConsumer

Field Summary

Fields

Modifier and Type	Field	Description
static int	THREADS

Constructor Summary

Constructors

Constructor	Description
SegmentWriteQueue(SegmentWriteQueue.SegmentConsumer writer)

Method Summary

Modifier and Type	Method	Description
void	addToQueue(RemoteSegmentArchiveEntry indexEntry, byte[] data, int offset, int size)
void	close()
void	flush()
boolean	isEmpty()
SegmentWriteAction	read(UUID id)

Methods inherited from class java.lang.Object

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

Field Detail

THREADS

public static final int THREADS

Constructor Detail

SegmentWriteQueue

public SegmentWriteQueue(SegmentWriteQueue.SegmentConsumer writer)

Method Detail

addToQueue

public void addToQueue(RemoteSegmentArchiveEntry indexEntry,
                       byte[] data,
                       int offset,
                       int size)
                throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

read

public SegmentWriteAction read(UUID id)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

isEmpty

public boolean isEmpty()