Class SubscriberGrpc (1.134.2) 

public final class SubscriberGrpc

The service that an application uses to manipulate subscriptions and to consume messages from a subscription via the Pull method or by establishing a bi-directional stream using the StreamingPull method.

Inheritance

java.lang.Object > SubscriberGrpc

Static Fields

SERVICE_NAME

public static final String SERVICE_NAME
Field Value
Type Description
String

Static Methods

bindService(SubscriberGrpc.AsyncService service)

public static final ServerServiceDefinition bindService(SubscriberGrpc.AsyncService service)
Parameter
Name Description
service SubscriberGrpc.AsyncService
Returns
Type Description
io.grpc.ServerServiceDefinition

getAcknowledgeMethod()

public static MethodDescriptor<AcknowledgeRequest,Empty> getAcknowledgeMethod()
Returns
Type Description
io.grpc.MethodDescriptor<AcknowledgeRequest,Empty>

getCreateSnapshotMethod()

public static MethodDescriptor<CreateSnapshotRequest,Snapshot> getCreateSnapshotMethod()
Returns
Type Description
io.grpc.MethodDescriptor<CreateSnapshotRequest,Snapshot>

getCreateSubscriptionMethod()

public static MethodDescriptor<Subscription,Subscription> getCreateSubscriptionMethod()
Returns
Type Description
io.grpc.MethodDescriptor<Subscription,Subscription>

getDeleteSnapshotMethod()

public static MethodDescriptor<DeleteSnapshotRequest,Empty> getDeleteSnapshotMethod()
Returns
Type Description
io.grpc.MethodDescriptor<DeleteSnapshotRequest,Empty>

getDeleteSubscriptionMethod()

public static MethodDescriptor<DeleteSubscriptionRequest,Empty> getDeleteSubscriptionMethod()
Returns
Type Description
io.grpc.MethodDescriptor<DeleteSubscriptionRequest,Empty>

getGetSnapshotMethod()

public static MethodDescriptor<GetSnapshotRequest,Snapshot> getGetSnapshotMethod()
Returns
Type Description
io.grpc.MethodDescriptor<GetSnapshotRequest,Snapshot>

getGetSubscriptionMethod()

public static MethodDescriptor<GetSubscriptionRequest,Subscription> getGetSubscriptionMethod()
Returns
Type Description
io.grpc.MethodDescriptor<GetSubscriptionRequest,Subscription>

getListSnapshotsMethod()

public static MethodDescriptor<ListSnapshotsRequest,ListSnapshotsResponse> getListSnapshotsMethod()
Returns
Type Description
io.grpc.MethodDescriptor<ListSnapshotsRequest,ListSnapshotsResponse>

getListSubscriptionsMethod()

public static MethodDescriptor<ListSubscriptionsRequest,ListSubscriptionsResponse> getListSubscriptionsMethod()
Returns
Type Description
io.grpc.MethodDescriptor<ListSubscriptionsRequest,ListSubscriptionsResponse>

getModifyAckDeadlineMethod()

public static MethodDescriptor<ModifyAckDeadlineRequest,Empty> getModifyAckDeadlineMethod()
Returns
Type Description
io.grpc.MethodDescriptor<ModifyAckDeadlineRequest,Empty>

getModifyPushConfigMethod()

public static MethodDescriptor<ModifyPushConfigRequest,Empty> getModifyPushConfigMethod()
Returns
Type Description
io.grpc.MethodDescriptor<ModifyPushConfigRequest,Empty>

getPullMethod()

public static MethodDescriptor<PullRequest,PullResponse> getPullMethod()
Returns
Type Description
io.grpc.MethodDescriptor<PullRequest,PullResponse>

getSeekMethod()

public static MethodDescriptor<SeekRequest,SeekResponse> getSeekMethod()
Returns
Type Description
io.grpc.MethodDescriptor<SeekRequest,SeekResponse>

getServiceDescriptor()

public static ServiceDescriptor getServiceDescriptor()
Returns
Type Description
io.grpc.ServiceDescriptor

getStreamingPullMethod()

public static MethodDescriptor<StreamingPullRequest,StreamingPullResponse> getStreamingPullMethod()
Returns
Type Description
io.grpc.MethodDescriptor<StreamingPullRequest,StreamingPullResponse>

getUpdateSnapshotMethod()

public static MethodDescriptor<UpdateSnapshotRequest,Snapshot> getUpdateSnapshotMethod()
Returns
Type Description
io.grpc.MethodDescriptor<UpdateSnapshotRequest,Snapshot>

getUpdateSubscriptionMethod()

public static MethodDescriptor<UpdateSubscriptionRequest,Subscription> getUpdateSubscriptionMethod()
Returns
Type Description
io.grpc.MethodDescriptor<UpdateSubscriptionRequest,Subscription>

newBlockingStub(Channel channel)

public static SubscriberGrpc.SubscriberBlockingStub newBlockingStub(Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

Parameter
Name Description
channel io.grpc.Channel
Returns
Type Description
SubscriberGrpc.SubscriberBlockingStub

newFutureStub(Channel channel)

public static SubscriberGrpc.SubscriberFutureStub newFutureStub(Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

Parameter
Name Description
channel io.grpc.Channel
Returns
Type Description
SubscriberGrpc.SubscriberFutureStub

newStub(Channel channel)

public static SubscriberGrpc.SubscriberStub newStub(Channel channel)

Creates a new async stub that supports all call types for the service

Parameter
Name Description
channel io.grpc.Channel
Returns
Type Description
SubscriberGrpc.SubscriberStub