Package io.dapr.v1
Class AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub>
io.dapr.v1.AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub
- Enclosing class:
- AppCallbackAlphaGrpc
public static final class AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub
extends io.grpc.stub.AbstractBlockingStub<AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub>
A stub to allow clients to do synchronous rpc calls to service AppCallbackAlpha.
AppCallbackAlpha V1 is an optional extension to AppCallback V1 to opt for Alpha RPCs.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
-
Method Summary
Modifier and TypeMethodDescriptionbuild
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) Subscribes bulk events from PubsubSends job back to the app's endpoint at trigger time.Methods inherited from class io.grpc.stub.AbstractBlockingStub
newStub, newStub
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<AppCallbackAlphaGrpc.AppCallbackAlphaBlockingStub>
-
onBulkTopicEventAlpha1
public DaprAppCallbackProtos.TopicEventBulkResponse onBulkTopicEventAlpha1(DaprAppCallbackProtos.TopicEventBulkRequest request) Subscribes bulk events from Pubsub
-
onJobEventAlpha1
public DaprAppCallbackProtos.JobEventResponse onJobEventAlpha1(DaprAppCallbackProtos.JobEventRequest request) Sends job back to the app's endpoint at trigger time.
-