com.google.pubsub.v1

Class SubscriberGrpc.SubscriberStub

java.lang.Object

io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberStub>

com.google.pubsub.v1.SubscriberGrpc.SubscriberStub

All Implemented Interfaces:

SubscriberGrpc.Subscriber

Enclosing class:

SubscriberGrpc

public static class SubscriberGrpc.SubscriberStub
extends io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberStub>
implements SubscriberGrpc.Subscriber

Method Summary

Modifier and Type	Method and Description
void	acknowledge(AcknowledgeRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	createSubscription(Subscription request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
void	deleteSubscription(DeleteSubscriptionRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
void	listSubscriptions(ListSubscriptionsRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
void	modifyAckDeadline(ModifyAckDeadlineRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	modifyPushConfig(ModifyPushConfigRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	pull(PullRequest request, io.grpc.stub.StreamObserver<PullResponse> responseObserver)

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withChannel, withCompressor, withDeadlineAfter, withDeadlineNanoTime, withInterceptors

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createSubscription

public void createSubscription(Subscription request,
                               io.grpc.stub.StreamObserver<Subscription> responseObserver)

Specified by:

createSubscription in interface SubscriberGrpc.Subscriber

getSubscription

public void getSubscription(GetSubscriptionRequest request,
                            io.grpc.stub.StreamObserver<Subscription> responseObserver)

Specified by:

getSubscription in interface SubscriberGrpc.Subscriber

listSubscriptions

public void listSubscriptions(ListSubscriptionsRequest request,
                              io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)

Specified by:

listSubscriptions in interface SubscriberGrpc.Subscriber

deleteSubscription

public void deleteSubscription(DeleteSubscriptionRequest request,
                               io.grpc.stub.StreamObserver<Empty> responseObserver)

Specified by:

deleteSubscription in interface SubscriberGrpc.Subscriber

modifyAckDeadline

public void modifyAckDeadline(ModifyAckDeadlineRequest request,
                              io.grpc.stub.StreamObserver<Empty> responseObserver)

Specified by:

modifyAckDeadline in interface SubscriberGrpc.Subscriber

acknowledge

public void acknowledge(AcknowledgeRequest request,
                        io.grpc.stub.StreamObserver<Empty> responseObserver)

Specified by:

acknowledge in interface SubscriberGrpc.Subscriber

pull

public void pull(PullRequest request,
                 io.grpc.stub.StreamObserver<PullResponse> responseObserver)

Specified by:

pull in interface SubscriberGrpc.Subscriber

modifyPushConfig

public void modifyPushConfig(ModifyPushConfigRequest request,
                             io.grpc.stub.StreamObserver<Empty> responseObserver)

Specified by:

modifyPushConfig in interface SubscriberGrpc.Subscriber