TypeArgumentBinder
and consumer classes for PubSub support.See: Description
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 | Description |
---|---|
CustomBindingSubscriber | |
DefaultPubSubAcknowledgement |
Defaul implementation of
Acknowledgement contract. |
DefaultSubscriberFactory |
Default implementation of
SubscriberFactory . |
MessagePublishTimeAnnotationBinder | |
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. |
PubSubMessageIdBinder |
Binds a PubSubMessage Id to the argument.
|
SubscriberFactoryConfig |
Holds necessary configuration to create
Subscriber via SubscriberFactory . |
Annotation Type | Description |
---|---|
MessagePublishTime |
TypeArgumentBinder
and consumer classes for PubSub support.