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
JSF backing bean for monitoring and managing the viewer's internal message queue.
See Also:

  • Constructor Details

    • MessageQueueBean

      public MessageQueueBean()
      Creates a new MessageQueueBean instance.

    • MessageQueueBean

      public MessageQueueBean(MessageQueueManager broker)
      Creates a new MessageQueueBean instance.
      Parameters:
      broker - message queue manager to use

  • Method Details

    • init

      @PostConstruct public void init()
      init.

    • close

      @PreDestroy public void close()
      close.
      Throws:
      JMSException - if any.

    • getQueueContent

      public Map<String,Integer> getQueueContent()
      getQueueContent.
      Returns:
      a map of queue names to their current message counts

    • 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 of all currently active ViewerMessage objects in the queue

    • getQueryMessages

      public List<ViewerMessage> getQueryMessages(String messageType)
      getQueryMessages.
      Parameters:
      messageType - message type to filter by
      Returns:
      List

    • removeMessagesFromQueue

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

    • deleteMessage

      public void deleteMessage(ViewerMessage ticket)
      Deletes a single message from the queue.
      Parameters:
      ticket - message to delete from queue

    • getMessageType

      public String getMessageType()
      Getter for the field messageType.
      Returns:
      the message type currently used as filter

    • setMessageType

      public void setMessageType(String messageType)
      Setter for the field messageType.
      Parameters:
      messageType - message type to set as filter

    • isMessageBrokerStart

      public boolean isMessageBrokerStart()
      isMessageBrokerStart.
      Returns:
      true if the message broker has been started, false otherwise

    • isPaused

      public boolean isPaused()
      isPaused.
      Returns:
      true if message queue processing is currently paused, false otherwise

    • getLazyModelViewerHistory

      public TableDataProvider<ViewerMessage> getLazyModelViewerHistory()
      Getter for the field lazyModelViewerHistory.
      Returns:
      the TableDataProvider for the viewer message history

    • updateMessageQueueState

      public void updateMessageQueueState()
      updateMessageQueueState.

    • getListeners

      public List<DefaultQueueListener> getListeners()
      getListeners.
      Returns:
      a list of active message queue listeners registered with the message broker

    • restartAllListeners

      public void restartAllListeners()
      restartAllListeners.

    • getMessageQueueState

      public MessageQueueBean.MessageQueueState getMessageQueueState()