io.micronaut.pulsar.events

Class ConsumerSubscriptionFailedEvent

java.lang.Object

io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

All Implemented Interfaces:

PulsarFailureEvent

public final class ConsumerSubscriptionFailedEvent
extends java.lang.Object
implements PulsarFailureEvent

Raise error event on failed subscription. Gives more flexibility than throwing exceptions. Developers decide how to handle problems with Pulsar connections.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor and Description
ConsumerSubscriptionFailedEvent(java.lang.Throwable sourceError, java.lang.String consumerName)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getConsumerName()
java.lang.String	getReason()
java.util.Optional<java.lang.Throwable>	getSourceError()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerSubscriptionFailedEvent

public ConsumerSubscriptionFailedEvent(java.lang.Throwable sourceError,
                                       java.lang.String consumerName)

Method Detail

getSourceError

public java.util.Optional<java.lang.Throwable> getSourceError()

getConsumerName

public java.lang.String getConsumerName()

getReason

public java.lang.String getReason()

Specified by:

getReason in interface PulsarFailureEvent