Package com.oracle.coherence.spring.messaging.exceptions

Class CoherenceSubscriberException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

com.oracle.coherence.spring.messaging.exceptions.CoherenceSubscriberException

All Implemented Interfaces:

Serializable

public class CoherenceSubscriberException
extends RuntimeException

Exception thrown for subscriber errors.

Since:

3.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()	Return the element that was being processed that caused the error.
com.tangosol.net.topic.Subscriber<?>	getKafkaConsumer()	Return the consumer that produced the error.
Object	getKafkaListener()	Return The bean that is the kafka listener.

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()

Return The bean that is the kafka listener.

Returns:

the bean that is the kafka listener

getKafkaConsumer

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

Return the consumer that produced the error.

Returns:

the consumer that produced the error

getElement

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

Return the element that was being processed that caused the error.

Returns:

the element that was being processed that caused the error