Class ReferenceIDSupplier

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.mirror.ReferenceIDSupplier
All Implemented Interfaces:
org.apache.activemq.artemis.utils.collections.NodeStoreFactory<org.apache.activemq.artemis.core.server.MessageReference>
public class ReferenceIDSupplier extends Object implements org.apache.activemq.artemis.utils.collections.NodeStoreFactory<org.apache.activemq.artemis.core.server.MessageReference>
Since Artemis 2.30.0 this is supplying a new NodeStore per queue. It is also parsing MessageReference and Message for the proper ID for the messages.
Since:
2.30.0

  • Constructor Details

    • ReferenceIDSupplier

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

  • Method Details

    • newNodeStore

      public org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference> newNodeStore()
      This will return the NodeStore that will be used by the Queue.
      Specified by:
      newNodeStore in interface org.apache.activemq.artemis.utils.collections.NodeStoreFactory<org.apache.activemq.artemis.core.server.MessageReference>

    • getDefaultNodeID

      public String getDefaultNodeID()

    • getServerID

      public String getServerID(org.apache.activemq.artemis.core.server.MessageReference element)

    • getServerID

      public String getServerID(Message message)

    • getID

      public long getID(org.apache.activemq.artemis.core.server.MessageReference element)

    • getID

      public Long getID(Message message)