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

Class SubscriptionErrorMessageEncoder

java.lang.Object

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

com.illumon.iris.sbetransport.server.messages.SubscriptionErrorMessageEncoder

public class SubscriptionErrorMessageEncoder
extends MessageEncoder

Encoder for a SubscriptionError 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
SubscriptionErrorMessageEncoder(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, TableSubscriptionErrorCode errorCode, String errorMessage)

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionErrorMessageEncoder

public SubscriptionErrorMessageEncoder(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, TableSubscriptionErrorCode errorCode, String errorMessage)