class WriteOrderCreator extends QueueProcessor<WriteOrder> {

    @Override
    protected void processMessage(WriteOrder message) throws QueueProcessingException {
        try {
            sendMessageToQueue(message);
        } catch (Exception ex) {
            throw new QueueProcessingException(QueueProcessingException.RetryPolicy.RETRY,
                "Could not process message " + JsonHandler.unprettyPrint(message), ex);
        }
    }

    public  WriteOrderCreator(ArchiveReferentialRepository archiveReferentialRepository,
        QueueRepository readWriteQueue);

}