}

        @Test
        @DisplayName("Should get and set MID")
        void testMidProperty() {
            assertEquals(0, testMessage.getMid());
            testMessage.setMid(12345L);
            assertEquals(12345L, testMessage.getMid());
        }

        @Test
        @DisplayName("Should get and set async ID")
        void testAsyncIdProperty() {

      if (leftCode != rightCode) {
        return leftCode < rightCode ? -1 : 1;
      }

      // identityHashCode collision (rare, but not as rare as you'd think)
      int result = getUid(left).compareTo(getUid(right));
      if (result == 0) {
        throw new AssertionError(); // extremely, extremely unlikely.
      }
      return result;
    }

    @Override
    public String toString() {

                if (!repositories.isEmpty()) {
                    trackingData.add("Configured repositories:");
                    for (RemoteRepository r : repositories) {
                        trackingData.add(" - " + r.getId() + " : " + r.getUrl());
                    }
                } else {
                    trackingData.add("No repositories configured");
                }
            }

        assertEquals(1L, item1.getId());
        assertArrayEquals(new String[] { "a", "b" }, item1.getInputs());
        assertEquals("c", item1.getOutput());

        OptionalEntity<CharMappingItem> result2 = charMappingFile.get(2L);
        assertTrue(result2.isPresent());
        CharMappingItem item2 = result2.get();
        assertEquals(2L, item2.getId());

            }
            final FailureUrl failureUrl = storeFailureUrl(crawlerContext, urlQueue, errorName, t);
            if (failureUrl != null) {
                failureUrlId = failureUrl.getId();
            }
        } catch (final ContainerNotAvailableException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("container was destroyed.");
            }
            return;

        // Setup tree with configuration
        when(tree.getConfig()).thenReturn(config);
        when(tree.getSendBufferSize()).thenReturn(65536);
        when(config.getPid()).thenReturn(12345);
        when(config.getSendBufferSize()).thenReturn(65536);

        target = new SmbPipeHandleImpl(pipe);
    }

    @Test

                        logger.debug("Scheduled job is running: id={}", scheduledJob.getId());
                    }
                    counter.incrementAndGet();
                } else if (logger.isDebugEnabled()) {
                    logger.debug("Scheduled job is not running: id={}", scheduledJob.getId());
                }
            }
        });
        return counter.get();
    }

    /**

                return new ArrayList<>(); // Always return empty for fast tests
            }

            public String store(String sessionId, DataConfig dataConfig) {
                return sessionId + "-" + dataConfig.getId();
            }

            public void remove(String sessionCountId) {
                // No-op
            }
        }, "crawlingConfigHelper");

        final ScheduledJobService mockService = new ScheduledJobService() {
            @Override
            public OptionalEntity<ScheduledJob> getScheduledJob(final String id) {
                if (scheduledJob.getId().equals(id)) {
                    return OptionalEntity.of(scheduledJob);
                }
                return OptionalEntity.empty();
            }
        };

        assertNotNull(wagon, "Check wagon, protocol=" + protocol);
    }

    private final class ArtifactRepositoryLayoutStub implements ArtifactRepositoryLayout {
        @Override
        public String getId() {
            return "test";
        }

        @Override
        public String pathOfRemoteRepositoryMetadata(ArtifactMetadata metadata) {
            return "path";
        }

        @Override