Package fr.gouv.vitam.storage.offers.tape.spec

Interface QueueRepository

All Known Implementing Classes:

QueueRepositoryImpl, TapeCatalogRepository

public interface QueueRepository

Method Summary

Modifier and Type	Method	Description
void	add(QueueMessageEntity queueMessageEntity)
void	addIfAbsent(List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	complete(String queueMessageId)	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(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 queueMessageId)
void	tryCancelIfNotStarted(List<QueryCriteria> criteria)

Method Details

add

void add(QueueMessageEntity queueMessageEntity)
  throws QueueException

Throws:

QueueException

addIfAbsent

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

Throws:

QueueException

tryCancelIfNotStarted

void tryCancelIfNotStarted(List<QueryCriteria> criteria)
                    throws QueueException

Throws:

QueueException

remove

long remove(String queueMessageId)
     throws QueueException

Throws:

QueueException

complete

long complete(String queueMessageId)
       throws QueueException

Make QueueMessageEntity COMPLETED

Parameters:

queueMessageId -

Returns:

Throws:

QueueException

markError

long markError(String queueMessageId)
        throws QueueException

Mark queueEntity as Error

Parameters:

queueMessageId -

Returns:

Throws:

QueueException

markReady

long markReady(String queueMessageId)
        throws QueueException

Mark queueEntity as READY

Parameters:

queueMessageId -

Returns:

Throws:

QueueException

initializeOnBootstrap

long initializeOnBootstrap()

receive

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

Throws:

QueueException

receive

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

Throws:

QueueException

receive

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

Throws:

QueueException

receive

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

Throws:

QueueException