Package 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	Description
protected final com.mongodb.client.MongoCollection<org.bson.Document>	collection

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	add(QueueMessageEntity queue)
void	addIfAbsent(List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	complete(String queueId)	Make QueueMessageEntity COMPLETED
Map<org.apache.commons.lang3.tuple.Pair<QueueState,QueueMessageType>,Integer>	countByStateAndType()	count queue entries grouped by state & message type
long	initializeOnBootstrap()
long	markError(String queueMessageId)	Mark queueEntity as Error
long	markReady(String queueMessageId)	Mark queueEntity as READY
<T> Optional<T>	receive(QueueMessageType messageType)
<T> Optional<T>	receive(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)
long	remove(String queueId)
void	tryCancelIfNotStarted(List<QueryCriteria> criteria)

Methods inherited from class java.lang.Object

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

Field Details

collection

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

Constructor Details

QueueRepositoryImpl

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

Method Details

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

tryCancelIfNotStarted

public void tryCancelIfNotStarted(List<QueryCriteria> criteria)
                           throws QueueException

Specified by:

tryCancelIfNotStarted 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

countByStateAndType

public Map<org.apache.commons.lang3.tuple.Pair<QueueState,QueueMessageType>,Integer> countByStateAndType()
                                                                                                  throws QueueException

count queue entries grouped by state & message type

Returns:

number of queue entries by state & message type

Throws:

QueueException