@Override
	public void close() {
		if (!active.get()) {
			return;
		}
		log.debug("Closing event stream |%s| ...", this);

		push(new ShutdownEvent());
		active.set(false);
		log.debug("Event stream |%s| was closed.", this);
	}
@Override
	public void close() {
		if (!active.get()) {
			return;
		}
		log.debug("Closing event stream |%s| ...", this);

		push(new ShutdownEvent());
		active.set(false);
		log.debug("Event stream |%s| was closed.", this);
	}
@ Override public void close ( ) { if ( ! active . get ( ) ) { return ; } log . debug ( "Closing event stream |%s| ..." , this ) ; push ( new ShutdownEvent ( ) ) ; active . set ( false ) ; log . debug ( "Event stream |%s| was closed." , this ) ; }
Close this event stream loop and waits for associated {@link EventStreamServlet} exit.
Close this event stream loop and waits for associated {