Package io.micronaut.gcp.pubsub.bind

Contains binders @see TypeArgumentBinder and consumer classes for PubSub support.

Since:

2.0.0

Author:

Vinicius Carvalho

Interface Summary

Interface	Description
PubSubAnnotatedArgumentBinder<A extends java.lang.annotation.Annotation>	An interface for PubSub argument binding based on an annotation.
PubSubArgumentBinder<T>	An interface for PubSub argument binding.
PubSubTypeArgumentBinder<T>	An interface for PubSub argument binding based on argument type.
SubscriberFactory	Factory to create SubscriberInterface using default configurations.

Class Summary

Class	Description
DefaultPubSubAcknowledgement	Defaul implementation of Acknowledgement contract.
DefaultSubscriberFactory	Default implementation of SubscriberFactory.
PubSubAcknowledgementBinder	Binds Acknowledgement arguments.
PubSubAttributesConvertibleValues	Convert PubSub attributes to the requested type.
PubSubBinderRegistry
PubSubBodyBinder	Binds arguments annotated with Body and uses the appropriate PubSubMessageSerDes to deserialize the contents of the PubSubMessage data.
PubSubConsumerState	Stores the context of a PubSubMessage that is received.
PubSubDefaultArgumentBinder	Default body binder of PubSub consumers.
PubSubHeaderBinder	Binds an argument annotated with Header annotation.
PubSubMessageHeaderBinder	Support the new MessageHeader annotation.
PubSubMessageIdBinder	Binds a PubSubMessage Id to the argument.
SubscriberFactoryConfig	Holds necessary configuration to create Subscriber via SubscriberFactory.