public class WrappingPublisher extends ProxyService implements Publisher
Implements
PublisherConstructors
WrappingPublisher(Publisher<MessageMetadata> wirePublisher, MessageTransformer<PubsubMessage,Message> transformer)
public WrappingPublisher(Publisher<MessageMetadata> wirePublisher, MessageTransformer<PubsubMessage,Message> transformer)
Parameters | |
---|---|
Name | Description |
wirePublisher |
Publisher<MessageMetadata> |
transformer |
MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> |
Methods
publish(PubsubMessage message)
public ApiFuture<String> publish(PubsubMessage message)
Parameter | |
---|---|
Name | Description |
message |
com.google.pubsub.v1.PubsubMessage |
Returns | |
---|---|
Type | Description |
ApiFuture<String> |