Package com.swiftmq.impl.jms.standard.v750

Class AsyncMessageProcessor

MessageProcessor
com.swiftmq.impl.jms.standard.v750.AsyncMessageProcessor
public class AsyncMessageProcessor extends MessageProcessor

  • Constructor Details

    • AsyncMessageProcessor

      public AsyncMessageProcessor(Session session, SessionContext ctx, Consumer consumer, int consumerCacheSize, int recoveryEpoche)

  • Method Details

    • getMaxBulkSize

      public long getMaxBulkSize()

    • setMaxBulkSize

      public void setMaxBulkSize(long maxBulkSize)

    • getConsumerCacheSize

      public int getConsumerCacheSize()

    • setConsumerCacheSize

      public void setConsumerCacheSize(int consumerCacheSize)

    • isValid

      public boolean isValid()

    • stop

      public void stop()

    • reset

      public void reset()

    • processMessages

      public void processMessages(int numberMessages)

    • processMessage

      public void processMessage(MessageEntry messageEntry)

    • processException

      public void processException(Exception exception)

    • isStarted

      public boolean isStarted()

    • register

      public void register()

    • run

      public void run()

    • getDescription

      public String getDescription()

    • getDispatchToken

      public String getDispatchToken()