Class AckManager

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.mirror.AckManager
All Implemented Interfaces:
org.apache.activemq.artemis.core.server.ActiveMQComponent
public class AckManager extends Object implements org.apache.activemq.artemis.core.server.ActiveMQComponent

  • Constructor Summary

    Constructors
    Constructor
    Description
    AckManager(org.apache.activemq.artemis.core.server.ActiveMQServer server)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    ack(String nodeID, org.apache.activemq.artemis.core.server.Queue targetQueue, long messageID, org.apache.activemq.artemis.core.server.impl.AckReason reason, boolean allowRetry)
     
    void
    addRetry(String nodeID, org.apache.activemq.artemis.core.server.Queue queue, long messageID, org.apache.activemq.artemis.core.server.impl.AckReason reason)
     
    void
    beginRetry()
     
    void
    endRetry()
     
    boolean
    initRetry()
     
    boolean
    isStarted()
     
    void
    pause()
     
    void
    registerMirror(AMQPMirrorControllerTarget mirrorTarget)
     
    void
    reload(RecordInfo recordInfo)
     
    void
    retryAddress(SimpleString address, io.netty.util.collection.LongObjectHashMap<JournalHashMap<org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.server.Queue>> acksToRetry)
     
    int
    size()
     
    Map<SimpleString, io.netty.util.collection.LongObjectHashMap<JournalHashMap<org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.server.Queue>>>
    sortRetries()
     
    void
    start()
     
    void
    stop()
     
    void
    unregisterMirror(AMQPMirrorControllerTarget mirrorTarget)
     

    Methods inherited from class Object

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

    Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

    asyncStop

  • Constructor Details

    • AckManager

      public AckManager(org.apache.activemq.artemis.core.server.ActiveMQServer server)

  • Method Details

    • size

      public int size()

    • reload

      public void reload(RecordInfo recordInfo)

    • stop

      public void stop()
      Specified by:
      stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

    • pause

      public void pause()

    • isStarted

      public boolean isStarted()
      Specified by:
      isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

    • start

      public void start()
      Specified by:
      start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

    • beginRetry

      public void beginRetry()

    • endRetry

      public void endRetry()

    • initRetry

      public boolean initRetry()

    • registerMirror

      public void registerMirror(AMQPMirrorControllerTarget mirrorTarget)

    • unregisterMirror

      public void unregisterMirror(AMQPMirrorControllerTarget mirrorTarget)

    • sortRetries

      public Map<SimpleString, io.netty.util.collection.LongObjectHashMap<JournalHashMap<org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.server.Queue>>> sortRetries()

    • retryAddress

      public void retryAddress(SimpleString address, io.netty.util.collection.LongObjectHashMap<JournalHashMap<org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.persistence.impl.journal.codec.AckRetry, org.apache.activemq.artemis.core.server.Queue>> acksToRetry)

    • addRetry

      public void addRetry(String nodeID, org.apache.activemq.artemis.core.server.Queue queue, long messageID, org.apache.activemq.artemis.core.server.impl.AckReason reason)

    • ack

      public boolean ack(String nodeID, org.apache.activemq.artemis.core.server.Queue targetQueue, long messageID, org.apache.activemq.artemis.core.server.impl.AckReason reason, boolean allowRetry)