public class GrpcMessagingServerConnection extends GrpcMessagingConnection
GrpcMessagingConnection
implementation for server.GrpcMessagingConnection.ConnectionOwner, GrpcMessagingConnection.ContextualFuture<T>, GrpcMessagingConnection.HandlerHolder
Constructor and Description |
---|
GrpcMessagingServerConnection(String transportId,
io.atomix.catalyst.concurrent.ThreadContext context,
ExecutorService executor,
long requestTimeoutMs)
Creates a messaging connection for server.
|
close, handler, handler, handleResponseMessage, onClose, onCompleted, onError, onException, onNext, send, sendAndReceive, setTargetObserver, toString
public GrpcMessagingServerConnection(String transportId, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs)
GrpcMessagingConnection.setTargetObserver(io.grpc.stub.StreamObserver<alluxio.grpc.TransportMessage>)
should be called explicitly before using the connection.transportId
- transport Id for this connectioncontext
- copycat thread contextexecutor
- transport executorrequestTimeoutMs
- timeout in milliseconds for requestsCopyright © 2023. All Rights Reserved.