Fires an event with the {@link CaptureStatus}.
438588
public static <T> void fire(HasCameraCaptureHandlers source, CaptureStatus status) {
        CameraCaptureEvent event = new CameraCaptureEvent(status, null);
        source.fireEvent(event);
    }
349764
protected void notifyStatus(String event){
		BlockingQueue<String> eventsQueue = (LinkedBlockingQueue<String>)getServletContext().getAttribute("eventsQueue");
//		if (eventsQueue == null) eventsQueue = new LinkedBlockingQueue<String>();
//		getServletContext().setAttribute("eventsQueue", eventsQueue);
		
		try {
			eventsQueue.put(event);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}		
	}
711919
private void fireReceiveAllowedStateChangeEvent(boolean newState)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "fireReceiveAllowedStateChangeEvent", Boolean.valueOf(newState));

        MessageProcessor messageProcessor = getMessageProcessor();

        if (messageProcessor.getMessagingEngine().isEventNotificationEnabled())
        {
            // Build the message for the Notification

            String message =
                            nls.getFormattedMessage("NOTIFY_RECEIVE_ALLOWED_STATE_CHANGE_CWSIP0552",
                                                    new Object[] { getName(),
                                                                  getUuid().toString(),
                                                                  Boolean.valueOf(newState) },
                                                    null);

            // Build the properties for the Notification
            Properties props = new Properties();

            props.put(SibNotificationConstants.KEY_DESTINATION_NAME, getName());
            props.put(SibNotificationConstants.KEY_DESTINATION_UUID, getUuid().toString());

            if (newState)
                props.put(SibNotificationConstants.KEY_RECEIVE_ALLOWED_STATE,
                          SibNotificationConstants.RECEIVE_ALLOWED_TRUE);
            else
                props.put(SibNotificationConstants.KEY_RECEIVE_ALLOWED_STATE,
                          SibNotificationConstants.RECEIVE_ALLOWED_FALSE);

            // Now create the Event object to pass to the control adapter
            MPRuntimeEvent MPevent =
                            new MPRuntimeEvent(SibNotificationConstants.TYPE_SIB_MESSAGEPOINT_RECEIVE_ALLOWED_STATE,
                                            message,
                                            props);
            // Fire the event
            runtimeEventOccurred(MPevent);
        }
        else
        {
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                SibTr.debug(tc, "fireReceiveAllowedStateChangeEvent", "Event Notification is disabled, cannot fire event");
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "fireReceiveAllowedStateChangeEvent");
    }
822693
public static <T> void fire(HasCameraCaptureHandlers source, String errorMessage) {
        CameraCaptureEvent event = new CameraCaptureEvent(CaptureStatus.ERRORED, errorMessage);
        source.fireEvent(event);
    }
135506
protected synchronized void fireMPDChangeEvent(MPDChangeEvent.Event event) {
        MPDChangeEvent mce = new MPDChangeEvent(this, event);

        for (MPDChangeListener mcl : listeners) {
            mcl.mpdChanged(mce);
        }
    }
808751
synchronized void fireEvent(final Event<?> event) {
        final String eventType = event.getType();
        List<Event<?>> events = synchronizedEvents.get(eventType);
        if (null == events) {
            events = new ArrayList<>();
            synchronizedEvents.put(eventType, events);
        }

        events.add(event);
        setChanged();
        notifyListeners(event);
    }
865925
public void fireChange() {
        if (getNotification() && listeners != null) {
            EventObject event = new EventObject(this);
            for (int i = 0; i < listeners.size(); i++) {
                listeners.get(i).stateChanged(event);
            }
        }
    }
691750
private void fireEvent(RecorderEventImpl event) {
        eventSender.event = event;
        scheduler.submit(eventSender, PriorityQueueScheduler.INPUT_QUEUE);
    }
343444
public void fireTagParseEvent(TagParseEvent tpe)
	{
		for (int i = 0; i < tagParseListeners.size(); i++)
		{
			TagParseListener l = tagParseListeners.get(i);
			l.tagParsed(tpe);
		}
	}
428722
@LogExecTime
	public void fireEvent(String locator, String eventName)
	{
		jtCore.fireEvent(locator, eventName);
	}
490101
@Override
  public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    if (evt instanceof IdleStateEvent) {
      IdleStateEvent e = (IdleStateEvent) evt;
      if (e.state() == IdleState.READER_IDLE) {
        LOGGER.warn("Closing dead connection.");
        ctx.close();
        return;
      }
    }

    super.userEventTriggered(ctx, evt);
  }
562126
synchronized void statusUpdate(TaskStatus status) {
    setProgress(status.getProgress());
    this.runState = status.getRunState();
    this.stateString = status.getStateString();
    this.nextRecordRange = status.getNextRecordRange();

    setDiagnosticInfo(status.getDiagnosticInfo());
    
    if (status.getStartTime() > 0) {
      this.startTime = status.getStartTime(); 
    }
    if (status.getFinishTime() > 0) {
      setFinishTime(status.getFinishTime()); 
    }
    
    this.phase = status.getPhase();
    this.counters = status.getCounters();
    this.outputSize = status.outputSize;
  }
163684
public synchronized void setStatusAndNotify(final LauncherStatus newStatus) {
    LOG.log(Level.FINEST, "Set status: {0} -> {1}", new Object[] {this.status, newStatus});
    this.status = newStatus;
    this.notify();
  }
319063
protected void fireStateChanged() {
        Object[] listeners = LISTENER_LIST.getListenerList();

        // Process the listeners last to first, notifying
        // those that are interested in this event
        for (int i = listeners.length - 2; i >= 0; i -= 2) {
            if (listeners[i] == javax.swing.event.ChangeListener.class) {
                if (changeEvent == null) {
                    changeEvent = new javax.swing.event.ChangeEvent(this);
                }
                ((javax.swing.event.ChangeListener) listeners[i + 1]).stateChanged(changeEvent);
            }
        }
    }
1029427
public void fireEvent(final Event<?> event)
    {
        Scheduler.get().scheduleDeferred(new Scheduler.ScheduledCommand() {
            @Override
            public void execute() {
                bus.fireEventFromSource(event, dialog.getInterfaceModel().getId());
            }
        });

    }
497383
@Override
    public void fireEvent(String configName, Optional<String> valueOpt)
    {
        this.emitEvent(configName, valueOpt);
    }
485115
@EventHandler
    public void handle(ChargingStationStatusNotificationReceivedEvent event) {
        ChargingStation chargingStation = repository.findOne(event.getChargingStationId().getId());

        if (chargingStation != null) {
            chargingStation.setStatus(event.getStatusNotification().getStatus());
            repository.createOrUpdate(chargingStation);
        }
    }