kryo.register(double[].class);
        kryo.register(Float.class);
        kryo.register(float[].class);
        kryo.register(Boolean.class);
        kryo.register(boolean[].class);
        kryo.register(Byte.class);
        kryo.register(byte[].class);
        kryo.register(Short.class);
        kryo.register(short[].class);
        kryo.register(Character.class);
        kryo.register(char[].class);

            throw new RuntimeException();
          }
        };
    eventBus.register(subscriber);
    eventBus.post(EVENT);
  }

  public void testDeadEventForwarding() {
    GhostCatcher catcher = new GhostCatcher();
    bus.register(catcher);

    // A String -- an event for which no one has registered.
    bus.post(EVENT);

    List<DeadEvent> events = catcher.getEvents();

            throw new RuntimeException();
          }
        };
    eventBus.register(subscriber);
    eventBus.post(EVENT);
  }

  public void testDeadEventForwarding() {
    GhostCatcher catcher = new GhostCatcher();
    bus.register(catcher);

    // A String -- an event for which no one has registered.
    bus.post(EVENT);

    List<DeadEvent> events = catcher.getEvents();

    
    // Registration state
    private volatile WitnessRegistrationState state;
    private volatile long lastHeartbeat;
    private int flags;
    
    public enum WitnessRegistrationState {
        REGISTERING,
        REGISTERED,
        UNREGISTERING,
        FAILED,
        EXPIRED
    }
    
    public WitnessRegistration(String shareName, InetAddress serverAddress, 

          e2);
    }
  }

  /**
   * Registers all subscriber methods on {@code object} to receive events.
   *
   * @param object object whose subscriber methods should be registered.
   */
  public void register(Object object) {
    subscribers.register(object);
  }

  /**
   * Unregisters all subscriber methods on a registered {@code object}.
   *

    /**
     * Registers a scheduled job with the job manager.
     *
     * @param scheduledJob the scheduled job to register
     */
    public void register(final ScheduledJob scheduledJob) {
        final JobManager jobManager = ComponentUtil.getJobManager();
        jobManager.schedule(cron -> register(cron, scheduledJob));
    }

    /**
     * Registers a scheduled job with the specified cron scheduler.

                request.setFlags(registration.getFlags());

                WitnessRegisterResponse response = rpcClient.register(request);

                if (response != null && response.isSuccess()) {
                    registration.setState(WitnessRegistrationState.REGISTERED);
                    registration.setContextHandle(response.getContextHandle());

    }

    /**
     * Test registering same searcher multiple times.
     */
    @Test
    public void test_registerSameSearcherMultipleTimes() throws Exception {
        try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));
            final TestSearcher searcher = new TestSearcher(50);
            processor.register(searcher);

        // Get the queryProcessor that was registered in parent class
        queryProcessor = ComponentUtil.getComponent("queryProcessor");

        // Register all query commands needed for testing
        new TermQueryCommand().register();
        new MatchAllQueryCommand().register();
        new PhraseQueryCommand().register();
        new BooleanQueryCommand().register();
        new PrefixQueryCommand().register();

            }

            @Override
            public String getIndexDocumentUpdateIndex() {
                return documentUpdateIndex;
            }
        };

        // Register components
        ComponentUtil.register(searchEngineClient, "searchEngineClient");
        ComponentUtil.setFessConfig(fessConfig);
    }

    @Override
    protected void tearDown(TestInfo testInfo) throws Exception {