Package io.micronaut.pulsar.events

Class ConsumerSubscriptionFailedEvent

java.lang.Object

io.micronaut.pulsar.events.ConsumerSubscriptionFailedEvent

All Implemented Interfaces:

PulsarFailureEvent

public final class ConsumerSubscriptionFailedEvent
extends 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	Description
ConsumerSubscriptionFailedEvent(Throwable sourceError, String consumerName)

Method Summary

Modifier and Type	Method	Description
String	getConsumerName()
String	getReason()
Optional<Throwable>	getSourceError()

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerSubscriptionFailedEvent

public ConsumerSubscriptionFailedEvent(Throwable sourceError,
 String consumerName)

Method Details

getSourceError

public Optional<Throwable> getSourceError()

getConsumerName

public String getConsumerName()

getReason

public String getReason()

Specified by:

getReason in interface PulsarFailureEvent