Platform Explorer / Nuxeo Platform LTS 2019 10.10

Extension point streamProcessor

Contribution Descriptors

Existing Contributions

Contributions are presented in the same order as the registration order on this extension point. This order is displayed before the contribution name, in brackets.

  • nuxeo-core-10.10-HF32.jar /OSGI-INF/retention-and-hold-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.core.security.RetentionExpiredAction" defaultConcurrency="1" defaultPartitions="1" logConfig="bulk" name="retentionExpired">
          <!-- continue on failure, because failure to expire retention doesn't give us an inconsistent state -->
          <policy continueOnFailure="true" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-platform-csv-export-10.10-HF21.jar /OSGI-INF/csv-export-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <!-- CSV exporter processor -->
        <streamProcessor class="org.nuxeo.ecm.platform.csv.export.action.CSVExportAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="csvExport">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
          <option name="produceImmediate">false</option>
        </streamProcessor>
      </extension>
  • nuxeo-platform-imaging-core-10.10-HF21.jar /OSGI-INF/imaging-bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.picture.recompute.RecomputeViewsAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="recomputeViews">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
          <option name="produceImmediate">false</option>
        </streamProcessor>
      </extension>
  • nuxeo-platform-audit-core-10.10-HF33.jar /OSGI-INF/nxaudit-service.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.audit.impl.StreamAuditWriter" defaultCodec="legacy" defaultConcurrency="1" defaultPartitions="1" enabled="true" logConfig="audit" name="auditLogWriter">
          <policy batchCapacity="25" batchThreshold="500ms" continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="AuditLogWriter"/>
        </streamProcessor>
      </extension>
  • nuxeo-core-bulk-10.10-HF33.jar /OSGI-INF/bulk-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <!-- SetProperty processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetPropertiesAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="setProperties">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- SetSystemProperty processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetSystemPropertiesAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="setSystemProperties">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- RemoveProxy processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.RemoveProxyAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="removeProxy">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- Trash processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.TrashAction" defaultConcurrency="1" defaultPartitions="1" logConfig="bulk" name="trash">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
      </extension>
  • nuxeo-automation-features-10.10-HF28.jar /OSGI-INF/bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.automation.core.operations.services.bulk.AutomationBulkAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="automation">
          <policy continueOnFailure="true" delay="1s" maxRetries="3" name="automation"/>
        </streamProcessor>
      </extension>
  • nuxeo-elasticsearch-core-10.10-HF32.jar /OSGI-INF/bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.elasticsearch.bulk.IndexAction" defaultConcurrency="2" defaultPartitions="4" enabled="true" logConfig="bulk" name="reindex">
          <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
          <!-- concurrency to build indexing requests -->
          <computation concurrency="2" name="index"/>
          <!-- concurrency to execute indexing requests -->
          <computation concurrency="2" name="bulkIndex"/>
          <computation concurrency="1" name="indexCompletion"/>
          <!-- optimal size of the elasticsearch bulk request -->
          <option name="esBulkSizeBytes">5242880</option>
          <!-- max number of actions in the elasticsearch bulk request -->
          <option name="esBulkActions">1000</option>
          <!-- flush elasticsearch bulk request interval -->
          <option name="flushIntervalSeconds">5</option>
        </streamProcessor>
    
      </extension>
  • nuxeo-thumbnail-10.10-HF18.jar /OSGI-INF/thumbnail-bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.thumbnail.action.RecomputeThumbnailsAction" defaultConcurrency="2" defaultPartitions="2" logConfig="bulk" name="recomputeThumbnails">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
          <option name="produceImmediate">false</option>
        </streamProcessor>
      </extension>