Шаг пользовательской обработки Spring интеграции

Мне нужно ввести этап обработки в весеннюю интеграцию примерно так:

import org.springframework.messaging.Message;

public class SomeDocumentProcessingStep {

    public Message<MyDocument> process(Message<MyDocument> myMessage) {
        // do some manipulations with message like providing new headers;
        return resultingMessage;
    }
}

Вопрос в том, как включить такой этап обработки в конфигурацию интеграции Spring? У меня что-то вроде этого:

<int:chain input-channel = "someInput" output-channel = "someOutput">
    <!--Here I want to use my processing step class -->
    <!--Chain contains other processing steps like transformations -->
</int:chain>

Один из способов сделать это, если с service-activator, но тогда мне нужно отправить новое сообщение вручную из моей службы. Что-то вроде этого:

public class SomeService {
    private final MessageChannel outputChannel;
    private final MessagingTemplate template;
    // constructor ommited
    public void distribute(Message<MyDocument> message) {
        // do my manipulations
        template.send(outputChannel, resultingMessage);
    }
}

И настройте его примерно так:

<int:service-activator input-channel = "someInput" ref = "someService" method = "distribute"/>

Но у меня такое ощущение, что это неправильный подход. Есть ли лучший способ сделать это внутри цепочки интеграции? Мне нужен этот настраиваемый шаг обработки, который будет в середине обработки сообщения. Для меня использования <int:header-enricher> недостаточно, так как он позволяет создавать заголовки один за другим. Я хочу делать это в одном классе.