software.chronicle.datagrid.internal.queue

Class LocalExcept<T,M>

java.lang.Object

software.chronicle.datagrid.internal.queue.LocalExcept<T,M>

All Implemented Interfaces:

Map.Entry<T,M>, net.openhft.chronicle.bytes.CommonMarshallable, net.openhft.chronicle.core.io.Resettable, net.openhft.chronicle.wire.Marshallable, net.openhft.chronicle.wire.ReadMarshallable, net.openhft.chronicle.wire.WriteMarshallable, net.openhft.chronicle.wire.WriteValue, QueueView.Excerpt<T,M>

public final class LocalExcept<T,M>
extends Object
implements QueueView.Excerpt<T,M>, net.openhft.chronicle.wire.Marshallable, Map.Entry<T,M>

Field Summary

Fields inherited from interface net.openhft.chronicle.wire.WriteMarshallable

EMPTY

Fields inherited from interface net.openhft.chronicle.wire.ReadMarshallable

DISCARD

Constructor Summary

Constructors

Constructor and Description
LocalExcept(Class<T> topicTypeClass, Class<M> messageTypeClass)

Method Summary

Modifier and Type	Method and Description
void	clear() Resets this Excerpt by clearing its internal state.
T	getKey()
M	getValue()
long	index() Returns the unique index for this Excerpt.
@NotNull LocalExcept<T,M>	index(long index)
M	message() Returns the message for this Excerpt.
void	readMarshallable(@NotNull net.openhft.chronicle.wire.WireIn wireIn)
M	setValue(M value)
T	topic() Returns the topic for this Excerpt.
@NotNull String	toString()
void	writeMarshallable(@NotNull net.openhft.chronicle.wire.WireOut wireOut)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.wire.Marshallable

$equals, $fieldInfoMap, $fieldInfos, $hashCode, $toString, className, copyTo, deepCopy, fromFile, fromFile, fromString, fromString, fromString, getField, getLongField, mergeToMap, reset, setField, setLongField, streamFromFile, streamFromFile

Methods inherited from interface net.openhft.chronicle.wire.WriteMarshallable

writeValue

Methods inherited from interface net.openhft.chronicle.wire.ReadMarshallable

unexpectedField

Methods inherited from interface net.openhft.chronicle.bytes.CommonMarshallable

usesSelfDescribingMessage

Methods inherited from interface java.util.Map.Entry

comparingByKey, comparingByKey, comparingByValue, comparingByValue, equals, hashCode

Constructor Detail

LocalExcept

public LocalExcept(Class<T> topicTypeClass,
                   Class<M> messageTypeClass)

Method Detail

topic

@Nullable
public T topic()

Description copied from interface: QueueView.Excerpt

Returns the topic for this Excerpt.

Specified by:

topic in interface QueueView.Excerpt<T,M>

Returns:

the topic for this Excerpt

message

@Nullable
public M message()

Description copied from interface: QueueView.Excerpt

Returns the message for this Excerpt.

Specified by:

message in interface QueueView.Excerpt<T,M>

Returns:

the message for this Excerpt

index

public long index()

Description copied from interface: QueueView.Excerpt

Returns the unique index for this Excerpt.

The index can be seen as a sort of "address" for the Excerpt. An index from a previous Excerpt is strictly less than an index from a later Excerpt.

Specified by:

index in interface QueueView.Excerpt<T,M>

Returns:

the unique index for this Excerpt

index

@NotNull
public @NotNull LocalExcept<T,M> index(long index)

toString

@NotNull
public @NotNull String toString()

Overrides:

toString in class Object

writeMarshallable

public void writeMarshallable(@NotNull
                              @NotNull net.openhft.chronicle.wire.WireOut wireOut)

Specified by:

writeMarshallable in interface net.openhft.chronicle.wire.Marshallable

Specified by:

writeMarshallable in interface net.openhft.chronicle.wire.WriteMarshallable

readMarshallable

public void readMarshallable(@NotNull
                             @NotNull net.openhft.chronicle.wire.WireIn wireIn)

Specified by:

readMarshallable in interface net.openhft.chronicle.wire.Marshallable

Specified by:

readMarshallable in interface net.openhft.chronicle.wire.ReadMarshallable

clear

public void clear()

Description copied from interface: QueueView.Excerpt

Resets this Excerpt by clearing its internal state.

Specified by:

clear in interface QueueView.Excerpt<T,M>

getKey

@Nullable
public T getKey()

Specified by:

getKey in interface Map.Entry<T,M>

getValue

@Nullable
public M getValue()

Specified by:

getValue in interface Map.Entry<T,M>

setValue

@NotNull
public M setValue(M value)

Specified by:

setValue in interface Map.Entry<T,M>