Package com.illumon.iris.sbetransport.server.messages

Class RowsRemovedMessageEncoder

java.lang.Object

com.illumon.iris.sbetransport.server.messages.MessageEncoder

com.illumon.iris.sbetransport.server.messages.RowsRemovedMessageEncoder

public class RowsRemovedMessageEncoder
extends MessageEncoder

Encoder for a RowsRemoved message. Since any number of rows may be removed in a single table update, we must provide for splitting into any number of fixed-size SBE RowsRemoved messages.

Field Summary

Fields inherited from class com.illumon.iris.sbetransport.server.messages.MessageEncoder

freeBufferSupplier, log, messageConsumer, messageHeaderEncoder

Constructor Summary

Constructors

Constructor	Description
RowsRemovedMessageEncoder(com.fishlib.io.logger.Logger log, Supplier<org.agrona.concurrent.UnsafeBuffer> freeBufferSupplier, Consumer<org.agrona.concurrent.UnsafeBuffer> messageConsumer, int bufferSize)

Method Summary

Modifier and Type	Method	Description
int	send(int subscriptionId, Index removed)

Methods inherited from class java.lang.Object

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

Constructor Details

RowsRemovedMessageEncoder

public RowsRemovedMessageEncoder(com.fishlib.io.logger.Logger log, Supplier<org.agrona.concurrent.UnsafeBuffer> freeBufferSupplier, Consumer<org.agrona.concurrent.UnsafeBuffer> messageConsumer, int bufferSize)

Method Details

send

public int send(int subscriptionId, Index removed) throws IOException

Throws:

IOException