Package org.nuxeo.lib.stream.log.mem

Class MemLogAppender<M extends Externalizable>

java.lang.Object

org.nuxeo.lib.stream.log.mem.MemLogAppender<M>

All Implemented Interfaces:

AutoCloseable, CloseableLogAppender<M>, LogAppender<M>

public class MemLogAppender<M extends Externalizable>
extends Object
implements CloseableLogAppender<M>

Memory implementation of LogAppender.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	NOCODEC_TAG

Constructor Summary

Constructors

Constructor	Description
MemLogAppender(MemLogs memLogs, Name name, Codec<M> codec)

Method Summary

Modifier and Type	Method	Description
LogOffset	append(int partition, M message)	Append a message into a partition, returns LogOffset position of the message.
void	close()
boolean	closed()	Returns true if the appender has been closed by the manager.
LogTailer<M>	createTailer(LogPartition partition, Name group, Codec<M> codec)
Codec<M>	getCodec()	Returns the codec used to write record.
Name	name()	Returns the Log's name.
int	size()	Returns the number of partitions in the Log.
String	toString()
boolean	waitFor(LogOffset logOffset, Name group, Duration timeout)	Wait for consumer to process a message up to the offset.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.log.LogAppender

append

Field Details

NOCODEC_TAG

protected static final String NOCODEC_TAG

See Also:

• Constant Field Values

Constructor Details

MemLogAppender

public MemLogAppender(MemLogs memLogs,
 Name name,
 Codec<M> codec)

Method Details

name

public Name name()

Description copied from interface: LogAppender

Returns the Log's name.

Specified by:

name in interface LogAppender<M extends Externalizable>

getCodec

public Codec<M> getCodec()

Description copied from interface: LogAppender

Returns the codec used to write record. A null codec is the default legacy encoding.

Specified by:

getCodec in interface LogAppender<M extends Externalizable>

closed

public boolean closed()

Description copied from interface: LogAppender

Returns true if the appender has been closed by the manager.

Specified by:

closed in interface LogAppender<M extends Externalizable>

size

public int size()

Description copied from interface: LogAppender

Returns the number of partitions in the Log.

Specified by:

size in interface LogAppender<M extends Externalizable>

append

public LogOffset append(int partition,
 M message)

Description copied from interface: LogAppender

Append a message into a partition, returns LogOffset position of the message. This method is thread safe, a queue can be shared by multiple producers.

Specified by:

append in interface LogAppender<M extends Externalizable>

Parameters:

partition - index lower than LogAppender.size()

createTailer

public LogTailer<M> createTailer(LogPartition partition,
 Name group,
 Codec<M> codec)

waitFor

public boolean waitFor(LogOffset logOffset,
 Name group,
 Duration timeout)
                throws InterruptedException

Description copied from interface: LogAppender

Wait for consumer to process a message up to the offset. The message is processed if a consumer of the group commits a greater or equals offset. Return true if the message has been consumed, false in case of timeout.

Specified by:

waitFor in interface LogAppender<M extends Externalizable>

Throws:

InterruptedException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableLogAppender<M extends Externalizable>

toString

public String toString()

Overrides:

toString in class Object