Package org.saidone

Class AlfrescoNodeProcessorConfiguration

java.lang.Object
org.saidone.component.BaseComponent
org.saidone.AlfrescoNodeProcessorConfiguration
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware
@Configuration public class AlfrescoNodeProcessorConfiguration extends BaseComponent
Spring configuration that defines common beans used by the application such as the queue and the lists of asynchronous tasks.

  • Constructor Details

    • AlfrescoNodeProcessorConfiguration

      public AlfrescoNodeProcessorConfiguration()

  • Method Details

    • queue

      @Bean public LinkedBlockingQueue<String> queue()
      Queue used to pass node identifiers between collectors and processors.

    • nodeCollectors

      @Bean public LinkedList<CompletableFuture<Void>> nodeCollectors()
      Holder for asynchronous collector tasks.

    • nodeProcessors

      @Bean public LinkedList<CompletableFuture<Void>> nodeProcessors()
      Holder for asynchronous processor tasks.

    • processedNodesCounter

      @Bean public AtomicInteger processedNodesCounter()
      Counter of processed nodes shared across processors.

    • objectMapper

      @Bean public com.fasterxml.jackson.databind.ObjectMapper objectMapper()
      Jackson ObjectMapper for JSON serialization and deserialization.