@Generated(value="by gapic-generator") @BetaApi(value="A restructuring of stub classes is planned, so this may break in the future") public class GrpcPublisherStub extends PublisherStub
This class is for advanced usage and reflects the underlying API directly.
Modifier | Constructor and Description |
---|---|
protected |
GrpcPublisherStub(PublisherStubSettings settings,
ClientContext clientContext)
Constructs an instance of GrpcPublisherStub, using the given settings.
|
protected |
GrpcPublisherStub(PublisherStubSettings settings,
ClientContext clientContext,
GrpcStubCallableFactory callableFactory)
Constructs an instance of GrpcPublisherStub, using the given settings.
|
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long duration,
TimeUnit unit) |
void |
close() |
static GrpcPublisherStub |
create(ClientContext clientContext) |
static GrpcPublisherStub |
create(ClientContext clientContext,
GrpcStubCallableFactory callableFactory) |
static GrpcPublisherStub |
create(PublisherStubSettings settings) |
UnaryCallable<com.google.pubsub.v1.Topic,com.google.pubsub.v1.Topic> |
createTopicCallable() |
UnaryCallable<com.google.pubsub.v1.DeleteTopicRequest,Empty> |
deleteTopicCallable() |
UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> |
getIamPolicyCallable() |
UnaryCallable<com.google.pubsub.v1.GetTopicRequest,com.google.pubsub.v1.Topic> |
getTopicCallable() |
boolean |
isShutdown() |
boolean |
isTerminated() |
UnaryCallable<com.google.pubsub.v1.ListTopicsRequest,com.google.pubsub.v1.ListTopicsResponse> |
listTopicsCallable() |
UnaryCallable<com.google.pubsub.v1.ListTopicsRequest,TopicAdminClient.ListTopicsPagedResponse> |
listTopicsPagedCallable() |
UnaryCallable<com.google.pubsub.v1.ListTopicSubscriptionsRequest,com.google.pubsub.v1.ListTopicSubscriptionsResponse> |
listTopicSubscriptionsCallable() |
UnaryCallable<com.google.pubsub.v1.ListTopicSubscriptionsRequest,TopicAdminClient.ListTopicSubscriptionsPagedResponse> |
listTopicSubscriptionsPagedCallable() |
UnaryCallable<com.google.pubsub.v1.PublishRequest,com.google.pubsub.v1.PublishResponse> |
publishCallable() |
UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> |
setIamPolicyCallable() |
void |
shutdown() |
void |
shutdownNow() |
UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> |
testIamPermissionsCallable() |
UnaryCallable<com.google.pubsub.v1.UpdateTopicRequest,com.google.pubsub.v1.Topic> |
updateTopicCallable() |
protected GrpcPublisherStub(PublisherStubSettings settings, ClientContext clientContext) throws IOException
IOException
protected GrpcPublisherStub(PublisherStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public static final GrpcPublisherStub create(PublisherStubSettings settings) throws IOException
IOException
public static final GrpcPublisherStub create(ClientContext clientContext) throws IOException
IOException
public static final GrpcPublisherStub create(ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException
IOException
public UnaryCallable<com.google.pubsub.v1.Topic,com.google.pubsub.v1.Topic> createTopicCallable()
createTopicCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.UpdateTopicRequest,com.google.pubsub.v1.Topic> updateTopicCallable()
updateTopicCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.PublishRequest,com.google.pubsub.v1.PublishResponse> publishCallable()
publishCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.GetTopicRequest,com.google.pubsub.v1.Topic> getTopicCallable()
getTopicCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.ListTopicsRequest,TopicAdminClient.ListTopicsPagedResponse> listTopicsPagedCallable()
listTopicsPagedCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.ListTopicsRequest,com.google.pubsub.v1.ListTopicsResponse> listTopicsCallable()
listTopicsCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.ListTopicSubscriptionsRequest,TopicAdminClient.ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsPagedCallable()
listTopicSubscriptionsPagedCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.ListTopicSubscriptionsRequest,com.google.pubsub.v1.ListTopicSubscriptionsResponse> listTopicSubscriptionsCallable()
listTopicSubscriptionsCallable
in class PublisherStub
public UnaryCallable<com.google.pubsub.v1.DeleteTopicRequest,Empty> deleteTopicCallable()
deleteTopicCallable
in class PublisherStub
public UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> setIamPolicyCallable()
setIamPolicyCallable
in class PublisherStub
public UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> getIamPolicyCallable()
getIamPolicyCallable
in class PublisherStub
public UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> testIamPermissionsCallable()
testIamPermissionsCallable
in class PublisherStub
public final void close()
close
in interface AutoCloseable
close
in class PublisherStub
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.