}
}

private void handleWitnessEvent(WitnessNotification notification) {
    log.info("Handling witness event: {} for resource: {}", 
        notification.getEventType(), notification.getResourceName());
    
    switch (notification.getEventType()) {
        case RESOURCE_CHANGE:
            handleResourceChange(notification);
            break;
            
        case CLIENT_MOVE:

        assertTrue(listener.waitForNotification(1000));
        assertNotNull(listener.getLastNotification());
        assertEquals(WitnessEventType.CLIENT_MOVE, listener.getLastNotification().getEventType());

        client.close();
    }

    @Test
    void testUnregistration() throws Exception {
        // Setup successful registration

     * @param notification the notification to process
     */
    public void processNotification(WitnessNotification notification) {
        log.info("Received witness notification: {} for resource: {}", notification.getEventType(), notification.getResourceName());

        // Find registrations that match this notification
        for (Map.Entry<String, WitnessRegistration> entry : registrations.entrySet()) {

     */
    private void handleWitnessEvent(WitnessNotification notification) {
        log.info("Handling witness event: {} for resource: {}", notification.getEventType(), notification.getResourceName());

        switch (notification.getEventType()) {
        case RESOURCE_CHANGE:
            handleResourceChange(notification);
            break;

        case CLIENT_MOVE:

        source.put("_id", searchLogEvent.getId());
        // source.put("version_no", searchLogEvent.getVersionNo());
        source.put("event_type", searchLogEvent.getEventType());
        return source;
    }

    /**
     * Converts a map to lower hyphen case.
     *
     * @param source The source map.
     * @return The converted map.
     */

     */
    public CoreExtensions read(XmlPullParser parser, boolean strict) throws IOException, XmlPullParserException {
        CoreExtensions coreExtensions = null;
        int eventType = parser.getEventType();
        boolean parsed = false;
        while (eventType != XmlPullParser.END_DOCUMENT) {
            if (eventType == XmlPullParser.START_TAG) {
                if (strict && !"extensions".equals(parser.getName())) {

String getAttributeName(int); public String getAttributePrefix(int); public String getAttributeType(int); public boolean isAttributeDefault(int); public String getAttributeValue(int); public String getAttributeValue(String, String); public int getEventType() throws XmlPullParserExcepti; public void require(int, String, String) throws XmlPullParserExcepti, java.io.IOException; public void skipSubTree() throws XmlPullParserExcepti, java.io.IOException; public String nextText() throws XmlPullParserExcepti,...