Collector & Processor: Data processing and message queue are fully working