public class GrpcMessagingServiceClientHandler extends MessagingServiceGrpc.MessagingServiceImplBase
GrpcMessagingTransport
.Constructor and Description |
---|
GrpcMessagingServiceClientHandler(io.atomix.catalyst.transport.Address serverAddress,
java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener,
io.atomix.catalyst.concurrent.ThreadContext context,
ExecutorService executor,
long requestTimeoutMs) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<TransportMessage> |
connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver)
RPC for establishing bi-di stream between client/server.
|
bindService
public GrpcMessagingServiceClientHandler(io.atomix.catalyst.transport.Address serverAddress, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs)
serverAddress
- server addresslistener
- listener for incoming connectionscontext
- catalyst thread contextexecutor
- transport executorrequestTimeoutMs
- request timeout value for new connectionspublic io.grpc.stub.StreamObserver<TransportMessage> connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver)
connect
in class MessagingServiceGrpc.MessagingServiceImplBase
responseObserver
- client's stream observerCopyright © 2023. All Rights Reserved.