Package io.deephaven.server.arrow

Class BarrageSubscriptionRequestHandler.BarrageSubscriptionRequestHandlerFactory

java.lang.Object

io.deephaven.server.arrow.BarrageSubscriptionRequestHandler.BarrageSubscriptionRequestHandlerFactory

All Implemented Interfaces:

ExchangeRequestHandlerFactory

Enclosing class:

BarrageSubscriptionRequestHandler

@AutoService(ExchangeRequestHandlerFactory.class)
public static class BarrageSubscriptionRequestHandler.BarrageSubscriptionRequestHandlerFactory
extends Object
implements ExchangeRequestHandlerFactory

Factory to handle Barrage DoExchange subscription requests.

Constructor Summary

Constructors

Constructor	Description
BarrageSubscriptionRequestHandlerFactory()

Method Summary

Modifier and Type	Method	Description
ArrowFlightUtil.DoExchangeMarshaller.Handler	create(ArrowFlightUtil.DoExchangeMarshaller marshaller, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)	Creates a handler for a DoExchange message.
byte	type()	The type of message that this factory produces a handler for.

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageSubscriptionRequestHandlerFactory

public BarrageSubscriptionRequestHandlerFactory()

Method Details

type

public byte type()

Description copied from interface: ExchangeRequestHandlerFactory

The type of message that this factory produces a handler for.

Message types are defined in BarrageMessageType.

Specified by:

type in interface ExchangeRequestHandlerFactory

Returns:

the type of message handled by this factory

create

public ArrowFlightUtil.DoExchangeMarshaller.Handler create(ArrowFlightUtil.DoExchangeMarshaller marshaller,
 io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Description copied from interface: ExchangeRequestHandlerFactory

Creates a handler for a DoExchange message.

Specified by:

create in interface ExchangeRequestHandlerFactory

Parameters:

marshaller - the DoExchangeMarshaller handling the message

listener - the listener for results of this message

Returns:

the Handler for the message