Package io.micronaut.coherence.messaging.exceptions

Class CoherenceSubscriberException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.micronaut.messaging.exceptions.MessagingException

io.micronaut.messaging.exceptions.MessageListenerException

io.micronaut.coherence.messaging.exceptions.CoherenceSubscriberException

All Implemented Interfaces:

Serializable

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

Since:

1.0

Author:

Jonathan Knight

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CoherenceSubscriberException(String message, Object listener, com.tangosol.net.topic.Subscriber<?> kafkaConsumer, com.tangosol.net.topic.Subscriber.Element<?> element)	Creates a new exception.
CoherenceSubscriberException(String message, Throwable cause, Object listener, com.tangosol.net.topic.Subscriber<?> kafkaConsumer, com.tangosol.net.topic.Subscriber.Element<?> element)	Creates a new exception.
CoherenceSubscriberException(Throwable cause, Object listener, com.tangosol.net.topic.Subscriber<?> kafkaConsumer, com.tangosol.net.topic.Subscriber.Element<?> element)	Creates a new exception.

Method Summary

Modifier and Type	Method	Description
Optional<com.tangosol.net.topic.Subscriber.Element<?>>	getElement()
com.tangosol.net.topic.Subscriber<?>	getKafkaConsumer()
Object	getKafkaListener()

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.Object

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

Constructor Details

CoherenceSubscriberException

public CoherenceSubscriberException(String message,
 Object listener,
 com.tangosol.net.topic.Subscriber<?> kafkaConsumer,
 com.tangosol.net.topic.Subscriber.Element<?> element)

Creates a new exception.

Parameters:

message - The message

listener - The listener

kafkaConsumer - The consumer

element - The consumer record

CoherenceSubscriberException

public CoherenceSubscriberException(String message,
 Throwable cause,
 Object listener,
 com.tangosol.net.topic.Subscriber<?> kafkaConsumer,
 com.tangosol.net.topic.Subscriber.Element<?> element)

Creates a new exception.

Parameters:

message - The message

cause - The cause

listener - The listener

kafkaConsumer - The consumer

element - The consumer record

CoherenceSubscriberException

public CoherenceSubscriberException(Throwable cause,
 Object listener,
 com.tangosol.net.topic.Subscriber<?> kafkaConsumer,
 com.tangosol.net.topic.Subscriber.Element<?> element)

Creates a new exception.

Parameters:

cause - The cause

listener - The listener

kafkaConsumer - The consumer

element - The consumer record

Method Details

getKafkaListener

public Object getKafkaListener()

Returns:

The bean that is the kafka listener

getKafkaConsumer

public com.tangosol.net.topic.Subscriber<?> getKafkaConsumer()

Returns:

The consumer that produced the error

getElement

public Optional<com.tangosol.net.topic.Subscriber.Element<?>> getElement()

Returns:

The element that was being processed that caused the error