if (message.isSuccess()) {
                List<WitnessAsyncNotifyMessage.WitnessNotificationResponse> notifications = message.getNotifications();
                if (!notifications.isEmpty()) {
                    log.debug("Received {} notifications", notifications.size());
                    return notifications.get(0); // Return first notification
                }
            } else {

notify_webhook        publish bucket notifications to webhook endpoints
notify_amqp           publish bucket notifications to AMQP endpoints
notify_kafka          publish bucket notifications to Kafka endpoints
notify_mqtt           publish bucket notifications to MQTT endpoints
notify_nats           publish bucket notifications to NATS endpoints
notify_nsq            publish bucket notifications to NSQ endpoints

                }

            } catch (Exception e) {
                log.error("Failed to register for witness notifications", e);
                throw new RuntimeException(e);
            }
        });
    }

    /**
     * Unregisters from witness notifications.
     *
     * @param registration the registration to remove
     * @return a future that completes when unregistration is done

import java.util.concurrent.ConcurrentHashMap;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jcifs.internal.util.SMBUtil;
import jcifs.smb.SmbFile;

/**
 * Handles directory change notifications for SMB3 directory leasing
 */
public class DirectoryChangeNotifier {

    private static final Logger log = LoggerFactory.getLogger(DirectoryChangeNotifier.class);

    // Backoff and timing constants (in ms)

    assertWithMessage("Eviction notifications must be received")
        .that(removalListener.getCount())
        .isEqualTo(10);

    CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
    // ensure that no new notifications are sent
    assertWithMessage("Eviction notifications must be received")
        .that(removalListener.getCount())
        .isEqualTo(10);

        this.loc = loc;
    }

    /**
     * Returns the last modification date of this sitemap entry.
     * @return the last modification date
     */
    @Override
    public String getLastmod() {
        return lastmod;
    }

    /**
     * Sets the last modification date of this sitemap entry.
     * @param lastmod the last modification date to set
     */
    public void setLastmod(final String lastmod) {

            processNotificationBatch(batch);
        }
    }
    
    private void processNotificationBatch(List<WitnessNotification> notifications) {
        // Process multiple notifications together for efficiency
        for (WitnessNotification notification : notifications) {
            // Handle notification
        }
    }
}
```

## 10. Security Considerations

            // create
            newInputs = inputs;
            newOutputs = outputs;
        }
    }

    /**
     * Gets the new input words.
     * Returns a defensive copy to prevent external modification.
     *
     * @return The new input words (defensive copy).
     */
    public String[] getNewInputs() {
        return newInputs == null ? null : newInputs.clone();
    }

    /**

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs;

import java.util.List;
import java.util.concurrent.Callable;

/**
 * Handle for receiving change notifications from an SMB server
 *
 *
 * @author mbechler
 *
 */
public interface SmbWatchHandle extends AutoCloseable, Callable<List<FileNotifyInformation>> {

    /**
     * Get the next set of changes
     *

public final class RemovalListeners {

  private RemovalListeners() {}

  /**
   * Returns a {@code RemovalListener} which processes all eviction notifications using {@code
   * executor}.
   *
   * @param listener the backing listener
   * @param executor the executor with which removal notifications are asynchronously executed
   */
  public static <K, V> RemovalListener<K, V> asynchronous(