Class SubscriberGrpc (1.117.0)

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

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Fields

SERVICE_NAME

public static final String SERVICE_NAME

Field Value

Type	Description
String

Static Methods

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