public void send()

in src/main/java/org/apache/commons/scxml2/env/SimpleDispatcher.java [156:236]
74 lines of code
14 McCabe index (conditional complexity)

    public void send(final Map<String, SCXMLIOProcessor> ioProcessors, final String id, final String target,
            final String type, final String event, final Object data, final Object hints, final long delay) {
        if (log.isInfoEnabled()) {
            final String buf =
                    "send ( id: " + id +
                    ", target: " + target +
                    ", type: " + type +
                    ", event: " + event +
                    ", data: " + String.valueOf(data) +
                    ", hints: " + String.valueOf(hints) +
                    ", delay: " + delay +
                    ')';
            log.info(buf);
        }

        // We only handle the "scxml" type (which is the default too) and optionally the #_internal target

        if ((type != null) && !type.equalsIgnoreCase(SCXMLIOProcessor.SCXML_EVENT_PROCESSOR) && !type.equals(SCXMLIOProcessor.DEFAULT_EVENT_PROCESSOR)) {
            ioProcessors.get(SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR)
                    .addEvent(new EventBuilder(TriggerEvent.ERROR_EXECUTION, TriggerEvent.ERROR_EVENT).sendId(id).build());
            throw new ActionExecutionError(true, "<send>: Unsupported type - " + type);
        }
        final String originType = SCXMLIOProcessor.DEFAULT_EVENT_PROCESSOR;
        SCXMLIOProcessor ioProcessor;

        boolean internal = false;

        String origin = target;
        if (target == null) {
            ioProcessor = ioProcessors.get(SCXMLIOProcessor.SCXML_EVENT_PROCESSOR);
            origin = SCXMLIOProcessor.SCXML_EVENT_PROCESSOR;
        }
        else if (ioProcessors.containsKey(target)) {
            ioProcessor = ioProcessors.get(target);
            internal = SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR.equals(target);
        }
        else if (SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR.equals(target)) {
            ioProcessor = ioProcessors.get(SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR);
            internal = true;
        }
        else {
            if (target.startsWith(SCXMLIOProcessor.EVENT_PROCESSOR_ALIAS_PREFIX)) {
                ioProcessors.get(SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR).addEvent(
                        new EventBuilder(TriggerEvent.ERROR_COMMUNICATION, TriggerEvent.ERROR_EVENT)
                                .sendId(id).build());
                throw new ActionExecutionError(true, "<send>: Unavailable target - " + target);
            }
            ioProcessors.get(SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR).addEvent(
                    new EventBuilder(TriggerEvent.ERROR_EXECUTION, TriggerEvent.ERROR_EVENT)
                            .sendId(id).build());
            throw new ActionExecutionError(true, "<send>: Invalid or unsupported target - " + target);
        }

        if (event == null) {
            ioProcessors.get(SCXMLIOProcessor.INTERNAL_EVENT_PROCESSOR)
                    .addEvent(new EventBuilder(TriggerEvent.ERROR_EXECUTION, TriggerEvent.ERROR_EVENT).sendId(id).build());
            throw new ActionExecutionError(true, "<send>: Cannot send without event name");
        }
        final EventBuilder eventBuilder = new EventBuilder(event, TriggerEvent.SIGNAL_EVENT)
                .sendId(id)
                .data(data);
        if (!internal) {
            eventBuilder.origin(origin).originType(originType);
            if (SCXMLIOProcessor.PARENT_EVENT_PROCESSOR.equals(target)) {
                eventBuilder.invokeId(((ParentSCXMLIOProcessor)ioProcessor).getInvokeId());
            }
            if (delay > 0L) {
                // Need to schedule this one
                final Timer timer = new Timer(true);
                timer.schedule(new DelayedEventTask(id, eventBuilder.build(), ioProcessor), delay);
                timers.put(id, timer);
                if (log.isDebugEnabled()) {
                    log.debug("Scheduled event '" + event + "' with delay "
                            + delay + "ms, as specified by <send> with id '"
                            + id + "'");
                }
                return;
            }
        }
        ioProcessor.addEvent(eventBuilder.build());
    }