Class RedisBinderRegistry

java.lang.Object

io.micronaut.configuration.lettuce.pubsub.bind.RedisBinderRegistry

All Implemented Interfaces:

io.micronaut.core.bind.ArgumentBinderRegistry<RedisListenerMessage>

@Singleton
public class RedisBinderRegistry
extends Object
implements io.micronaut.core.bind.ArgumentBinderRegistry<RedisListenerMessage>

Resolves binders for Redis Pub/Sub listener arguments.

Since:

7.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor	Description
RedisBinderRegistry(RedisBodyBinder bodyBinder, RedisChannelBinder channelBinder, RedisMessageBinder messageBinder)

Method Summary

Modifier and Type	Method	Description
<T> Optional<io.micronaut.core.bind.ArgumentBinder<T, RedisListenerMessage>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument)
<T> Optional<io.micronaut.core.bind.ArgumentBinder<T, RedisListenerMessage>>	findArgumentBinder(io.micronaut.core.type.Argument<T> argument, RedisListenerMessage source)

Methods inherited from class Object

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

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

addArgumentBinder, addRequestArgumentBinder

Constructor Details

RedisBinderRegistry

public RedisBinderRegistry(RedisBodyBinder bodyBinder,
 RedisChannelBinder channelBinder,
 RedisMessageBinder messageBinder)

Parameters:

bodyBinder - The body binder

channelBinder - The channel binder

messageBinder - The full message binder

Method Details

findArgumentBinder

public <T>
Optional<io.micronaut.core.bind.ArgumentBinder<T, RedisListenerMessage>> findArgumentBinder(io.micronaut.core.type.Argument<T> argument)

Specified by:

findArgumentBinder in interface io.micronaut.core.bind.ArgumentBinderRegistry<RedisListenerMessage>

findArgumentBinder

public <T>
Optional<io.micronaut.core.bind.ArgumentBinder<T, RedisListenerMessage>> findArgumentBinder(io.micronaut.core.type.Argument<T> argument,
 RedisListenerMessage source)

Specified by:

findArgumentBinder in interface io.micronaut.core.bind.ArgumentBinderRegistry<RedisListenerMessage>