software.chronicle.datagrid.cluster

Class DatagridWireOutPublisher

java.lang.Object

net.openhft.chronicle.core.io.AbstractCloseable

net.openhft.chronicle.network.connection.VanillaWireOutPublisher

software.chronicle.datagrid.cluster.DatagridWireOutPublisher

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.CloseableTracer, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, net.openhft.chronicle.network.connection.WireOutPublisher

public class DatagridWireOutPublisher
extends net.openhft.chronicle.network.connection.VanillaWireOutPublisher

Field Summary

Fields inherited from class net.openhft.chronicle.core.io.AbstractCloseable

CHECK_THREAD_SAFETY, WARN_NS

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
DatagridWireOutPublisher(@NotNull net.openhft.chronicle.wire.WireType wireType)

Method Summary

Modifier and Type	Method and Description
void	addWireConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)
void	applyAction(@NotNull net.openhft.chronicle.wire.WireOut outWire)
boolean	removeBytesConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)

Methods inherited from class net.openhft.chronicle.network.connection.VanillaWireOutPublisher

applyAction, clear, isEmpty, performClose, put, threadSafetyCheck, toString, wireType

Methods inherited from class net.openhft.chronicle.core.io.AbstractCloseable

assertCloseablesClosed, clearUsedByThread, close, createdHere, disableCloseableTracing, enableCloseableTracing, isClosed, isClosing, isInUserThread, performCloseInBackground, referenceId, resetUsedByThread, shouldPerformCloseInBackground, shouldWaitForClosed, throwExceptionIfClosed, throwExceptionIfClosedInSetter, unmonitor, waitForClosed, warnAndCloseIfNotClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.network.connection.WireOutPublisher

close, isClosed, newThrottledWireOutPublisher, publish

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

closeQuietly, closeQuietly, notifyClosing

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosing, throwExceptionIfClosed

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceName, temporary

Constructor Detail

DatagridWireOutPublisher

public DatagridWireOutPublisher(@NotNull
                                @NotNull net.openhft.chronicle.wire.WireType wireType)

Method Detail

applyAction

public void applyAction(@NotNull
                        @NotNull net.openhft.chronicle.wire.WireOut outWire)

Specified by:

applyAction in interface net.openhft.chronicle.network.connection.WireOutPublisher

Overrides:

applyAction in class net.openhft.chronicle.network.connection.VanillaWireOutPublisher

addWireConsumer

public void addWireConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)

removeBytesConsumer

public boolean removeBytesConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)