Package com.swiftmq.impl.queue.standard.queue

Class MessageProcessorRegistry

java.lang.Object
com.swiftmq.impl.queue.standard.queue.MessageProcessorRegistry
public class MessageProcessorRegistry extends Object

  • Constructor Details

    • MessageProcessorRegistry

      public MessageProcessorRegistry()

  • Method Details

    • storeMessageProcessor

      public int storeMessageProcessor(MessageProcessor processor)

    • removeMessageProcessor

      public void removeMessageProcessor(MessageProcessor processor)

    • removeIf

      public void removeIf(Predicate<MessageProcessor> condition)

    • hasInterestedProcessor

      public boolean hasInterestedProcessor(MessageImpl message)

    • process

      public void process(Consumer<MessageProcessor> processorConsumer)

    • reset

      public void reset()