ArrayNotificationBuffer.java 文件源码

public NotificationResult
    fetchNotifications(NotificationBufferFilter filter,
                       long startSequenceNumber,
                       long timeout,
                       int maxNotifications)
        throws InterruptedException {
    NotificationBuffer buf = ArrayNotificationBuffer.this;
    return buf.fetchNotifications(filter, startSequenceNumber,
                                  timeout, maxNotifications);
}