Spring Integration 2.2.3.RELEASE @ServiceActivator не вызывается

У меня есть устаревший код с этими версиями (версия Spring: 3.2.1.RELEASE и версия Spring Integration 2.2.3.RELEASE). Я хотел бы перенести все xml-конфигурации интеграции Spring в конфигурацию java. Перед тем, как начать миграцию, я провожу несколько тестов и борюсь с @ServiceActivator, который не работает. Мой пример:

@Configuration
@ImportResource("classpath*:integration-config.xml")
public static class IntegrationConfig {
    @Bean
    public MessageChannel queueChannel() {
        return new QueueChannel(5);
    }

    @Bean
    public MessageChannel pubSubChannel() {
        PublishSubscribeChannel publishSubscribeChannel = new PublishSubscribeChannel();
        publishSubscribeChannel.subscribe(new MessageHandler() {
            @Override
            public void handleMessage(Message<?> message) throws MessagingException {
                System.out.println("First handler :" + message.getPayload());
            }
        });

        publishSubscribeChannel.subscribe(new MessageHandler() {
            @Override
            public void handleMessage(Message<?> message) throws MessagingException {
                System.out.println("Second handler :" + message.getPayload());
            }
        });
     return publishSubscribeChannel;
    }
}

И :

@MessageEndpoint
public static class MessageEndpointDefintion {

    @ServiceActivator(inputChannel = "queueChannel")
    public void queueActivator(String payload) {
        System.out.println("Payload from queue : " + payload);
    }

    @ServiceActivator(inputChannel = "pubSubChannel")
    public void pubSubActivator(Message<String> message) {
        System.out.println("Payload from pub-sub :" + message.getPayload());
    }
}

Когда я отправляю сообщения по каналам, вызывается любой @ServiceActivator.

Как указано здесь:, добавление @EnableIntegration (доступного с версии 4 Spring Integration) может решить проблему, но в моем случае я использую версию 2.2.3, которая не предоставляет эту аннотацию. Если они предоставят эту аннотацию в этой версии, я думаю, мы сможем ее использовать, но как?

Другой вопрос: могу ли я обновить версию Spring Integration до 4 с той же версией Spring (3.2.1)? Спасибо

РЕДАКТИРОВАТЬ

Я называю свою конфигурацию так: AbstractApplicationContext context = new AnnotationConfigApplicationContext(IntegrationConfig.class); и пример теста:

PublishSubscribeChannel publishSubscribeChannel;
publishSubscribeChannel = (PublishSubscribeChannel) context.getBean("pubSubChannel", MessageChannel.class);
publishSubscribeChannel.send(MessageBuilder.withPayload("==PUB-SUB-CHANNEL== ").build());

И integration-config.xml:

<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd = "http://www.springframework.org/schema/c"
   xmlns:int = "http://www.springframework.org/schema/integration"
   xsi:schemaLocation = "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd">

<int:annotation-config/>

<xsd:element name = "annotation-config">
    <xsd:annotation>
        <xsd:documentation>
            Enables annotation support for Message Endpoints.
        </xsd:documentation>
    </xsd:annotation>
</xsd:element>