restart build

cip4 · Nov 12, 2024 · 1798743 · 1798743
1 parent 843b2d2
commit 1798743
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/src/test/java/org/cip4/bambi/core/AbstractDeviceTest.java b/src/test/java/org/cip4/bambi/core/AbstractDeviceTest.java
@@ -53,6 +53,7 @@
 import org.cip4.bambi.BambiTestDevice;
 import org.cip4.bambi.core.IDeviceProperties.EWatchFormat;
 import org.cip4.bambi.core.queues.QueueEntry;
+import org.cip4.bambi.core.queues.QueueProcessor;
 import org.cip4.jdflib.auto.JDFAutoQueueEntry.EnumQueueEntryStatus;
 import org.cip4.jdflib.core.AttributeName;
 import org.cip4.jdflib.core.ElementName;
@@ -259,9 +260,10 @@ public void testDoSynchMulti() throws Exception
 		final BambiTestDevice device = Mockito.spy(new BambiTestDevice());
 		device.setSynchronous(true);
 		when(device.getParallelSynch()).thenReturn(4);
+		QueueProcessor queueProcessor = device.getQueueProcessor();
 		for (int i = 0; i < 42; i++)
 		{
-			final JDFQueueEntry qe = device.getQueueProcessor().getQueue().appendQueueEntry();
+			final JDFQueueEntry qe = queueProcessor.getQueue().appendQueueEntry();
 			qe.setQueueEntryID("qe" + i);
 			qe.setQueueEntryStatus(EnumQueueEntryStatus.Waiting);
 			final JDFNode root = JDFNode.createRoot();
@@ -271,13 +273,13 @@ public void testDoSynchMulti() throws Exception
 		}
 		for (int i = 0; i < 1234; i++)
 		{
-			if (device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
+			if (queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
 			{
 				ThreadUtil.sleep(123);
 			}
 		}
-		assertEquals(0, device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Waiting));
-		assertNotEquals(0, device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Completed));
+		assertEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting));
+		assertNotEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Completed));
 	}
 
 	/**
@@ -289,9 +291,10 @@ public void testDoAsynchMulti() throws Exception
 		final BambiTestDevice device = Mockito.spy(new BambiTestDevice());
 		device.setSynchronous(false);
 		when(device.getParallelSynch()).thenReturn(4);
+		QueueProcessor queueProcessor = device.getQueueProcessor();
 		for (int i = 0; i < 42; i++)
 		{
-			final JDFQueueEntry qe = device.getQueueProcessor().getQueue().appendQueueEntry();
+			final JDFQueueEntry qe = queueProcessor.getQueue().appendQueueEntry();
 			qe.setQueueEntryID("qe" + i);
 			qe.setQueueEntryStatus(EnumQueueEntryStatus.Waiting);
 			final JDFNode root = JDFNode.createRoot();
@@ -301,13 +304,13 @@ public void testDoAsynchMulti() throws Exception
 		}
 		for (int i = 0; i < 1234; i++)
 		{
-			if (device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
+			if (queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting) > 0)
 			{
 				ThreadUtil.sleep(123);
 			}
 		}
-		assertEquals(0, device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Waiting));
-		assertNotEquals(0, device.getQueueProcessor().getQueue().numEntries(EnumQueueEntryStatus.Completed));
+		assertEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Waiting));
+		assertNotEquals(0, queueProcessor.getQueue().numEntries(EnumQueueEntryStatus.Completed));
 	}
 
 	/**