A stub to allow clients to do asynchronous rpc calls to service PublisherService.
The service that a publisher client application uses to publish messages to
topics. Published messages are retained by the service for the duration of
the retention period configured for the respective topic, and are delivered
to subscriber clients upon request (via the SubscriberService).
Establishes a stream with the server for publishing messages. Once the
stream is initialized, the client publishes messages by sending publish
requests on the stream. The server responds with a PublishResponse for each
PublishRequest sent by the client, in the same order that the requests
were sent. Note that multiple PublishRequests can be in flight
simultaneously, but they will be processed by the server in the order that
they are sent by the client on a given stream.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-28 UTC."],[],[],null,["# Class PublisherServiceGrpc.PublisherServiceStub (1.15.13)\n\nVersion latestkeyboard_arrow_down\n\n- [1.15.13 (latest)](/java/docs/reference/google-cloud-pubsublite/latest/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.15.12](/java/docs/reference/google-cloud-pubsublite/1.15.12/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.14.8](/java/docs/reference/google-cloud-pubsublite/1.14.8/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.13.8](/java/docs/reference/google-cloud-pubsublite/1.13.8/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.12.22](/java/docs/reference/google-cloud-pubsublite/1.12.22/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.11.2](/java/docs/reference/google-cloud-pubsublite/1.11.2/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.10.0](/java/docs/reference/google-cloud-pubsublite/1.10.0/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.9.4](/java/docs/reference/google-cloud-pubsublite/1.9.4/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.8.0](/java/docs/reference/google-cloud-pubsublite/1.8.0/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.7.1](/java/docs/reference/google-cloud-pubsublite/1.7.1/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.6.3](/java/docs/reference/google-cloud-pubsublite/1.6.3/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.5.5](/java/docs/reference/google-cloud-pubsublite/1.5.5/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub)\n- [1.4.12](/java/docs/reference/google-cloud-pubsublite/1.4.12/com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub) \n\n public static final class PublisherServiceGrpc.PublisherServiceStub extends AbstractAsyncStub\u003cPublisherServiceGrpc.PublisherServiceStub\u003e\n\nA stub to allow clients to do asynchronous rpc calls to service PublisherService.\n\nThe service that a publisher client application uses to publish messages to\ntopics. Published messages are retained by the service for the duration of\nthe retention period configured for the respective topic, and are delivered\nto subscriber clients upon request (via the `SubscriberService`). \n\nInheritance\n-----------\n\n[java.lang.Object](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html) \\\u003e io.grpc.stub.AbstractStub \\\u003e io.grpc.stub.AbstractAsyncStub \\\u003e PublisherServiceGrpc.PublisherServiceStub \n\nInherited Members\n-----------------\n\nio.grpc.stub.AbstractAsyncStub.\\\u003cT\\\u003enewStub(io.grpc.stub.AbstractStub.StubFactory\\\u003cT\\\u003e,io.grpc.Channel) \nio.grpc.stub.AbstractAsyncStub.\\\u003cT\\\u003enewStub(io.grpc.stub.AbstractStub.StubFactory\\\u003cT\\\u003e,io.grpc.Channel,io.grpc.CallOptions) \nio.grpc.stub.AbstractStub.\\\u003cT\\\u003ewithOption(io.grpc.CallOptions.Key\\\u003cT\\\u003e,T) \nio.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions) \nio.grpc.stub.AbstractStub.getCallOptions() \nio.grpc.stub.AbstractStub.getChannel() \nio.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials) \nio.grpc.stub.AbstractStub.withChannel(io.grpc.Channel) \nio.grpc.stub.AbstractStub.withCompression(java.lang.String) \nio.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline) \nio.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration) \nio.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit) \nio.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor) \nio.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...) \nio.grpc.stub.AbstractStub.withMaxInboundMessageSize(int) \nio.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int) \nio.grpc.stub.AbstractStub.withOnReadyThreshold(int) \nio.grpc.stub.AbstractStub.withWaitForReady() \n[Object.clone()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#clone--) \n[Object.equals(Object)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#equals-java.lang.Object-) \n[Object.finalize()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#finalize--) \n[Object.getClass()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#getClass--) \n[Object.hashCode()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#hashCode--) \n[Object.notify()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notify--) \n[Object.notifyAll()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notifyAll--) \n[Object.toString()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#toString--) \n[Object.wait()](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait--) \n[Object.wait(long)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-) \n[Object.wait(long,int)](https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait-long-int-)\n\nMethods\n-------\n\n### build(Channel channel, CallOptions callOptions)\n\n protected PublisherServiceGrpc.PublisherServiceStub build(Channel channel, CallOptions callOptions)\n\n**Overrides** \nio.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)\n\n### publish(StreamObserver\\\u003cPublishResponse\\\u003e responseObserver)\n\n public StreamObserver\u003cPublishRequest\u003e publish(StreamObserver\u003cPublishResponse\u003e responseObserver)\n\nEstablishes a stream with the server for publishing messages. Once the\nstream is initialized, the client publishes messages by sending publish\nrequests on the stream. The server responds with a PublishResponse for each\nPublishRequest sent by the client, in the same order that the requests\nwere sent. Note that multiple PublishRequests can be in flight\nsimultaneously, but they will be processed by the server in the order that\nthey are sent by the client on a given stream."]]
