Package io.micronaut.gcp.pubsub.support

Class PubSubPublisherState

java.lang.Object

io.micronaut.gcp.pubsub.support.PubSubPublisherState

All Implemented Interfaces:

AutoCloseable

public class PubSubPublisherState
extends Object
implements AutoCloseable

Stores the context of a PubSubMessage to be pulished. Values of this class comes from parsing of method annotations and hence are cached @see PubSubConsumerAdvice

Since:

2.0.0

Author:

Vinicius Carvalho

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubSubPublisherState.TopicState	Internal class to represent Topic State.

Constructor Summary

Constructors

Constructor	Description
PubSubPublisherState(PubSubPublisherState.TopicState topicState, Map<String,String> staticMessageAttributes, io.micronaut.core.type.Argument<?> bodyArgument, com.google.cloud.pubsub.v1.PublisherInterface publisher, Optional<io.micronaut.core.type.Argument> orderingArgument)

Method Summary

Modifier and Type	Method	Description
void	close()
io.micronaut.core.type.Argument<?>	getBodyArgument()
Optional<io.micronaut.core.type.Argument>	getOrderingArgument()
com.google.cloud.pubsub.v1.PublisherInterface	getPublisher()
Map<String,String>	getStaticMessageAttributes()
PubSubPublisherState.TopicState	getTopicState()

Methods inherited from class java.lang.Object

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

Constructor Details

PubSubPublisherState

public PubSubPublisherState(PubSubPublisherState.TopicState topicState,
 Map<String,String> staticMessageAttributes,
 io.micronaut.core.type.Argument<?> bodyArgument,
 com.google.cloud.pubsub.v1.PublisherInterface publisher,
 Optional<io.micronaut.core.type.Argument> orderingArgument)

Method Details

getPublisher

public com.google.cloud.pubsub.v1.PublisherInterface getPublisher()

Returns:

the cached publisher associated with the method.

getTopicState

public PubSubPublisherState.TopicState getTopicState()

Returns:

topicState information

getStaticMessageAttributes

public Map<String,String> getStaticMessageAttributes()

Returns:

Message Attributes from Header annotations

getBodyArgument

public io.micronaut.core.type.Argument<?> getBodyArgument()

Returns:

the body argument

getOrderingArgument

public Optional<io.micronaut.core.type.Argument> getOrderingArgument()

Returns:

Argument annotated with @OrderingKey.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception