fr.gouv.vitam.storage.offers.tape.impl.queue

Class QueueRepositoryImpl

java.lang.Object

fr.gouv.vitam.storage.offers.tape.impl.queue.QueueRepositoryImpl

All Implemented Interfaces:

QueueRepository

Direct Known Subclasses:

TapeCatalogRepository

public class QueueRepositoryImpl
extends Object
implements QueueRepository

Field Summary

Fields

Modifier and Type	Field and Description
protected com.mongodb.client.MongoCollection<org.bson.Document>	collection

Constructor Summary

Constructors

Constructor and Description
QueueRepositoryImpl(com.mongodb.client.MongoCollection<org.bson.Document> collection)

Method Summary

Modifier and Type	Method and Description
void	add(QueueMessageEntity queue)
void	addIfAbsent(List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	complete(String queueId) Make QueueMessageEntity COMPLETED
long	initializeOnBootstrap()
long	markError(String queueMessageId) Mark queueEntity as Error
long	markReady(String queueMessageId) Mark queueEntity as READY
<T> Optional<T>	receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType)
<T> Optional<T>	receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType, boolean usePriority)
<T> Optional<T>	receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType)
<T> Optional<T>	receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType, boolean usePriority)
<T> Optional<T>	receive(QueueMessageType messageType)
<T> Optional<T>	receive(QueueMessageType messageType, boolean usePriority)
long	remove(String queueId)

Methods inherited from class java.lang.Object

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

Field Detail

collection

protected final com.mongodb.client.MongoCollection<org.bson.Document> collection

Constructor Detail

QueueRepositoryImpl

public QueueRepositoryImpl(com.mongodb.client.MongoCollection<org.bson.Document> collection)

Method Detail

add

public void add(QueueMessageEntity queue)
         throws QueueException

Specified by:

add in interface QueueRepository

Throws:

QueueException

addIfAbsent

public void addIfAbsent(List<QueryCriteria> criteria,
                        QueueMessageEntity queueMessageEntity)
                 throws QueueException

Specified by:

addIfAbsent in interface QueueRepository

Throws:

QueueException

remove

public long remove(String queueId)
            throws QueueException

Specified by:

remove in interface QueueRepository

Throws:

QueueException

complete

public long complete(String queueId)
              throws QueueException

Description copied from interface: QueueRepository

Make QueueMessageEntity COMPLETED

Specified by:

complete in interface QueueRepository

Returns:

Throws:

QueueException

markError

public long markError(String queueMessageId)
               throws QueueException

Description copied from interface: QueueRepository

Mark queueEntity as Error

Specified by:

markError in interface QueueRepository

Returns:

Throws:

QueueException

markReady

public long markReady(String queueMessageId)
               throws QueueException

Description copied from interface: QueueRepository

Mark queueEntity as READY

Specified by:

markReady in interface QueueRepository

Returns:

Throws:

QueueException

initializeOnBootstrap

public long initializeOnBootstrap()

Specified by:

initializeOnBootstrap in interface QueueRepository

receive

public <T> Optional<T> receive(QueueMessageType messageType)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Throws:

QueueException

receive

public <T> Optional<T> receive(QueueMessageType messageType,
                               boolean usePriority)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Throws:

QueueException

receive

public <T> Optional<T> receive(org.bson.conversions.Bson inQuery,
                               QueueMessageType messageType)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Throws:

QueueException

receive

public <T> Optional<T> receive(org.bson.conversions.Bson inQuery,
                               QueueMessageType messageType,
                               boolean usePriority)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Throws:

QueueException

receive

public <T> Optional<T> receive(org.bson.conversions.Bson inQuery,
                               org.bson.conversions.Bson inUpdate,
                               QueueMessageType messageType)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Throws:

QueueException

receive

public <T> Optional<T> receive(org.bson.conversions.Bson inQuery,
                               org.bson.conversions.Bson inUpdate,
                               QueueMessageType messageType,
                               boolean usePriority)
                        throws QueueException

Specified by:

receive in interface QueueRepository

Parameters:

inQuery - filter

inUpdate - atomic update

usePriority - if true sort by priority and take first

Returns:

Throws:

QueueException