public abstract class GrpcRequestAbstractStreamObserver extends Object implements io.grpc.stub.StreamObserver<Object>
Modifier and Type | Field and Description |
---|---|
protected GrpcConsumer |
consumer |
protected GrpcEndpoint |
endpoint |
protected org.apache.camel.Exchange |
exchange |
protected Map<String,Object> |
headers |
protected io.grpc.stub.StreamObserver<Object> |
responseObserver |
Constructor and Description |
---|
GrpcRequestAbstractStreamObserver(GrpcEndpoint endpoint,
GrpcConsumer consumer,
io.grpc.stub.StreamObserver<Object> responseObserver,
Map<String,Object> headers) |
protected final GrpcEndpoint endpoint
protected final GrpcConsumer consumer
protected org.apache.camel.Exchange exchange
protected io.grpc.stub.StreamObserver<Object> responseObserver
public GrpcRequestAbstractStreamObserver(GrpcEndpoint endpoint, GrpcConsumer consumer, io.grpc.stub.StreamObserver<Object> responseObserver, Map<String,Object> headers)
Apache Camel