/* (non-Javadoc)
@see com.smartfoxserver.v2.extensions.IServerEventHandler#handleServerEvent(com.smartfoxserver.v2.core.ISFSEvent)
774870
@Override
    public void handleServerEvent(ISFSEvent event) throws SFSException {
        Zone sfsZone = (Zone) event.getParameter(SFSEventParam.ZONE);
        User sfsUser = (User) event.getParameter(SFSEventParam.USER);
        User recipient = (User)event.getParameter(SFSEventParam.RECIPIENT);
        String message = (String)event.getParameter(SFSEventParam.MESSAGE);
        ISFSObject params = (ISFSObject)event.getParameter(SFSEventParam.OBJECT);
        ApiBuddyMessageImpl buddyMessage = new ApiBuddyMessageImpl();
        buddyMessage.setContent(message);
        buddyMessage.setSender((ApiBaseUser)sfsUser.getProperty(APIKey.USER));
        buddyMessage.setZone((ApiZone)sfsZone.getProperty(APIKey.ZONE));
        buddyMessage.setRecipient((ApiBaseUser)recipient.getProperty(APIKey.USER));
        notifyToHandlers(buddyMessage, params);
    }
539239
public function onKernelException(GetResponseForExceptionEvent $event)
    {
        if ($event->getException() instanceof InternalErrorException) {
            $this->handleInternalError($event);
        } else {
            $this->handleNativeError($event);
        }
    }
930101
public void handleDebugEvents(DebugEvent[] events)
	{
		if (view == null)
		{
			return;
		}

		for (int i = 0; i < events.length; ++i)
		{
			DebugEvent event = events[i];

			append(new VdmDebugLogItem(Messages.ItemType_Event, getDebugEventKind(event)
					+ " from " + event.getSource().getClass().getName()));//$NON-NLS-1$

			if (event.getKind() == DebugEvent.CREATE)
			{
				handleCreateEvent(event);
			} else if (event.getKind() == DebugEvent.MODEL_SPECIFIC
					&& event.getDetail() == ExtendedDebugEventDetails.DGBP_NEW_CONNECTION)
			{
				if (event.getSource() instanceof IDbgpDebugingEngine)
				{
					((IDbgpDebugingEngine) event.getSource()).addRawListener(this);
				}
			} else if (event.getKind() == DebugEvent.TERMINATE)
			{
				handleTerminateEvent(event);
			}
		}
	}
222206
@Override
    public void handleEvent(Event event) {
        LOG.fine("CustomInfoHandler called");

        if (customInfo != null) {
            event.getCustomInfo().putAll(customInfo);
        }
    }
1159355
@Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof HttpServerUpgradeHandler.UpgradeEvent) {
            HttpServerUpgradeHandler.UpgradeEvent upgradeEvent =
                    (HttpServerUpgradeHandler.UpgradeEvent) evt;
            onHeadersRead(ctx, 1, http1HeadersToHttp2Headers(upgradeEvent.upgradeRequest()), 0 , true);
        }
        super.userEventTriggered(ctx, evt);
    }
86319
public void handleEvent(Event event) {
        String topic = event.getTopic();
        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) {
            Tr.debug(tc, "Received event topic: " + topic);
        }
        HttpInboundLink link = event.getProperty(CallbackIDs.CALLBACK_HTTPICL.getName(), HttpInboundLink.class);
        if (null != link) {
            if (tc.isEventEnabled()) {
                Tr.event(tc, "Processing request on new thread; " + link);
            }
            link.ready(link.getVirtualConnection());
        } else {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
                Tr.event(tc, "Unable to process pipelined request with null link");
            }
        }
    }
584317
@Override protected void handleEvents(final String EVENT_TYPE) {
        super.handleEvents(EVENT_TYPE);
        if ("VISIBILITY".equals(EVENT_TYPE)) {
            Helper.enableNode(title, clock.isTitleVisible());
            Helper.enableNode(text, clock.isTextVisible());
            Helper.enableNode(dateText, clock.isDateVisible());
            Helper.enableNode(second, clock.isSecondsVisible());
        } else if ("FINISHED".equals(EVENT_TYPE)) {

        }
    }
431341
@Override
	public void handleEvent(String event, Map<ISFSEventParam, Object> params) {
		handleExtendedEvent(event, new SFSEvent(null, params));
	}
352171
public void setSystemEventHandler(final SystemEventHandler systemEventHandler) {
    if (systemEventSubscription != null) {
      systemEventSubscription.unsubscribe();
    }
    if (systemEventHandler != null) {
      systemEventSubscription = eventBus().get()
          .filter(evt -> evt.type().equals(EventType.SYSTEM))
          .subscribe(new Subscriber<CouchbaseEvent>() {
            @Override
            public void onCompleted() { /* Ignoring on purpose. */}

            @Override
            public void onError(Throwable e) { /* Ignoring on purpose. */ }

            @Override
            public void onNext(CouchbaseEvent evt) {
              systemEventHandler.onEvent(evt);
            }
          });
    }
  }
963761
public void handleDebugEvents(DebugEvent[] events)
	{
		for (int i = 0; i < events.length; i++)
		{
			DebugEvent event = events[i];
			if (event.getSource().equals(getProcess()))
			{

				if (event.getKind() == DebugEvent.TERMINATE)
				{
					closeStreams();
					DebugPlugin.getDefault().removeDebugEventListener(this);
				}

				resetName();
			}
		}
	}
134609
@EventHandler
    public void handle(ChargingStationOpeningTimesSetEvent event) {
        LOG.info("ChargingStationOpeningTimesSetEvent");

        ChargingStation chargingStation = getChargingStation(event.getChargingStationId());
        if (chargingStation != null) {
            chargingStation.setOpeningTimes(convertFromApiOpeningTimes(event.getOpeningTimes()));
            chargingStationRepository.createOrUpdate(chargingStation);
        }
    }
416216
void handleAgentCompleteEvent(AgentCompleteEvent event)
    {
        AsteriskAgentImpl agent = getAgentByAgentId(event.getChannel());
        if (agent == null)
        {
            logger.error("Ignored AgentCompleteEvent for unknown agent " + event.getChannel());
            return;
        }
        agent.updateState(AgentState.AGENT_IDLE);
    }
414923
@Override
  public synchronized void handleEvent(final Event event) {
    if (event.getType() == EventType.JOB_FINISHED && Status.FAILED
        .equals(event.getData().getStatus())) {
      this.value = this.value + 1;
    }
  }
652744
private void handleMembershipEvent(GroupMembershipEvent event) {
    post(new ClusterMembershipEvent(ClusterMembershipEvent.Type.valueOf(event.type().name()), event.member()));
  }
588375
@EventHandler
    public void handle(ComponentAvailabilityChangedToInoperativeEvent event) {
        updateComponentAvailability(event.getChargingStationId(), event.getComponentId(), event.getComponent(), Availability.INOPERATIVE);
    }
42933
public void handleControlMessage(SIBUuid8 sourceMEUuid, ControlMessage cMsg)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "handleControlMessage", new Object[]{sourceMEUuid, cMsg});
      
    InvalidOperationException e = new InvalidOperationException(
        nls.getFormattedMessage(
          "INTERNAL_MESSAGING_ERROR_CWSIP0001",
          new Object[] {
            "com.ibm.ws.sib.processor.impl.DurableInputHandler",
            "1:183:1.52.1.1" },
          null));
    
    // FFDC
    FFDCFilter.processException(
      e,
      "com.ibm.ws.sib.processor.impl.DurableInputHandler.handleControlMessage",
      "1:190:1.52.1.1",
      this);
      
    SibTr.exception(tc, e);
    SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0001",
      new Object[] {
        "com.ibm.ws.sib.processor.impl.DurableInputHandler",
        "1:197:1.52.1.1" });
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "handleControlMessage", e);
    throw e;
  }
701895
public void processEvent(EventObject event) {
    if (event instanceof RequestEvent) {
      processRequestEvent((RequestEvent) event);
    } else {
      LOG.error("invalid event type received: " + event.getClass().getName() + ": "
          + event.toString());
    }
  }