Uploaded image for project: 'Nuxeo Platform'
  1. Nuxeo Platform
  2. NXP-28356

Enable to register a Processor without running it

    XMLWordPrintable

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 11.1, 2021.0
    • Component/s: Streams
    • Tags:
    • Team:
      PLATFORM
    • Sprint:
      nxplatform 11.1.23, nxplatform 11.1.24
    • Story Points:
      0

      Description

      There are cases where a processor needs to be defined but not start/stop by the StreamService.
      For instance, an import processor can be registered and start/stop using a REST API.
      Another case is when having different processors that work together, we may want to initialized all the streams first and then control the order the processors are started.

      We can add start flag:

      <streamProcessor name="myProcessor" class="org.nuxeo.runtime.stream.tests.MyStreamProcessor" logConfig="default" start="false" >...

      Also, some a processor can use source or sink streams defined by other processor and in this case, we don't want to create conflict during initialization (streams being defined by both processor).
      We can add an external flag to the stream configuration:

      <streamProcessor name="myProcessor" class="org.nuxeo.runtime.stream.tests.MyStreamProcessor" logConfig="default">
   <stream name="externalOutput" external="true" />
   ...

        Attachments

          Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. NXP-29238 Enable to register a Processor without running it (10.10 Backport)

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved

          New Feature - A new feature of the product, which has yet to be developed. NXP-29361 Add an option to disable Stream Processing

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved

          Improvement - An improvement or enhancement to an existing feature or task. NXP-28086 Bulk Service should have an option to use an Elasticsearch scroller

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          is required by

          Improvement - An improvement or enhancement to an existing feature or task. NXP-28357 Bulk Service Processor should be contributed by configuration

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          Is referenced in

          [Captain Hook] PR for 10.10: #4143 PR for 10.10: #4143

          [Captain Hook] PR for master: #4294 PR for master: #4294

          [Captain Hook] PR for master: #4597 PR for master: #4597

            Activity

              People

              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0 minutes
                  0m
                  Logged:
                  Time Spent - 4 hours
                  4h