Class RedisListenerException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.micronaut.messaging.exceptions.MessagingException

io.micronaut.messaging.exceptions.MessageListenerException

io.micronaut.configuration.lettuce.pubsub.exception.RedisListenerException

All Implemented Interfaces:

Serializable

public class RedisListenerException
extends io.micronaut.messaging.exceptions.MessageListenerException

Exception thrown when an error occurs processing a Redis Pub/Sub message.

Since:

7.0

Author:

Graeme Rocher

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RedisListenerException(String message, Throwable cause, Object listener, @Nullable RedisMessage redisMessage, String channel)

Method Summary

Modifier and Type	Method	Description
String	getMessageChannel()
Object	getRedisListener()
Optional<RedisMessage>	getRedisMessage()

Methods inherited from class Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class Object

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

Constructor Details

RedisListenerException

public RedisListenerException(String message,
 Throwable cause,
 Object listener,
 @Nullable RedisMessage redisMessage,
 String channel)

Parameters:

message - The message

cause - The cause

listener - The listener bean

redisMessage - The Redis message

channel - The configured message channel

Method Details

getRedisListener

public Object getRedisListener()

Returns:

The listener bean

getRedisMessage

public Optional<RedisMessage> getRedisMessage()

Returns:

The Redis message, if available

getMessageChannel

public String getMessageChannel()

Returns:

The configured message channel