/**
     * Sets the URL of the API endpoint.
     * @param url The URL to set.
     */
    public void setUrl(final String url) {
        this.url = url;
    }

    /**
     * Sets the connection timeout.
     * @param connectionTimeout The connection timeout in milliseconds.
     */
    public void setConnectionTimeout(final Integer connectionTimeout) {
        this.connectionTimeout = connectionTimeout;
    }

  public void testSize_populated() {
    for (LoadingCache<Object, Object> cache : caches()) {
      // don't let the entries get GCed
      List<Entry<Object, Object>> unused = warmUp(cache);
      assertEquals(WARMUP_SIZE, cache.size());
      assertMapSize(cache.asMap(), WARMUP_SIZE);
      checkValidState(cache);
    }
  }

  public void testContainsKey_found() {

     *
     * @param crawlingInfo the crawling information entity to store
     * @throws FessSystemException if the crawling information is null
     */
    public void store(final CrawlingInfo crawlingInfo) {
        setupStoreCondition(crawlingInfo);

        crawlingInfoBhv.insertOrUpdate(crawlingInfo, op -> op.setRefreshPolicy(Constants.TRUE));

    }

    /**

     *
     * @param targetNodePath the target node path to set
     */
    public void setTargetNodePath(final String targetNodePath) {
        this.targetNodePath = targetNodePath;
    }

    /**
     * Sets the cache duration for XPathAPI instances.
     *
     * @param cacheDuration the cache duration in minutes
     */
    public void setCacheDuration(final long cacheDuration) {
        this.cacheDuration = cacheDuration;

    }

    @Override
    public void run() {
      while (true) {
        try {
          Thread.sleep(everyMillis);
        } catch (InterruptedException e) {
          // ok. just stop sleeping.
        }
        if (shouldStop) {
          break;
        }
        interruptee.interrupt();
      }
    }

    void stopInterrupting() {
      shouldStop = true;
    }
  }

 */
public class WitnessNotificationTest {

    private WitnessNotification notification;

    @BeforeEach
    void setUp() {
        notification = new WitnessNotification(WitnessEventType.CLIENT_MOVE, "TestResource");
    }

    @Test
    void testNotificationCreation() {
        assertEquals(WitnessEventType.CLIENT_MOVE, notification.getEventType());

    @Override
    protected void setUpChild() throws Exception {
        // Initialize and register TermRangeQueryCommand
        queryCommand = new TermRangeQueryCommand();
        queryCommand.register();
    }

    public void test_getQueryClassName() {
        assertEquals("TermRangeQuery", queryCommand.getQueryClassName());
    }

    public void test_execute_withInvalidQuery() {
        try {

    }

    @Override
    public void close() throws IOException {
        pipe.close();
    }

    @Override
    public void write(final int b) throws IOException {
        tmp[0] = (byte) b;
        write(tmp, 0, 1);
    }

    @Override
    public void write(final byte[] b) throws IOException {
        write(b, 0, b.length);
    }

    @Override

        assertEquals(6, packet.length);
    }

    @Test
    void writeTrailerWireFormatShouldReturnZero() {
        // Test that writeTrailerWireFormat always returns 0, as per its implementation.
        SessionRetargetResponsePacket packet = new SessionRetargetResponsePacket();
        assertEquals(0, packet.writeTrailerWireFormat(new byte[0], 0));
    }

    @Test
    void readTrailerWireFormatShouldReadSixBytesSuccessfully() throws IOException {

     */
    public int getVersion() {
        return version;
    }

    /**
     * Sets the witness protocol version.
     *
     * @param version the protocol version
     */
    public void setVersion(int version) {
        this.version = version;
    }

    /**
     * Gets the share name to monitor.
     *
     * @return the share name
     */
    public String getShareName() {