Class SubscriberGrpc (1.125.13)

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

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`