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.markReady(String queueId)
Optional<TapeCatalog>	TapeCatalogServiceImpl.receive(org.bson.conversions.Bson inQuery)

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(List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	QueueRepositoryImpl.complete(String queueId)
Map<org.apache.commons.lang3.tuple.Pair<QueueState,QueueMessageType>,Integer>	QueueRepositoryImpl.countByStateAndType()	count queue entries grouped by state & message type
long	QueueRepositoryImpl.markError(String queueMessageId)
long	QueueRepositoryImpl.markReady(String queueMessageId)
<T> Optional<T>	QueueRepositoryImpl.receive(QueueMessageType messageType)
<T> Optional<T>	QueueRepositoryImpl.receive(QueueMessageType messageType, boolean usePriority)
<T> Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType)
<T> Optional<T>	QueueRepositoryImpl.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType, boolean usePriority)
long	QueueRepositoryImpl.remove(String queueId)
void	QueueRepositoryImpl.tryCancelIfNotStarted(List<QueryCriteria> criteria)

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(List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)
long	QueueRepository.complete(String queueMessageId)	Make QueueMessageEntity COMPLETED
long	QueueRepository.markError(String queueMessageId)	Mark queueEntity as Error
long	QueueRepository.markReady(String queueMessageId)	Mark queueEntity as READY
void	TapeCatalogService.markReady(String queueId)
<T> Optional<T>	QueueRepository.receive(QueueMessageType messageType)
<T> Optional<T>	QueueRepository.receive(QueueMessageType messageType, boolean usePriority)
<T> Optional<T>	QueueRepository.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType)
<T> Optional<T>	QueueRepository.receive(org.bson.conversions.Bson inQuery, QueueMessageType messageType, boolean usePriority)
Optional<TapeCatalog>	TapeCatalogService.receive(org.bson.conversions.Bson inQuery)
long	QueueRepository.remove(String queueMessageId)
void	QueueRepository.tryCancelIfNotStarted(List<QueryCriteria> criteria)

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
Optional<? extends ReadWriteOrder>	TapeDriveOrderConsumer.consume(TapeDriveWorker driveWorker)
Optional<? extends ReadWriteOrder>	TapeDriveWorkerManager.consume(TapeDriveWorker driveWorker)
Optional<? extends ReadWriteOrder>	TapeDriveOrderProducer.produce(TapeDriveWorker driveWorker)
Optional<? extends ReadWriteOrder>	TapeDriveWorkerManager.produce(TapeDriveWorker driveWorker)