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 |
---|---|
PublishResponse |
PublisherApi.publish(PublishRequest request)
Adds one or more messages to the topic.
|
PublishResponse |
PublisherApi.publish(java.lang.String topic,
java.util.List<PubsubMessage> messages)
Adds one or more messages to the topic.
|
Modifier and Type | Method and Description |
---|---|
ApiCallable<PublishRequest,PublishResponse> |
PublisherApi.publishCallable()
Adds one or more messages to the topic.
|
BundlingCallSettings<PublishRequest,PublishResponse> |
PublisherSettings.publishSettings()
Returns the object with the settings used for calls to publish.
|
BundlingCallSettings.Builder<PublishRequest,PublishResponse> |
PublisherSettings.Builder.publishSettings()
Returns the builder for the settings used for calls to publish.
|
Modifier and Type | Field and Description |
---|---|
static io.grpc.MethodDescriptor<PublishRequest,PublishResponse> |
PublisherGrpc.METHOD_PUBLISH |
Modifier and Type | Method and Description |
---|---|
PublishResponse |
PublishResponse.Builder.build() |
PublishResponse |
PublishResponse.Builder.buildPartial() |
static PublishResponse |
PublishResponse.getDefaultInstance() |
PublishResponse |
PublishResponse.getDefaultInstanceForType() |
PublishResponse |
PublishResponse.Builder.getDefaultInstanceForType() |
static PublishResponse |
PublishResponse.parseDelimitedFrom(java.io.InputStream input) |
static PublishResponse |
PublishResponse.parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static PublishResponse |
PublishResponse.parseFrom(byte[] data) |
static PublishResponse |
PublishResponse.parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static PublishResponse |
PublishResponse.parseFrom(ByteString data) |
static PublishResponse |
PublishResponse.parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static PublishResponse |
PublishResponse.parseFrom(CodedInputStream input) |
static PublishResponse |
PublishResponse.parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static PublishResponse |
PublishResponse.parseFrom(java.io.InputStream input) |
static PublishResponse |
PublishResponse.parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
PublishResponse |
PublisherGrpc.PublisherBlockingClient.publish(PublishRequest request) |
PublishResponse |
PublisherGrpc.PublisherBlockingStub.publish(PublishRequest request) |
Modifier and Type | Method and Description |
---|---|
Parser<PublishResponse> |
PublishResponse.getParserForType() |
static Parser<PublishResponse> |
PublishResponse.parser() |
com.google.common.util.concurrent.ListenableFuture<PublishResponse> |
PublisherGrpc.PublisherFutureClient.publish(PublishRequest request) |
com.google.common.util.concurrent.ListenableFuture<PublishResponse> |
PublisherGrpc.PublisherFutureStub.publish(PublishRequest request) |
Modifier and Type | Method and Description |
---|---|
PublishResponse.Builder |
PublishResponse.Builder.mergeFrom(PublishResponse other) |
static PublishResponse.Builder |
PublishResponse.newBuilder(PublishResponse prototype) |
Modifier and Type | Method and Description |
---|---|
void |
PublisherGrpc.Publisher.publish(PublishRequest request,
io.grpc.stub.StreamObserver<PublishResponse> responseObserver) |
void |
PublisherGrpc.PublisherStub.publish(PublishRequest request,
io.grpc.stub.StreamObserver<PublishResponse> responseObserver) |