io.micronaut.configuration.kafka.bind

Class ConsumerRecordBinderRegistry

java.lang.Object

io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry

All Implemented Interfaces:

ArgumentBinderRegistry<ConsumerRecord<?,?>>

@Singleton
public class ConsumerRecordBinderRegistry
extends Object
implements ArgumentBinderRegistry<ConsumerRecord<?,?>>

A registry of ConsumerRecordBinder.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>... binders) Creates the registry for the given binders.

Method Summary

Modifier and Type	Method and Description
<T> Optional<ArgumentBinder<T,ConsumerRecord<?,?>>>	findArgumentBinder(Argument<T> argument, ConsumerRecord<?,?> source) Locate an ArgumentBinder for the given argument and source type.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordBinderRegistry

public ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>... binders)

Creates the registry for the given binders.

Parameters:

binders - The binders

Method Detail

findArgumentBinder

public <T> Optional<ArgumentBinder<T,ConsumerRecord<?,?>>> findArgumentBinder(Argument<T> argument,
                                                                              ConsumerRecord<?,?> source)

Description copied from interface: ArgumentBinderRegistry

Locate an ArgumentBinder for the given argument and source type.

Specified by:

findArgumentBinder in interface ArgumentBinderRegistry<ConsumerRecord<?,?>>

Type Parameters:

T - The argument type

Parameters:

argument - The argument

source - The source

Returns:

An Optional of ArgumentBinder