lib/src/kbasesearchengine/events/ObjectEventQueue.java
public boolean load(final StoredStatusEvent event) {
        Utils.nonNull(event, "event");
        if (!event.getState().equals(StatusEventProcessingState.UNPROC)) {
            throw new IllegalArgumentException("Illegal state for loading event: " +
                    event.getState());
        }
        if (!isObjectLevelEvent(event)) {
            throw new IllegalArgumentException("Illegal type for loading event: " +
                    event.getEvent().getEventType());
        }
        if (!containedEvents.contains(event.getID())) {
            queue.add(event);
            containedEvents.add(event.getID());
            return true;
        }
        return false;
    }
/** Add a new {@link StatusEventProcessingState#UNPROC} event to the queue.
     * Events that already exist in the queue as determined by the event id are ignored.
     * Before any loaded events are added to the ready or processing states,
     * {@link #moveToReady()} must be called.
     * @param event the event to add.
     * @return true if the object was added to the queue, false if the event already existed in
     * the queue
     */
Add a new  StatusEventProcessingState#UNPROC event to the queue.
Events that already exist in the queue as determined by the event id are ignored.
Before any loaded events are added to the ready or processing states,
#moveToReady() must be called.
@param event the event to add.
@return true if the object was added to the queue, false if the event already existed in
the queue
Add a new StatusEventProcessingState#UNPROC event to the queue . Events that already exist in the queue as determined by the event id are ignored . Before any loaded events are added to the ready or processing states #moveToReady () must be called . @param event the event to add . @return true if the object was added to the queue false if the event already existed in the queue
public boolean load(final StoredStatusEvent event) {
        Utils.nonNull(event, "event");
        if (!event.getState().equals(StatusEventProcessingState.UNPROC)) {
            throw new IllegalArgumentException("Illegal state for loading event: " +
                    event.getState());
        }
        if (!isObjectLevelEvent(event)) {
            throw new IllegalArgumentException("Illegal type for loading event: " +
                    event.getEvent().getEventType());
        }
        if (!containedEvents.contains(event.getID())) {
            queue.add(event);
            containedEvents.add(event.getID());
            return true;
        }
        return false;
    }
public boolean load ( final StoredStatusEvent event ) { Utils . nonNull ( event , "event" ) ; if ( ! event . getState ( ) . equals ( StatusEventProcessingState . UNPROC ) ) { throw new IllegalArgumentException ( "Illegal state for loading event: " + event . getState ( ) ) ; } if ( ! isObjectLevelEvent ( event ) ) { throw new IllegalArgumentException ( "Illegal type for loading event: " + event . getEvent ( ) . getEventType ( ) ) ; } if ( ! containedEvents . contains ( event . getID ( ) ) ) { queue . add ( event ) ; containedEvents . add ( event . getID ( ) ) ; return true ; } return false ; }
Add a new {@link StatusEventProcessingState#UNPROC} event to the queue.
Add a new { @link StatusEventProcessingState#UNPROC } event to the queue .