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

Class SubscribeResponseMessageEncoder

java.lang.Object

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

com.illumon.iris.sbetransport.server.messages.SubscribeResponseMessageEncoder

public class SubscribeResponseMessageEncoder
extends MessageEncoder

Encoder for a SubscribeResponse message. These are fixed size, no need to split into multiple SBE messages.

Field Summary

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

freeBufferSupplier, log, messageConsumer, messageHeaderEncoder

Constructor Summary

Constructors

Constructor	Description
SubscribeResponseMessageEncoder(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 subId, ColumnInfo[] columns)

Methods inherited from class java.lang.Object

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

Constructor Details

SubscribeResponseMessageEncoder

public SubscribeResponseMessageEncoder(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 subId, ColumnInfo[] columns)