Package io.goobi.viewer.managedbeans

Class MessageQueueBean

java.lang.Object
io.goobi.viewer.managedbeans.MessageQueueBean
All Implemented Interfaces:
Serializable
@Named @ApplicationScoped public class MessageQueueBean extends Object implements Serializable

MessageQueueBean class.

See Also:

  • Constructor Details

    • MessageQueueBean

      public MessageQueueBean()

      Constructor for MessageQueueBean.

    • MessageQueueBean

      public MessageQueueBean(MessageQueueManager broker)

      Constructor for MessageQueueBean.

      Parameters:
      broker - a MessageQueueManager object

  • Method Details

    • init

      @PostConstruct public void init()

      init.

    • close

      @PreDestroy public void close() throws jakarta.jms.JMSException

      close.

      Throws:
      jakarta.jms.JMSException - if any.

    • getQueueContent

      public Map<String,Integer> getQueueContent()

      getQueueContent.

      Returns:
      a Map object

    • getTotalMessagesInQueueCount

      public int getTotalMessagesInQueueCount()

    • pauseQueue

      public void pauseQueue()

      pauseQueue.

    • resumeQueue

      public void resumeQueue()

      resumeQueue.

    • clearQueue

      public void clearQueue()

      clearQueue.

    • initMessageBrokerStart

      public void initMessageBrokerStart()

      initMessageBrokerStart.

    • getActiveQueryMesssages

      public List<ViewerMessage> getActiveQueryMesssages()
      Get a list of all active messages in the goobi_slow queue.
      Returns:
      List

    • getQueryMessages

      public List<ViewerMessage> getQueryMessages(String messageType)

      getQueryMessages.

      Parameters:
      messageType - a String object
      Returns:
      List

    • removeMessagesFromQueue

      public void removeMessagesFromQueue(String type)
      Remove all active messages of a given type from the queue.
      Parameters:
      type - a String object

    • deleteMessage

      public void deleteMessage(ViewerMessage ticket)
      Delete a single message from the queue
      Parameters:
      ticket - a ViewerMessage object

    • getMessageType

      public String getMessageType()

      Getter for the field messageType.

      Returns:
      a String object

    • setMessageType

      public void setMessageType(String messageType)

      Setter for the field messageType.

      Parameters:
      messageType - a String object

    • isMessageBrokerStart

      public boolean isMessageBrokerStart()

      isMessageBrokerStart.

      Returns:
      a boolean

    • isPaused

      public boolean isPaused()

      isPaused.

      Returns:
      a boolean

    • getLazyModelViewerHistory

      public TableDataProvider<ViewerMessage> getLazyModelViewerHistory()

      Getter for the field lazyModelViewerHistory.

      Returns:
      a TableDataProvider object

    • updateMessageQueueState

      public void updateMessageQueueState()

      updateMessageQueueState.

    • getListeners

      public List<DefaultQueueListener> getListeners()

      getListeners.

      Returns:
      a List object

    • restartAllListeners

      public void restartAllListeners()

      restartAllListeners.

    • getMessageQueueState

      public MessageQueueBean.MessageQueueState getMessageQueueState()