JPAライフサイクルイベントを使用してエンティティデータを取得する方法

その段落で述べているように、標準はエンティティリスナーの内部からのエンティティマネージャーメソッドの呼び出しをサポートしていません。Heiko Ruppが彼の答えで言っているように、永続化されたエンティティから構築することを強くお勧めcustDataします。それが不可能な場合は、以下を検討してください。

• 非同期に通知します。これはおそらく適切に動作するタイミングに依存するため、これはあまりお勧めしません。

public class EntityListener { 
    private final static String QUEUE_NAME = "customer"; 

    private ScheduledExecutorService getExecutorService（）{ 
        //どこかから非同期エグゼキューターサービスを取得
        //多少の遅延で
        通知をスケジュールするには// 
        おそらく、ScheduledExecutorService インスタンスが必要になるでしょう。または、
        通知する前にThread.sleep（...）//を試すこともできますが、これは醜い方法です。
    } 

    private void doNotifyOtherInNewTransaction（Customer entity）{ 
        //これをすべて正しく機能させるには、
        // 
        新しいトランザクション内で// 通知を実行する必要があります。かもしれない
        //これを宣言的に実行する方が簡単です
        // // REQUIRES_NEWで
        区切られたいくつかのメソッドを呼び出すことで// 
        試行{ 
            //（トランザクションを開始）
            doNotifyOther（entity）; 
            //（トランザクションのコミット）
        } catch（例外ex）{ 
            //（ロールバックトランザクション）
        } 
    } 

    @PostUpdate 
    @PostPersist 
    public void notifyOther（final Customer entity）{ 
        ScheduledExecutorService executor = getExecutorService（）; 
        //これは「未加工」バージョンです
        //ほとんどの場合
        、executor.schedule を呼び出し、遅延を指定する必要があります。 
        、古いトランザクションに
        //フラッシュしてコミットする時間を与えるために、// 
        てexecutor.execute（新しいRunnableを（）{ 
            @Override 
            ます。public void実行（）{ 
                doNotifyOtherInNewTransaction（エンティティ）; 
            } 
        }）; 
    } 

    //これは、元のコードとまったく同じです
    。public void doNotifyOther（Customer entity）{ 
        CustomerFacadeREST custFacade = new CustomerFacadeREST（）; 
        整数customerId = entity.getCustomerId（）; 
        文字列custData = custFacade.find（customerId）.toString（）; 
        String successMessage = "エンティティがサーバーに追加されました"; 
        {を試す
            ConnectionFactoryファクトリ=新しいConnectionFactory（）; 
            factory.setHost（ "localhost"）;
            接続connection = factory.newConnection（）; 
            チャネルチャネル= connection.createChannel（）; 
            channel.queueDeclare（QUEUE_NAME、false、false、false、null）; 
            channel.basicPublish（ ""、QUEUE_NAME、null、custData.getBytes（））;  
            channel.close（）; 
            connection.close（）; 
        } 
        catch（IOException ex）{ 
        } 
        最後に{ 
        } 
    }     
}

• コミット後のトリガーをいくつか登録します（Heilo Ruppの回答が不可能な場合の私の推奨事項）。データベースにフラッシュした後に実行されることが保証されているため、これはタイミングに依存しません。さらに、トランザクションをロールバックする場合に通知しないという利点もあります。これを行う方法は、トランザクション管理に何を使用しているかによって異なりますが、基本的には、特定のインスタンスのインスタンスを作成し、それをレジストリに登録します。たとえば、JTAでは次のようになります。

public class EntityListener { 
    private final static String QUEUE_NAME = "customer"; 

    private Transaction getTransaction（）{ 
        //どこかから現在のJTAトランザクション参照を取得
    } 

    private void doNotifyOtherInNewTransaction（Customer entity）{ 
        //これがすべて正しく機能するためには、
        // 
        新しいトランザクション内で// 通知を実行する必要があります。
        //宣言的に
        // 
        REQUIRES_NEWで区切られたいくつかのメソッドを呼び出すことで// これを行う方が簡単かもしれません// 
        {{ 
            トランザクションを開始する）
            doNotifyOther（entity）; 
            //（トランザクションをコミット）
         }キャッチ（例外ex）{
            //（ロールバックトランザクション）
         } 
    } 

    @PostUpdate 
    @PostPersist 
    public void notifyOther（final Customer entity）{ 
        Transaction transaction = getTransaction（）; 
        transaction.registerSynchronization（新しい同期（）{ 
            @Override 
            公共ボイドbeforeCompletion（）{} 

            @Override 
            公共ボイドafterCompletion（INT状態）{ 
                （ステータス== Status.STATUS_COMMITTED）{もし
                    doNotifyOtherInNewTransaction（エンティティ）; 
                } 
            } 
    //これは元のコードとまったく同じ 
        }）。             
    } 

    public void doNotifyOther（Customer entity）{ 
        CustomerFacadeREST custFacade = new CustomerFacadeREST（）; 
        整数customerId = entity.getCustomerId（）; 
        文字列custData = custFacade.find（customerId）.toString（）; 
        String successMessage = "エンティティがサーバーに追加されました"; 
        { 
            ConnectionFactory factory = new ConnectionFactory（）;を試してください 
            factory.setHost（ "localhost"）; 
            接続connection = factory.newConnection（）; 
            チャネルチャネル= connection.createChannel（）; 
            channel.queueDeclare（QUEUE_NAME、false、false、false、null）; 
            channel.basicPublish（ ""、QUEUE_NAME、null、custData。  
            channel.close（）; 
            connection.close（）; 
        }
        catch（IOException ex）{ 
        } 
        最後に{ 
        } 
    }     
}

Springトランザクションを使用している場合、コードは非常によく似ており、クラス名がいくつか変更されています。

いくつかのポインタ：

• 非同期アクションをトリガーするためのScheduledExecutorService Javadoc

• JTAとのトランザクション同期：トランザクションJavadocおよび同期Javadoc

• EJBトランザクション境界

• 同等のSpring：TransactionSynchronizationManager JavadocおよびTransactionSynchronization Javadoc。

• そしてSpringトランザクションに関するSpringドキュメント