Class MessagingCdiExtension

  • All Implemented Interfaces:
    Extension

    public class MessagingCdiExtension
    extends Object
    implements Extension
    MicroProfile Reactive Messaging CDI Extension.
    • Constructor Detail

      • MessagingCdiExtension

        public MessagingCdiExtension()
    • Method Detail

      • channelsLiveness

        public Map<String,​Boolean> channelsLiveness()
        Get names of all channels accompanied by boolean if cancel or onError signal has been intercepted in it.
        Returns:
        map of channels
      • channelsReadiness

        public Map<String,​Boolean> channelsReadiness()
        Get names of all channels accompanied by boolean if onSubscribe signal has been intercepted in it.
        Returns:
        map of channels