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

Interface QueueRepository

All Known Subinterfaces:

TapeCatalogService

All Known Implementing Classes:

QueueRepositoryImpl, TapeCatalogRepository, TapeCatalogServiceImpl

public interface QueueRepository

Method Summary

Modifier and Type	Method and 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(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 queueMessageId)

Method Detail

add

void add(QueueMessageEntity queueMessageEntity)
  throws QueueException

Throws:

QueueException

addIfAbsent

void addIfAbsent(List<QueryCriteria> criteria,
                 QueueMessageEntity queueMessageEntity)
          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

receive

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

Throws:

QueueException

receive

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

Type Parameters:

T -

Parameters:

inQuery - filter

inUpdate - atomic update

messageType -

usePriority - if true sort by priority and take first

Returns:

Throws:

QueueException