トランザクションリスナを春に動的に登録しますか？

Question

私は現在進行中のトランザクションにトランザクションリスナーを追加したいspringframeworkアプリケーションを持っています。その動機は、下流のシステムに通知するポストコミットアクションを引き起こすことです。私はいくつかのサービスメソッドの周りにトランザクションをラップするために@Transactionalを使用しています。これはポストトランザクションリスナーを作成/登録する場所です。私は次のような "何か"をしたい。

public class MyService { 
@Transaction 
public void doIt() { 
    modifyObjects(); 

    // something like this 
    getTransactionManager().registerPostCommitAction(new 
    TransactionSynchronizationAdapter() { 
    public void afterCommit() { 
     notifyDownstream(); 
    } 
    }); 
} 
} 

Springには、私が欲しいと思うTransactionSynchronizationインターフェイスとアダプタクラスがあります。現行のトランザクションまたはトランザクション・マネージャのどちらに動的に登録するかはすぐには分かりません。私が避けることができれば、JtaTransactionManagerをサブクラス化しないでください。

Q：誰もこれまでにこれをしましたか？

Q：アダプターを登録する最も簡単な方法は何ですか？

Answer 1

あなたはこれを達成するために、あなたのサービスでaspect to matchトランザクションメソッドの側面を使用することができます。

@Aspect 
public class AfterReturningExample { 

    @AfterReturning("execution(* com.mypackage.MyService.*(..))") 
    public void afterReturning() { 
    // ... 
    } 

} 

Answer 2

実際にはハード、私は思ってませんでした。 springはスレッドコンテキストに '正しい'ものを入れる静的ヘルパークラスを持っています。ここで

TransactionSynchronizationManager.registerSynchronization(
    new TransactionSynchronizationAdapter() { 
     @Override 
     public void afterCommit() { 
      s_logger.info("TRANSACTION COMPLETE!!!"); 
     } 
    } 
); 

Answer 3

は、私は、トランザクションがコミットされた後に送られた私のメッセージを望んで（私はRabbitMQのTXを使用することもできましたが、それらは、むしろ遅い）という同様の問題のためにした、より完全なソリューションです。あなたが実際にあなたがコミットした後に何かをする方法を誰かが表示されますよう願っ

@Override 
public void postAfterCommit(Object o) { 
    Optional<MessageBusResourceHolder> holder = MessageBusTxUtils.getTransactionalResourceHolder(this); 
    if (holder.isPresent()) { 
     holder.get().addMessage(o); 
    } 
    else { 
     post(o, false); 
    } 
} 

長いったらしいコーディングサンプルのため申し訳ありませんが行いますメッセージを送る今すぐあなたのクラスで

public class MessageBusUtils { 
    public static Optional<MessageBusResourceHolder> getTransactionalResourceHolder(TxMessageBus messageBus) { 

     if (! TransactionSynchronizationManager.isActualTransactionActive()) { 
      return Optional.absent(); 
     } 

     MessageBusResourceHolder o = (MessageBusResourceHolder) TransactionSynchronizationManager.getResource(messageBus); 
     if (o != null) return Optional.of(o); 

     o = new MessageBusResourceHolder(); 
     TransactionSynchronizationManager.bindResource(messageBus, o); 
     o.setSynchronizedWithTransaction(true); 
     if (TransactionSynchronizationManager.isSynchronizationActive()) { 
      TransactionSynchronizationManager.registerSynchronization(new MessageBusResourceSynchronization(o, messageBus)); 
     } 
     return Optional.of(o); 

    } 

    private static class MessageBusResourceSynchronization extends ResourceHolderSynchronization<MessageBusResourceHolder, TxMessageBus> { 
     private final TxMessageBus messageBus; 
     private final MessageBusResourceHolder holder; 

     public MessageBusResourceSynchronization(MessageBusResourceHolder resourceHolder, TxMessageBus resourceKey) { 
      super(resourceHolder, resourceKey); 
      this.messageBus = resourceKey; 
      this.holder = resourceHolder; 
     } 


     @Override 
     protected void cleanupResource(MessageBusResourceHolder resourceHolder, TxMessageBus resourceKey, 
       boolean committed) { 
      resourceHolder.getPendingMessages().clear(); 
     } 

     @Override 
     public void afterCompletion(int status) { 
      if (status == TransactionSynchronization.STATUS_COMMITTED) { 
       for (Object o : holder.getPendingMessages()) { 
        messageBus.post(o, false); 
       } 
      } 
      else { 
       holder.getPendingMessages().clear(); 
      } 
      super.afterCompletion(status); 
     } 


    } 
} 

public class MessageBusResourceHolder extends ResourceHolderSupport { 

    private List<Object> pendingMessages = Lists.newArrayList(); 

    public void addMessage(Object message) { 
     pendingMessages.add(message); 
    } 


    protected List<Object> getPendingMessages() { 
     return pendingMessages; 
    } 

} 

。

Answer 4

コミットとロールバックの方法でトランザクションマネージャをオーバーライドすることは意味があります。最初はsuper.commit()と呼んでください。