PubSubMessage (SmallRye Reactive Messaging 3.13.0 API)

java.lang.Object
- io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

All Implemented Interfaces:: Message<String>

public class PubSubMessage
extends Object
implements Message<String>

Field Summary
- Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message
  LOGGER

Constructor Summary

Constructors
Constructor	Description
`PubSubMessage(com.google.pubsub.v1.PubsubMessage message)`
`PubSubMessage(com.google.pubsub.v1.PubsubMessage message, com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CompletionStage<Void>`	`ack()`	Acknowledge this message.
`boolean`	`equals(Object o)`
`Supplier<CompletionStage<Void>>`	`getAck()`
`com.google.pubsub.v1.PubsubMessage`	`getMessage()`
`String`	`getPayload()`
`int`	`hashCode()`
`String`	`toString()`

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

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message
addMetadata, getMetadata, getMetadata, getNack, nack, nack, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload

- Constructor Detail
  - PubSubMessage
```
public PubSubMessage(com.google.pubsub.v1.PubsubMessage message)
```
  - PubSubMessage
```
public PubSubMessage(com.google.pubsub.v1.PubsubMessage message,
                     com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)
```
- Method Detail
  - getMessage
```
public com.google.pubsub.v1.PubsubMessage getMessage()
```
  - getPayload
```
public String getPayload()
```
    Specified by:
    
    getPayload in interface Message<String>
    
    Returns:
    
    The payload for this message.
  - ack
```
public CompletionStage<Void> ack()
```
    Description copied from interface: Message
    
    Acknowledge this message.
    
    Specified by:
    
    ack in interface Message<String>
    
    Returns:
    
    a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.
  - getAck
```
public Supplier<CompletionStage<Void>> getAck()
```
    Specified by:
    
    getAck in interface Message<String>
    
    Returns:
    
    the supplier used to retrieve the acknowledgement CompletionStage.
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object