Package io.deephaven.server.arrow

Class BarrageSnapshotRequestHandler

java.lang.Object

io.deephaven.server.arrow.BarrageSnapshotRequestHandler

All Implemented Interfaces:

ArrowFlightUtil.DoExchangeMarshaller.Handler, Closeable, AutoCloseable

public class BarrageSnapshotRequestHandler
extends Object
implements ArrowFlightUtil.DoExchangeMarshaller.Handler

Handler for DoGetRequest over DoExchange.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BarrageSnapshotRequestHandler.BarrageSnapshotRequestHandlerFactory	Factory to handle Barrage DoExchange snapshot requests.

Constructor Summary

Constructors

Constructor	Description
BarrageSnapshotRequestHandler(ArrowFlightUtil.DoExchangeMarshaller marshaller, TicketRouter ticketRouter, SessionState session, BarrageMessageWriter.Factory streamGeneratorFactory, 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

BarrageSnapshotRequestHandler

public BarrageSnapshotRequestHandler(ArrowFlightUtil.DoExchangeMarshaller marshaller,
 TicketRouter ticketRouter,
 SessionState session,
 BarrageMessageWriter.Factory streamGeneratorFactory,
 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