Вам нужно показать больше трассировки стека по этому вопросу, потому что сейчас неясно, какова ваша настоящая проблема.
Также было бы здорово поделиться некоторым кодом, который у вас есть, и что вы хотели бы сделать в тестовом примере.
Чтобы проверить наличие сообщения в канале, вы можете настроить ChannelInterceptor
и реализовать его preSend()
.
Однако мы также предлагаем что-то вроде @SpringIntegrationTest
с особенностями MockIntegration
. Таким образом, вы можете заменить ваш реальный активатор службы некоторым MockIntegration.mockMessageHandler()
и выполнить проверку на нем.
Вам нужно будет настроить noAutoStartup
для упомянутой аннотации, не опрашивать каталог, пока вы не подготовите свой макет и не вызовете this.mockIntegrationContext.substituteMessageHandlerFor()
.
Подробнее см. В Справочном руководстве: https://docs.spring.io/spring-integration/docs/current/reference/html/testing.html#test-context
Попробуйте преобразовать его перед суммированием. например.
SELECT SUM(CONVERT(bigint, columnname)) FROM tablename
или
SELECT SUM(CAST(columnname AS BIGINT)) FROM tablename