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
See Also:

  • Constructor Details

    • MessageQueueBean

      public MessageQueueBean()

    • MessageQueueBean

      public MessageQueueBean(MessageQueueManager broker)

  • Method Details

    • init

      @PostConstruct public void init()

    • close

      @PreDestroy public void close() throws javax.jms.JMSException
      Throws:
      javax.jms.JMSException

    • getQueueContent

      public Map<String,Integer> getQueueContent()

    • pauseQueue

      public void pauseQueue()

    • resumeQueue

      public void resumeQueue()

    • clearQueue

      public void clearQueue()

    • initMessageBrokerStart

      public void 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)
      Parameters:
      messageType -
      Returns:
      List

    • removeMessagesFromQueue

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

    • deleteMessage

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

    • getMessageType

      public String getMessageType()

    • setMessageType

      public void setMessageType(String messageType)

    • isMessageBrokerStart

      public boolean isMessageBrokerStart()

    • isPaused

      public boolean isPaused()

    • getLazyModelViewerHistory

      public TableDataProvider<ViewerMessage> getLazyModelViewerHistory()

    • updateMessageQueueState

      public void updateMessageQueueState()

    • getListeners

      public List<DefaultQueueListener> getListeners()

    • restartAllListeners

      public void restartAllListeners()