Uploaded image for project: 'Kogito'
  1. Kogito
  2. KOGITO-3422

CloudEvent Dispatcher + Muxer

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Unresolved
    • Icon: Major Major
    • None
    • None
    • Core Engine
    • False
    • False
    • Undefined
    • ---
    • ---

      Dispatcher

      • Create a CloudEvent subscriber+publisher (i.e. a Processor) that will dispatch incoming CloudEvents to the relevant components.
      • Dispatching may be done using either
        (1) a EventBus channel and then using a subscription to that event bus channel in the relevant components (i.e. generated endpoints)
        (2) subscribe Application.java or Processes.java, RuleUnits.java etc. to the "global" channel, then manually invoking Process.start(), RuleUnits.fire() etc.
        (3) each component @Injects and subscribes the global Publisher<CloudEvent> and filters out the events based on the type
      • For this task it's better going with (3) as this is the most simplest way to move forward. We may further improve with more JIRAs

      Muxer

      • For this task it is better that each component @Injects and writes to a "global" CloudEventEmitter and sends data to it.

            Unassigned Unassigned
            evacchi Edoardo Vacchi (Inactive)
            Marian Macik Marian Macik
            Marian Macik Marian Macik
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated: