Uses of Class
fr.gouv.vitam.storage.offers.tape.exception.QueueException

Packages that use QueueException

Package	Description
fr.gouv.vitam.storage.offers.tape.cas
fr.gouv.vitam.storage.offers.tape.impl.catalog
fr.gouv.vitam.storage.offers.tape.impl.queue
fr.gouv.vitam.storage.offers.tape.spec
fr.gouv.vitam.storage.offers.tape.worker

Uses of QueueException in fr.gouv.vitam.storage.offers.tape.cas

Methods in fr.gouv.vitam.storage.offers.tape.cas that throw QueueException

Modifier and Type	Method	Description
void	WriteOrderCreator.sendMessageToQueue(WriteOrder message)

Uses of QueueException in fr.gouv.vitam.storage.offers.tape.impl.catalog

Methods in fr.gouv.vitam.storage.offers.tape.impl.catalog that throw QueueException

Modifier and Type	Method	Description
void	TapeCatalogServiceImpl.add(QueueMessageEntity queue)
void	TapeCatalogServiceImpl.addIfAbsent(java.util.List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	TapeCatalogServiceImpl.complete(java.lang.String queueId)
long	TapeCatalogServiceImpl.markError(java.lang.String queueMessageId)
long	TapeCatalogServiceImpl.markReady(java.lang.String queueId)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(QueueMessageType messageType)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(QueueMessageType messageType, boolean usePriority)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType, boolean usePriority)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType)
<T> java.util.Optional<T>	TapeCatalogServiceImpl.receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType, boolean usePriority)
long	TapeCatalogServiceImpl.remove(java.lang.String queueId)

Uses of QueueException in fr.gouv.vitam.storage.offers.tape.impl.queue

Methods in fr.gouv.vitam.storage.offers.tape.impl.queue that throw QueueException

Modifier and Type	Method	Description
void	QueueRepositoryImpl.add(QueueMessageEntity queue)
void	QueueRepositoryImpl.addIfAbsent(java.util.List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	QueueRepositoryImpl.complete(java.lang.String queueId)
long	QueueRepositoryImpl.markError(java.lang.String queueMessageId)
long	QueueRepositoryImpl.markReady(java.lang.String queueMessageId)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(QueueMessageType messageType)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(QueueMessageType messageType, boolean usePriority)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType, boolean usePriority)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType)
<T> java.util.Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, org.bson.conversions.Bson inUpdate, QueueMessageType messageType, boolean usePriority)
long	QueueRepositoryImpl.remove(java.lang.String queueId)

Uses of QueueException in fr.gouv.vitam.storage.offers.tape.spec

Methods in fr.gouv.vitam.storage.offers.tape.spec that throw QueueException

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

Uses of QueueException in fr.gouv.vitam.storage.offers.tape.worker

Methods in fr.gouv.vitam.storage.offers.tape.worker that throw QueueException

Modifier and Type	Method	Description
java.util.Optional<? extends ReadWriteOrder>	TapeDriveOrderConsumer.consume(TapeDriveWorker driveWorker)
java.util.Optional<? extends ReadWriteOrder>	TapeDriveWorkerManager.consume(TapeDriveWorker driveWorker)
void	TapeDriveWorkerManager.enqueue(QueueMessageEntity entity)
java.util.Optional<? extends ReadWriteOrder>	TapeDriveOrderProducer.produce(TapeDriveWorker driveWorker)
java.util.Optional<? extends ReadWriteOrder>	TapeDriveWorkerManager.produce(TapeDriveWorker driveWorker)