Операции и агрегатор

Question

Я видел код агрегатора и насколько я понимаю, это следующие опс:

добавить сообщение в группу , если группа может быть выпущены тогда: полной группы и отправить его выход/ответ канал если (истекают-группы) удалить группу и сообщения из хранилища сообщений еще удалить только сообщения

здесь мне нужно некоторое ACID поддержку транзакций, чтобы сделать все, или ничего, но после прочтения документации, я не мог» t найти, как это сделать. Не могли бы вы рассказать мне, если это возможно, и если да, то как я могу это достичь?

заранее спасибо

Regard Гусман

Answer 1

Вы можете сделать въездной (прямой) канал в агрегаторе транзакционного ...

<tx:advice id="txAdvice" transaction-manager="transactionManager"> 
    <tx:attributes> 
     <tx:method name="send" /> 
    </tx:attributes> 
</tx:advice> 

<aop:config> 
    <aop:pointcut id="aggTx" expression="execution(* *.send(..)) &amp;&amp; bean(toAggChannel)" /> 
    <aop:advisor advice-ref="txAdvice" pointcut-ref="aggTx" /> 
</aop:config> 

Это будет обрабатывать нормальную доставку и выпуск.

Чтобы сделать частичные группы с частичными транзакциями, используйте MessageGroupStoreReaper и сделайте метод MessageGroupStore.expireMessageGroups() транзакционным способом аналогичным образом.

В настоящее время вы не можете использовать частичные группы в транзакции при использовании group-timeout или group-timeout-expression.