DefaultPubSubRpc (GCloud Java Pub/Sub 0.2.4 API)

java.lang.Object
- com.google.cloud.pubsub.spi.DefaultPubSubRpc

All Implemented Interfaces:: PubSubRpc, AutoCloseable

public class DefaultPubSubRpc
extends Object
implements PubSubRpc

Nested Class Summary
- Nested classes/interfaces inherited from interface com.google.cloud.pubsub.spi.PubSubRpc
  PubSubRpc.PullCallback, PubSubRpc.PullFuture

Constructor Summary

Constructors
Constructor and Description

DefaultPubSubRpc(PubSubOptions options)

Constructors
Constructor and Description
`DefaultPubSubRpc(PubSubOptions options)`

Method Summary

Methods
Modifier and Type	Method and Description
`Future<com.google.protobuf.Empty>`	`acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)` Sends a request to acknowledge messages for a subscription.
`void`	`close()`
`Future<com.google.pubsub.v1.Subscription>`	`create(com.google.pubsub.v1.Subscription subscription)` Sends a request to create a subscription.
`Future<com.google.pubsub.v1.Topic>`	`create(com.google.pubsub.v1.Topic topic)` Sends a request to create a topic.
`Future<com.google.protobuf.Empty>`	`delete(com.google.pubsub.v1.DeleteSubscriptionRequest request)` Sends a request to delete a subscription.
`Future<com.google.protobuf.Empty>`	`delete(com.google.pubsub.v1.DeleteTopicRequest request)` Sends a request to delete a topic.
`Future<com.google.pubsub.v1.Subscription>`	`get(com.google.pubsub.v1.GetSubscriptionRequest request)` Sends a request to get a subscription.
`Future<com.google.pubsub.v1.Topic>`	`get(com.google.pubsub.v1.GetTopicRequest request)` Sends a request to get a topic.
`Future<com.google.pubsub.v1.ListSubscriptionsResponse>`	`list(com.google.pubsub.v1.ListSubscriptionsRequest request)` Sends a request to list the subscriptions in a project.
`Future<com.google.pubsub.v1.ListTopicsResponse>`	`list(com.google.pubsub.v1.ListTopicsRequest request)` Sends a request to list the topics in a project.
`Future<com.google.pubsub.v1.ListTopicSubscriptionsResponse>`	`list(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)` Sends a request to list the subscriptions for a topic.
`Future<com.google.protobuf.Empty>`	`modify(com.google.pubsub.v1.ModifyAckDeadlineRequest request)` Sends a request to modify the acknowledge deadline of a subscription.
`Future<com.google.protobuf.Empty>`	`modify(com.google.pubsub.v1.ModifyPushConfigRequest request)` Sends a request to modify the push configuration of a subscription.
`Future<com.google.pubsub.v1.PublishResponse>`	`publish(com.google.pubsub.v1.PublishRequest request)` Sends a request to publish messages.
`PubSubRpc.PullFuture`	`pull(com.google.pubsub.v1.PullRequest request)` Sends a request to pull messages from a subscription.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DefaultPubSubRpc
```
public DefaultPubSubRpc(PubSubOptions options)
                 throws IOException
```
    Throws:
    
    IOException
- Method Detail
  - create
```
public Future<com.google.pubsub.v1.Topic> create(com.google.pubsub.v1.Topic topic)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to create a topic. This method returns a Future object to consume the result. Future.get() returns the created topic.
    
    Specified by:
    
    create in interface PubSubRpc
    
    Parameters:
    topic - the topic to create
  - publish
```
public Future<com.google.pubsub.v1.PublishResponse> publish(com.google.pubsub.v1.PublishRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to publish messages. This method returns a Future object to consume the result. Future.get() returns a response object containing the publish result.
    
    Specified by:
    
    publish in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - get
```
public Future<com.google.pubsub.v1.Topic> get(com.google.pubsub.v1.GetTopicRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to get a topic. This method returns a Future object to consume the result. Future.get() returns the requested topic or null if not found.
    
    Specified by:
    
    get in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - list
```
public Future<com.google.pubsub.v1.ListTopicsResponse> list(com.google.pubsub.v1.ListTopicsRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to list the topics in a project. This method returns a Future object to consume the result. Future.get() returns a response object containing the listing result.
    
    Specified by:
    
    list in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - list
```
public Future<com.google.pubsub.v1.ListTopicSubscriptionsResponse> list(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to list the subscriptions for a topic. This method returns a Future object to consume the result. Future.get() returns a response object containing the listing result.
    
    Specified by:
    
    list in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - delete
```
public Future<com.google.protobuf.Empty> delete(com.google.pubsub.v1.DeleteTopicRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to delete a topic. This method returns a Future object to consume the result. Future.get() returns Empty.getDefaultInstance() or null if the topic was not found.
    
    Specified by:
    
    delete in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - create
```
public Future<com.google.pubsub.v1.Subscription> create(com.google.pubsub.v1.Subscription subscription)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to create a subscription. This method returns a Future object to consume the result. Future.get() returns the created subscription.
    
    Specified by:
    
    create in interface PubSubRpc
    
    Parameters:
    subscription - the subscription to create
  - get
```
public Future<com.google.pubsub.v1.Subscription> get(com.google.pubsub.v1.GetSubscriptionRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to get a subscription. This method returns a Future object to consume the result. Future.get() returns the requested subscription or null if not found.
    
    Specified by:
    
    get in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - list
```
public Future<com.google.pubsub.v1.ListSubscriptionsResponse> list(com.google.pubsub.v1.ListSubscriptionsRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to list the subscriptions in a project. This method returns a Future object to consume the result. Future.get() returns a response object containing the listing result.
    
    Specified by:
    
    list in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - delete
```
public Future<com.google.protobuf.Empty> delete(com.google.pubsub.v1.DeleteSubscriptionRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to delete a subscription. This method returns a Future object to consume the result. Future.get() returns Empty.getDefaultInstance() or null if the subscription was not found.
    
    Specified by:
    
    delete in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - modify
```
public Future<com.google.protobuf.Empty> modify(com.google.pubsub.v1.ModifyAckDeadlineRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to modify the acknowledge deadline of a subscription. This method returns a Future object to consume the result. Future.get() returns Empty.getDefaultInstance() if the request was issued correctly.
    
    Specified by:
    
    modify in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - acknowledge
```
public Future<com.google.protobuf.Empty> acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to acknowledge messages for a subscription. This method returns a Future object to consume the result. Future.get() returns Empty.getDefaultInstance() if the request was issued correctly.
    
    Specified by:
    
    acknowledge in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - pull
```
public PubSubRpc.PullFuture pull(com.google.pubsub.v1.PullRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to pull messages from a subscription. This method returns a PubSubRpc.PullFuture object to consume the result. Future.get() returns a response object containing the pulled messages. PullFuture#addCallback(PullCallback) can be used to register a callback for the request's completion.
    
    Specified by:
    
    pull in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - modify
```
public Future<com.google.protobuf.Empty> modify(com.google.pubsub.v1.ModifyPushConfigRequest request)
```
    Description copied from interface: PubSubRpc
    
    Sends a request to modify the push configuration of a subscription. This method returns a Future object to consume the result. Future.get() returns Empty.getDefaultInstance() if the request was issued correctly.
    
    Specified by:
    
    modify in interface PubSubRpc
    
    Parameters:
    request - the request object containing all of the parameters for the API call
  - close
```
public void close()
           throws Exception
```
    Specified by:
    
    close in interface AutoCloseable
    
    Throws:
    
    Exception

Class DefaultPubSubRpc

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.cloud.pubsub.spi.PubSubRpc

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DefaultPubSubRpc

Method Detail

create

publish

get

list

list

delete

create

get

list

delete

modify

acknowledge

pull

modify

close