Package | Description |
---|---|
com.google.cloud.pubsub.spi.v1 |
A client to Google Cloud Pub/Sub API.
|
com.google.pubsub.v1 |
Modifier and Type | Method and Description |
---|---|
Subscription |
SubscriberApi.createSubscription(java.lang.String name,
java.lang.String topic,
PushConfig pushConfig,
int ackDeadlineSeconds)
Creates a subscription to a given topic.
|
Subscription |
SubscriberApi.createSubscription(Subscription request)
Creates a subscription to a given topic.
|
Subscription |
SubscriberApi.getSubscription(java.lang.String subscription)
Gets the configuration details of a subscription.
|
Modifier and Type | Method and Description |
---|---|
ApiCallable<Subscription,Subscription> |
SubscriberApi.createSubscriptionCallable()
Creates a subscription to a given topic.
|
ApiCallable<Subscription,Subscription> |
SubscriberApi.createSubscriptionCallable()
Creates a subscription to a given topic.
|
SimpleCallSettings<Subscription,Subscription> |
SubscriberSettings.createSubscriptionSettings()
Returns the object with the settings used for calls to createSubscription.
|
SimpleCallSettings<Subscription,Subscription> |
SubscriberSettings.createSubscriptionSettings()
Returns the object with the settings used for calls to createSubscription.
|
SimpleCallSettings.Builder<Subscription,Subscription> |
SubscriberSettings.Builder.createSubscriptionSettings()
Returns the builder for the settings used for calls to createSubscription.
|
SimpleCallSettings.Builder<Subscription,Subscription> |
SubscriberSettings.Builder.createSubscriptionSettings()
Returns the builder for the settings used for calls to createSubscription.
|
ApiCallable<GetSubscriptionRequest,Subscription> |
SubscriberApi.getSubscriptionCallable()
Gets the configuration details of a subscription.
|
SimpleCallSettings<GetSubscriptionRequest,Subscription> |
SubscriberSettings.getSubscriptionSettings()
Returns the object with the settings used for calls to getSubscription.
|
SimpleCallSettings.Builder<GetSubscriptionRequest,Subscription> |
SubscriberSettings.Builder.getSubscriptionSettings()
Returns the builder for the settings used for calls to getSubscription.
|
PageAccessor<Subscription> |
SubscriberApi.listSubscriptions(ListSubscriptionsRequest request)
Lists matching subscriptions.
|
PageAccessor<Subscription> |
SubscriberApi.listSubscriptions(java.lang.String project)
Lists matching subscriptions.
|
ApiCallable<ListSubscriptionsRequest,PageAccessor<Subscription>> |
SubscriberApi.listSubscriptionsPagedCallable()
Lists matching subscriptions.
|
PageStreamingCallSettings<ListSubscriptionsRequest,ListSubscriptionsResponse,Subscription> |
SubscriberSettings.listSubscriptionsSettings()
Returns the object with the settings used for calls to listSubscriptions.
|
PageStreamingCallSettings.Builder<ListSubscriptionsRequest,ListSubscriptionsResponse,Subscription> |
SubscriberSettings.Builder.listSubscriptionsSettings()
Returns the builder for the settings used for calls to listSubscriptions.
|
Modifier and Type | Method and Description |
---|---|
Subscription |
SubscriberApi.createSubscription(Subscription request)
Creates a subscription to a given topic.
|
Modifier and Type | Field and Description |
---|---|
static io.grpc.MethodDescriptor<Subscription,Subscription> |
SubscriberGrpc.METHOD_CREATE_SUBSCRIPTION |
static io.grpc.MethodDescriptor<Subscription,Subscription> |
SubscriberGrpc.METHOD_CREATE_SUBSCRIPTION |
static io.grpc.MethodDescriptor<GetSubscriptionRequest,Subscription> |
SubscriberGrpc.METHOD_GET_SUBSCRIPTION |
Modifier and Type | Method and Description |
---|---|
Subscription |
Subscription.Builder.build() |
Subscription |
Subscription.Builder.buildPartial() |
Subscription |
SubscriberGrpc.SubscriberBlockingClient.createSubscription(Subscription request) |
Subscription |
SubscriberGrpc.SubscriberBlockingStub.createSubscription(Subscription request) |
static Subscription |
Subscription.getDefaultInstance() |
Subscription |
Subscription.getDefaultInstanceForType() |
Subscription |
Subscription.Builder.getDefaultInstanceForType() |
Subscription |
SubscriberGrpc.SubscriberBlockingClient.getSubscription(GetSubscriptionRequest request) |
Subscription |
SubscriberGrpc.SubscriberBlockingStub.getSubscription(GetSubscriptionRequest request) |
Subscription |
ListSubscriptionsResponseOrBuilder.getSubscriptions(int index)
The subscriptions that match the request.
|
Subscription |
ListSubscriptionsResponse.getSubscriptions(int index)
The subscriptions that match the request.
|
Subscription |
ListSubscriptionsResponse.Builder.getSubscriptions(int index)
The subscriptions that match the request.
|
static Subscription |
Subscription.parseDelimitedFrom(java.io.InputStream input) |
static Subscription |
Subscription.parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
Subscription.parseFrom(byte[] data) |
static Subscription |
Subscription.parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
Subscription.parseFrom(ByteString data) |
static Subscription |
Subscription.parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
Subscription.parseFrom(CodedInputStream input) |
static Subscription |
Subscription.parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
Subscription.parseFrom(java.io.InputStream input) |
static Subscription |
Subscription.parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureClient.createSubscription(Subscription request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureStub.createSubscription(Subscription request) |
Parser<Subscription> |
Subscription.getParserForType() |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureClient.getSubscription(GetSubscriptionRequest request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureStub.getSubscription(GetSubscriptionRequest request) |
java.util.List<Subscription> |
ListSubscriptionsResponseOrBuilder.getSubscriptionsList()
The subscriptions that match the request.
|
java.util.List<Subscription> |
ListSubscriptionsResponse.getSubscriptionsList()
The subscriptions that match the request.
|
java.util.List<Subscription> |
ListSubscriptionsResponse.Builder.getSubscriptionsList()
The subscriptions that match the request.
|
static Parser<Subscription> |
Subscription.parser() |
Modifier and Type | Method and Description |
---|---|
ListSubscriptionsResponse.Builder |
ListSubscriptionsResponse.Builder.addSubscriptions(int index,
Subscription value)
The subscriptions that match the request.
|
ListSubscriptionsResponse.Builder |
ListSubscriptionsResponse.Builder.addSubscriptions(Subscription value)
The subscriptions that match the request.
|
Subscription |
SubscriberGrpc.SubscriberBlockingClient.createSubscription(Subscription request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureClient.createSubscription(Subscription request) |
Subscription |
SubscriberGrpc.SubscriberBlockingStub.createSubscription(Subscription request) |
com.google.common.util.concurrent.ListenableFuture<Subscription> |
SubscriberGrpc.SubscriberFutureStub.createSubscription(Subscription request) |
void |
SubscriberGrpc.Subscriber.createSubscription(Subscription request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |
void |
SubscriberGrpc.SubscriberStub.createSubscription(Subscription request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |
Subscription.Builder |
Subscription.Builder.mergeFrom(Subscription other) |
static Subscription.Builder |
Subscription.newBuilder(Subscription prototype) |
ListSubscriptionsResponse.Builder |
ListSubscriptionsResponse.Builder.setSubscriptions(int index,
Subscription value)
The subscriptions that match the request.
|
Modifier and Type | Method and Description |
---|---|
ListSubscriptionsResponse.Builder |
ListSubscriptionsResponse.Builder.addAllSubscriptions(java.lang.Iterable<? extends Subscription> values)
The subscriptions that match the request.
|
void |
SubscriberGrpc.Subscriber.createSubscription(Subscription request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |
void |
SubscriberGrpc.SubscriberStub.createSubscription(Subscription request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |
void |
SubscriberGrpc.Subscriber.getSubscription(GetSubscriptionRequest request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |
void |
SubscriberGrpc.SubscriberStub.getSubscription(GetSubscriptionRequest request,
io.grpc.stub.StreamObserver<Subscription> responseObserver) |