Uses of Class
fr.gouv.vitam.storage.offers.tape.exception.QueueException
-
-
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 voidWriteOrderCreator. 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 voidTapeCatalogServiceImpl. markReady(java.lang.String queueId)java.util.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 voidQueueRepositoryImpl. add(QueueMessageEntity queue)voidQueueRepositoryImpl. addIfAbsent(java.util.List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)longQueueRepositoryImpl. complete(java.lang.String queueId)java.util.Map<org.apache.commons.lang3.tuple.Pair<QueueState,QueueMessageType>,java.lang.Integer>QueueRepositoryImpl. countByStateAndType()count queue entries grouped by state & message typelongQueueRepositoryImpl. markError(java.lang.String queueMessageId)longQueueRepositoryImpl. 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)longQueueRepositoryImpl. remove(java.lang.String queueId)voidQueueRepositoryImpl. tryCancelIfNotStarted(java.util.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 voidQueueRepository. add(QueueMessageEntity queueMessageEntity)voidQueueRepository. addIfAbsent(java.util.List<QueryCriteria> criteria, QueueMessageEntity queueMessageEntity)longQueueRepository. complete(java.lang.String queueMessageId)Make QueueMessageEntity COMPLETEDlongQueueRepository. markError(java.lang.String queueMessageId)Mark queueEntity as ErrorlongQueueRepository. markReady(java.lang.String queueMessageId)Mark queueEntity as READYvoidTapeCatalogService. markReady(java.lang.String queueId)<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)java.util.Optional<TapeCatalog>TapeCatalogService. receive(org.bson.conversions.Bson inQuery)longQueueRepository. remove(java.lang.String queueMessageId)voidQueueRepository. tryCancelIfNotStarted(java.util.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 java.util.Optional<? extends ReadWriteOrder>TapeDriveOrderConsumer. consume(TapeDriveWorker driveWorker)java.util.Optional<? extends ReadWriteOrder>TapeDriveWorkerManager. consume(TapeDriveWorker driveWorker)java.util.Optional<? extends ReadWriteOrder>TapeDriveOrderProducer. produce(TapeDriveWorker driveWorker)java.util.Optional<? extends ReadWriteOrder>TapeDriveWorkerManager. produce(TapeDriveWorker driveWorker)
-