private void update(
            Map<String, Object> externalIdMap, Map<String, Object> output, Status status)
            throws Exception {
        Map<String, Object> outputMap = new HashMap<>();

        outputMap.put("externalId", objectMapper.writeValueAsString(externalIdMap));
        outputMap.putAll(output);

        Message msg =
                new Message(
                        UUID.randomUUID().toString(),
                        objectMapper.writeValueAsString(outputMap),
                        null);
        ObservableQueue queue = queues.get(status);
        if (queue == null) {
            throw new IllegalArgumentException(
                    "There is no queue for handling " + status.toString() + " status");
        }
        queue.publish(Collections.singletonList(msg));
    }
Monitors and processes messages on the default event queues that Conductor listens on.

<p>The default event queue type is controlled using the property: <code>
conductor.default-event-queue.type</code>
core/src/main/java/com/netflix/conductor/core/events/queue/DefaultEventQueueProcessor.java