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: