@Generated(value="by gapic-generator") @BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") public class GrpcSubscriberStub extends SubscriberStub
This class is for advanced usage and reflects the underlying API directly.
Modifier | Constructor and Description |
---|---|
protected |
GrpcSubscriberStub(SubscriberStubSettings settings,
ClientContext clientContext)
Constructs an instance of GrpcSubscriberStub, using the given settings.
|
protected |
GrpcSubscriberStub(SubscriberStubSettings settings,
ClientContext clientContext,
GrpcStubCallableFactory callableFactory)
Constructs an instance of GrpcSubscriberStub, using the given settings.
|
Modifier and Type | Method and Description |
---|---|
UnaryCallable<com.google.pubsub.v1.AcknowledgeRequest,Empty> |
acknowledgeCallable() |
boolean |
awaitTermination(long duration,
TimeUnit unit) |
void |
close() |
static GrpcSubscriberStub |
create(ClientContext clientContext) |
static GrpcSubscriberStub |
create(ClientContext clientContext,
GrpcStubCallableFactory callableFactory) |
static GrpcSubscriberStub |
create(SubscriberStubSettings settings) |
UnaryCallable<com.google.pubsub.v1.CreateSnapshotRequest,com.google.pubsub.v1.Snapshot> |
createSnapshotCallable() |
UnaryCallable<com.google.pubsub.v1.Subscription,com.google.pubsub.v1.Subscription> |
createSubscriptionCallable() |
UnaryCallable<com.google.pubsub.v1.DeleteSnapshotRequest,Empty> |
deleteSnapshotCallable() |
UnaryCallable<com.google.pubsub.v1.DeleteSubscriptionRequest,Empty> |
deleteSubscriptionCallable() |
UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> |
getIamPolicyCallable() |
UnaryCallable<com.google.pubsub.v1.GetSubscriptionRequest,com.google.pubsub.v1.Subscription> |
getSubscriptionCallable() |
boolean |
isShutdown() |
boolean |
isTerminated() |
UnaryCallable<com.google.pubsub.v1.ListSnapshotsRequest,com.google.pubsub.v1.ListSnapshotsResponse> |
listSnapshotsCallable() |
UnaryCallable<com.google.pubsub.v1.ListSnapshotsRequest,SubscriptionAdminClient.ListSnapshotsPagedResponse> |
listSnapshotsPagedCallable() |
UnaryCallable<com.google.pubsub.v1.ListSubscriptionsRequest,com.google.pubsub.v1.ListSubscriptionsResponse> |
listSubscriptionsCallable() |
UnaryCallable<com.google.pubsub.v1.ListSubscriptionsRequest,SubscriptionAdminClient.ListSubscriptionsPagedResponse> |
listSubscriptionsPagedCallable() |
UnaryCallable<com.google.pubsub.v1.ModifyAckDeadlineRequest,Empty> |
modifyAckDeadlineCallable() |
UnaryCallable<com.google.pubsub.v1.ModifyPushConfigRequest,Empty> |
modifyPushConfigCallable() |
UnaryCallable<com.google.pubsub.v1.PullRequest,com.google.pubsub.v1.PullResponse> |
pullCallable() |
UnaryCallable<com.google.pubsub.v1.SeekRequest,com.google.pubsub.v1.SeekResponse> |
seekCallable() |
UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> |
setIamPolicyCallable() |
void |
shutdown() |
void |
shutdownNow() |
BidiStreamingCallable<com.google.pubsub.v1.StreamingPullRequest,com.google.pubsub.v1.StreamingPullResponse> |
streamingPullCallable() |
UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> |
testIamPermissionsCallable() |
UnaryCallable<com.google.pubsub.v1.UpdateSnapshotRequest,com.google.pubsub.v1.Snapshot> |
updateSnapshotCallable() |
UnaryCallable<com.google.pubsub.v1.UpdateSubscriptionRequest,com.google.pubsub.v1.Subscription> |
updateSubscriptionCallable() |
protected GrpcSubscriberStub(SubscriberStubSettings settings, ClientContext clientContext) throws IOException
IOException
protected GrpcSubscriberStub(SubscriberStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public static final GrpcSubscriberStub create(SubscriberStubSettings settings) throws IOException
IOException
public static final GrpcSubscriberStub create(ClientContext clientContext) throws IOException
IOException
public static final GrpcSubscriberStub create(ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public UnaryCallable<com.google.pubsub.v1.Subscription,com.google.pubsub.v1.Subscription> createSubscriptionCallable()
createSubscriptionCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.GetSubscriptionRequest,com.google.pubsub.v1.Subscription> getSubscriptionCallable()
getSubscriptionCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.UpdateSubscriptionRequest,com.google.pubsub.v1.Subscription> updateSubscriptionCallable()
updateSubscriptionCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ListSubscriptionsRequest,SubscriptionAdminClient.ListSubscriptionsPagedResponse> listSubscriptionsPagedCallable()
listSubscriptionsPagedCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ListSubscriptionsRequest,com.google.pubsub.v1.ListSubscriptionsResponse> listSubscriptionsCallable()
listSubscriptionsCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.DeleteSubscriptionRequest,Empty> deleteSubscriptionCallable()
deleteSubscriptionCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ModifyAckDeadlineRequest,Empty> modifyAckDeadlineCallable()
modifyAckDeadlineCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.AcknowledgeRequest,Empty> acknowledgeCallable()
acknowledgeCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.PullRequest,com.google.pubsub.v1.PullResponse> pullCallable()
pullCallable
in class SubscriberStub
public BidiStreamingCallable<com.google.pubsub.v1.StreamingPullRequest,com.google.pubsub.v1.StreamingPullResponse> streamingPullCallable()
streamingPullCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ModifyPushConfigRequest,Empty> modifyPushConfigCallable()
modifyPushConfigCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ListSnapshotsRequest,SubscriptionAdminClient.ListSnapshotsPagedResponse> listSnapshotsPagedCallable()
listSnapshotsPagedCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.ListSnapshotsRequest,com.google.pubsub.v1.ListSnapshotsResponse> listSnapshotsCallable()
listSnapshotsCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.CreateSnapshotRequest,com.google.pubsub.v1.Snapshot> createSnapshotCallable()
createSnapshotCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.UpdateSnapshotRequest,com.google.pubsub.v1.Snapshot> updateSnapshotCallable()
updateSnapshotCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.DeleteSnapshotRequest,Empty> deleteSnapshotCallable()
deleteSnapshotCallable
in class SubscriberStub
public UnaryCallable<com.google.pubsub.v1.SeekRequest,com.google.pubsub.v1.SeekResponse> seekCallable()
seekCallable
in class SubscriberStub
public UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> setIamPolicyCallable()
setIamPolicyCallable
in class SubscriberStub
public UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> getIamPolicyCallable()
getIamPolicyCallable
in class SubscriberStub
public UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> testIamPermissionsCallable()
testIamPermissionsCallable
in class SubscriberStub
public final void close()
close
in interface AutoCloseable
close
in class SubscriberStub
public void shutdown()
public boolean isShutdown()
public boolean isTerminated()
public void shutdownNow()
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
InterruptedException
Copyright © 2019 Google LLC. All rights reserved.