@Test(expected = QueueException.class) public void enqueue_ko() throws QueueException { QueueMessageEntity queueMessageEntity = mock(QueueMessageEntity.class); doThrow(new QueueException("")).when(queueRepository).add(any()); tapeDriveWorkerManager.enqueue(queueMessageEntity); }
public void enqueue(QueueMessageEntity entity) throws QueueException { this.readWriteQueue.add(entity); }
TapeDriveWorkerManager implements TapeDriveOrderConsumer, TapeDriveOrderProducer { public void enqueue(QueueMessageEntity entity) throws QueueException { this.readWriteQueue.add(entity); } }
TapeDriveWorkerManager implements TapeDriveOrderConsumer, TapeDriveOrderProducer { public void enqueue(QueueMessageEntity entity) throws QueueException { this.readWriteQueue.add(entity); } TapeDriveWorkerManager(
        QueueRepository readWriteQueue,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        TapeLibraryPool tapeLibraryPool,
        Map<Integer, TapeCatalog> driveTape, String inputTarPath, boolean forceOverrideNonEmptyCartridges,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); }
TapeDriveWorkerManager implements TapeDriveOrderConsumer, TapeDriveOrderProducer { public void enqueue(QueueMessageEntity entity) throws QueueException { this.readWriteQueue.add(entity); } TapeDriveWorkerManager(
        QueueRepository readWriteQueue,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        TapeLibraryPool tapeLibraryPool,
        Map<Integer, TapeCatalog> driveTape, String inputTarPath, boolean forceOverrideNonEmptyCartridges,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); void startWorkers(); void enqueue(QueueMessageEntity entity); void shutdown(); void shutdown(long timeout, TimeUnit timeUnit); @Override QueueRepository getQueue(); @Override Optional<? extends ReadWriteOrder> consume(TapeDriveWorker driveWorker); @Override synchronized Optional<? extends ReadWriteOrder> produce(TapeDriveWorker driveWorker); }
TapeDriveWorkerManager implements TapeDriveOrderConsumer, TapeDriveOrderProducer { public void enqueue(QueueMessageEntity entity) throws QueueException { this.readWriteQueue.add(entity); } TapeDriveWorkerManager(
        QueueRepository readWriteQueue,
        ArchiveReferentialRepository archiveReferentialRepository,
        ReadRequestReferentialRepository readRequestReferentialRepository,
        TapeLibraryPool tapeLibraryPool,
        Map<Integer, TapeCatalog> driveTape, String inputTarPath, boolean forceOverrideNonEmptyCartridges,
        ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy); void startWorkers(); void enqueue(QueueMessageEntity entity); void shutdown(); void shutdown(long timeout, TimeUnit timeUnit); @Override QueueRepository getQueue(); @Override Optional<? extends ReadWriteOrder> consume(TapeDriveWorker driveWorker); @Override synchronized Optional<? extends ReadWriteOrder> produce(TapeDriveWorker driveWorker);  }