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 Details

    • ConsumerSubscriptionFailedEvent

      public ConsumerSubscriptionFailedEvent(Throwable sourceError, String consumerName)
  • Method Details