Package io.micronaut.gcp.pubsub.bind
package io.micronaut.gcp.pubsub.bind
Contains binders @see
TypeArgumentBinder
and consumer classes for PubSub support.- Since:
- 2.0.0
- Author:
- Vinicius Carvalho
-
ClassDescriptionDefaul implementation of
Acknowledgement
contract.Default implementation ofSubscriberFactory
.BindsAcknowledgement
arguments.PubSubAnnotatedArgumentBinder<A extends Annotation>An interface for PubSub argument binding based on an annotation.An interface for PubSub argument binding.Convert PubSub attributes to the requested type.Binds arguments annotated withMessageBody
and uses the appropriatePubSubMessageSerDes
to deserialize the contents of the PubSubMessage data.Stores the context of a PubSubMessage that is received.Default body binder of PubSub consumers.Binds an argument annotated withMessageHeader
annotation.Binds a PubSubMessage Id to the argument.An interface for PubSub argument binding based on argument type.Factory to createSubscriberInterface
using default configurations.Holds necessary configuration to createSubscriber
viaSubscriberFactory
.