Package io.micronaut.rabbitmq.bind

Class RabbitBodyBinder

java.lang.Object

io.micronaut.rabbitmq.bind.RabbitBodyBinder

All Implemented Interfaces:

io.micronaut.core.bind.annotation.AnnotatedArgumentBinder<io.micronaut.messaging.annotation.MessageBody,Object,RabbitConsumerState>, io.micronaut.core.bind.ArgumentBinder<Object,RabbitConsumerState>, RabbitAnnotatedArgumentBinder<io.micronaut.messaging.annotation.MessageBody>, RabbitArgumentBinder<Object>

@Singleton
public class RabbitBodyBinder
extends Object
implements RabbitAnnotatedArgumentBinder<io.micronaut.messaging.annotation.MessageBody>

Binds an argument of with the MessageBody annotation from the RabbitConsumerState.

Since:

1.1.0

Author:

James Kleeh

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.core.bind.ArgumentBinder

io.micronaut.core.bind.ArgumentBinder.BindingResult<T extends Object>

Constructor Summary

Constructors

Constructor	Description
RabbitBodyBinder(RabbitMessageSerDesRegistry serDesRegistry)	Default constructor.

Method Summary

Modifier and Type	Method	Description
io.micronaut.core.bind.ArgumentBinder.BindingResult<Object>	bind(io.micronaut.core.convert.ArgumentConversionContext<Object> context, RabbitConsumerState messageState)
Class<io.micronaut.messaging.annotation.MessageBody>	getAnnotationType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.core.bind.ArgumentBinder

createSpecific

Constructor Details

RabbitBodyBinder

public RabbitBodyBinder(RabbitMessageSerDesRegistry serDesRegistry)

Default constructor.

Parameters:

serDesRegistry - The registry to get a deserializer

Method Details

getAnnotationType

public Class<io.micronaut.messaging.annotation.MessageBody> getAnnotationType()

Specified by:

getAnnotationType in interface io.micronaut.core.bind.annotation.AnnotatedArgumentBinder<io.micronaut.messaging.annotation.MessageBody,Object,RabbitConsumerState>

bind

public io.micronaut.core.bind.ArgumentBinder.BindingResult<Object> bind(io.micronaut.core.convert.ArgumentConversionContext<Object> context,
 RabbitConsumerState messageState)

Specified by:

bind in interface io.micronaut.core.bind.ArgumentBinder<Object,RabbitConsumerState>