Package io.goobi.viewer.model.job.mq

Class GenerateCollectionArchivesMessageHandler

java.lang.Object

io.goobi.viewer.model.job.mq.GenerateCollectionArchivesMessageHandler

All Implemented Interfaces:

MessageHandler<MessageStatus>

public class GenerateCollectionArchivesMessageHandler
extends Object
implements MessageHandler<MessageStatus>

Scheduled dispatcher for per-collection BagIt archive generation. On each run it enumerates the configured collection fields, selects the eligible collections (top-level only, unless sub-collections are enabled in the configuration), and enqueues one TaskType.GENERATE_COLLECTION_ARCHIVE worker message per collection that has at least one enabled content type. It also prunes archive files on disk that no longer correspond to a live collection.

The actual (expensive) archive building happens in the worker handler on the dedicated archives queue, so this dispatcher only performs light-weight Solr faceting and message submission.

Constructor Summary

Constructors

Constructor	Description
GenerateCollectionArchivesMessageHandler()

Method Summary

Modifier and Type	Method	Description
MessageStatus	call(ViewerMessage message, MessageQueueManager queueManager)	Call this method to execute the ticket.
String	getMessageHandlerName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.goobi.viewer.controller.mq.MessageHandler

call, onStartup

Constructor Details

GenerateCollectionArchivesMessageHandler

public GenerateCollectionArchivesMessageHandler()

Method Details

call

public MessageStatus call(ViewerMessage message,
 MessageQueueManager queueManager)

Description copied from interface: MessageHandler

Call this method to execute the ticket.

Specified by:

call in interface MessageHandler<MessageStatus>

Parameters:

message - The ticket to handle

queueManager - reference to to manage the queue

Returns:

V

getMessageHandlerName

public String getMessageHandlerName()

Specified by:

getMessageHandlerName in interface MessageHandler<MessageStatus>