Class ReferenceNodeStore

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.mirror.ReferenceNodeStore
All Implemented Interfaces:
org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>
public class ReferenceNodeStore extends Object implements org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReferenceNodeStore(ReferenceIDSupplier idSupplier)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clear()
     
    long
    getID(org.apache.activemq.artemis.core.server.MessageReference element)
     
    String
    getName()
     
    org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference>
    getNode(String serverID, long id)
     
    String
    getServerID(Message message)
     
    String
    getServerID(org.apache.activemq.artemis.core.server.MessageReference element)
     
    void
    removeNode(org.apache.activemq.artemis.core.server.MessageReference element, org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference> node)
     
    org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>
    setName(String name)
     
    int
    size()
     
    void
    storeNode(org.apache.activemq.artemis.core.server.MessageReference element, org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference> node)
     
    String
    toString()
     

    Methods inherited from class Object

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

  • Constructor Details

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setName

      public org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference> setName(String name)
      Specified by:
      setName in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • getName

      public String getName()
      Specified by:
      getName in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • storeNode

      public void storeNode(org.apache.activemq.artemis.core.server.MessageReference element, org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference> node)
      Specified by:
      storeNode in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • removeNode

      public void removeNode(org.apache.activemq.artemis.core.server.MessageReference element, org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference> node)
      Specified by:
      removeNode in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • getNode

      public org.apache.activemq.artemis.utils.collections.LinkedListImpl.Node<org.apache.activemq.artemis.core.server.MessageReference> getNode(String serverID, long id)
      Specified by:
      getNode in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • 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)

    • clear

      public void clear()
      Specified by:
      clear in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>

    • size

      public int size()
      Specified by:
      size in interface org.apache.activemq.artemis.utils.collections.NodeStore<org.apache.activemq.artemis.core.server.MessageReference>