io.micronaut.gcp.pubsub.support

Class PubSubPublisherState

java.lang.Object

io.micronaut.gcp.pubsub.support.PubSubPublisherState

public class PubSubPublisherState
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
PubSubPublisherState(java.lang.String contentType, com.google.pubsub.v1.ProjectTopicName topicName, java.util.Map<java.lang.String,java.lang.String> staticMessageAttributes, io.micronaut.core.type.Argument<?> bodyArgument, java.lang.String executor)

Method Summary

Modifier and Type	Method and Description
io.micronaut.core.type.Argument<?>	getBodyArgument()
java.lang.String	getConfiguration()
java.lang.String	getContentType()
java.util.Map<java.lang.String,java.lang.String>	getStaticMessageAttributes()
com.google.pubsub.v1.ProjectTopicName	getTopicName()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubPublisherState

public PubSubPublisherState(java.lang.String contentType,
                            com.google.pubsub.v1.ProjectTopicName topicName,
                            java.util.Map<java.lang.String,java.lang.String> staticMessageAttributes,
                            io.micronaut.core.type.Argument<?> bodyArgument,
                            java.lang.String executor)

Method Detail

getContentType

public java.lang.String getContentType()

Returns:

the contentType

getTopicName

public com.google.pubsub.v1.ProjectTopicName getTopicName()

Returns:

the topic name

getStaticMessageAttributes

public java.util.Map<java.lang.String,java.lang.String> getStaticMessageAttributes()

Returns:

Message Attibutes from Header annotations

getBodyArgument

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

Returns:

the body argument

getConfiguration

public java.lang.String getConfiguration()

Returns:

the name of the PublisherConfigurationProperties to be used