Package io.deephaven.server.arrow

Class BarrageSubscriptionRequestHandler

java.lang.Object

io.deephaven.server.arrow.BarrageSubscriptionRequestHandler

All Implemented Interfaces:

ArrowFlightUtil.DoExchangeMarshaller.Handler, Closeable, AutoCloseable

public class BarrageSubscriptionRequestHandler
extends Object
implements ArrowFlightUtil.DoExchangeMarshaller.Handler

Handler for BarrageSubscriptionRequest over DoExchange.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BarrageSubscriptionRequestHandler.BarrageSubscriptionRequestHandlerFactory	Factory to handle Barrage DoExchange subscription requests.

Constructor Summary

Constructors

Constructor	Description
BarrageSubscriptionRequestHandler(ArrowFlightUtil.DoExchangeMarshaller marshaller, TicketRouter ticketRouter, SessionState session, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Method Summary

Modifier and Type	Method	Description
void	close()
void	handleMessage(BarrageProtoUtil.MessageInfo message)
protected void	validateMessage(BarrageProtoUtil.MessageInfo message)	Called at the start of handleMessage(BarrageProtoUtil.MessageInfo) to validate that the message is of the correct type and is initialized properly.

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageSubscriptionRequestHandler

public BarrageSubscriptionRequestHandler(ArrowFlightUtil.DoExchangeMarshaller marshaller,
 TicketRouter ticketRouter,
 SessionState session,
 io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Method Details

handleMessage

public void handleMessage(@NotNull
 BarrageProtoUtil.MessageInfo message)

Specified by:

handleMessage in interface ArrowFlightUtil.DoExchangeMarshaller.Handler

validateMessage

protected void validateMessage(@NotNull
 BarrageProtoUtil.MessageInfo message)

Called at the start of handleMessage(BarrageProtoUtil.MessageInfo) to validate that the message is of the correct type and is initialized properly.

Parameters:

message - the message to validate

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable