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

Class ConnectionResponseMessageEncoder

java.lang.Object

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

com.illumon.iris.sbetransport.server.messages.ConnectionResponseMessageEncoder

public class ConnectionResponseMessageEncoder
extends MessageEncoder

Encoder for a ConnectionResponse message. These are fixed size, no need to split into multiple SBE messages. This message serves to provide the size of buffer the client should allocate for receiving table updates.

Field Summary

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

freeBufferSupplier, log, messageConsumer, messageHeaderEncoder

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	send(int messageBufferSize)

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionResponseMessageEncoder

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

Method Details

send

public void send(int messageBufferSize)