@@ -0,0 +1,2742 @@
+package org.axonframework.axonserver.connector.util;%0A%0Aimport io.axoniq.axonserver.grpc.MetaDataValue;%0Aimport io.axoniq.axonserver.grpc.ProcessingInstruction;%0Aimport io.axoniq.axonserver.grpc.ProcessingKey;%0Aimport org.junit.jupiter.api.*;%0A%0Aimport java.util.Collections;%0A%0Aimport static org.junit.jupiter.api.Assertions.*;%0A%0A/**%0A * Test class validating the %7B@link ProcessingInstructionHelper%7D.%0A *%0A * @author Steven van Beelen%0A */%0Aclass ProcessingInstructionHelperTest %7B%0A%0A    private static final long EXPECTED_VALUE = 1729L;%0A    private static final MetaDataValue TEST_META_DATA_VALUE = MetaDataValue.newBuilder()%0A                                                                           .setNumberValue(EXPECTED_VALUE)%0A                                                                           .build();%0A%0A    @Test%0A    void testPriorityDefaultsToZero() %7B%0A        assertEquals(0L, ProcessingInstructionHelper.priority(Collections.emptyList()));%0A    %7D%0A%0A    @Test%0A    void testPriority() %7B%0A        ProcessingInstruction testProcessingInstruction =%0A                ProcessingInstruction.newBuilder()%0A                                     .setKey(ProcessingKey.PRIORITY)%0A                                     .setValue(TEST_META_DATA_VALUE)%0A                                     .build();%0A        assertEquals(EXPECTED_VALUE,%0A                     ProcessingInstructionHelper.priority(Collections.singletonList(testProcessingInstruction)));%0A    %7D%0A%0A    @Test%0A    void testNumberOfResultsDefaultsToZero() %7B%0A        assertEquals(1L, ProcessingInstructionHelper.numberOfResults(Collections.emptyList()));%0A    %7D%0A%0A    @Test%0A    void testNumberOfResults() %7B%0A        ProcessingInstruction testProcessingInstruction =%0A                ProcessingInstruction.newBuilder()%0A                                     .setKey(ProcessingKey.NR_OF_RESULTS)%0A                                     .setValue(TEST_META_DATA_VALUE)%0A                                     .build();%0A        assertEquals(EXPECTED_VALUE,%0A                     ProcessingInstructionHelper.numberOfResults(Collections.singletonList(testProcessingInstruction)));%0A    %7D%0A%0A    @Test%0A    void testTimeoutDefaultsToZero() %7B%0A        assertEquals(0L, ProcessingInstructionHelper.timeout(Collections.emptyList()));%0A    %7D%0A%0A    @Test%0A    void testTimeoutDefaults() %7B%0A        ProcessingInstruction testProcessingInstruction =%0A                ProcessingInstruction.newBuilder()%0A                                     .setKey(ProcessingKey.TIMEOUT)%0A                                     .setValue(TEST_META_DATA_VALUE)%0A                                     .build();%0A        assertEquals(EXPECTED_VALUE,%0A                     ProcessingInstructionHelper.timeout(Collections.singletonList(testProcessingInstruction)));%0A    %7D%0A%7D

Add tests