Всем привет, очередной геморой .
Значит задача:
Есть канал sender file.
Кладу несколько файлов в папку он их одновременно затягивает и создает несколько параллельных потоков.
Мне надо сделать adapter module которой будет сам все эти файлы считывать и обрабатывать в одном потоке, вопрос в том что я не знаю как вырубить в адаптере это параллельное считываете нескольких файлов. Единственное что пришло в голову так это указать в additional parameters параметр msecs, типо ждать перед каждой считкой каждого файла и как раз за это время в модуле всю папку считывать и удалять то что считал.

Спасибо за советы.

Думаю, что никак. Можно только накапливать файлы в IP.
А предложенным способом легко добьешься неконсистентности:
1) 1-ый файл (1 mess) попадает в твой модуль
2) считываешь и удаляешь последующие файлы в модуле
удалив некоторые файлы, может произойти сбой (например ошибка в сети)

Итого файлы потеряны безвозвратно, а 1-ый файл останется на месте, т.к. вызов модуля идет до записи сообщения в БД AE.