sourceCallback) throws MuleException { while(notStopped()) { QueueSession session = sessionProvider.connect(); (1) CallbackContext ctx = callback.createContext(); (2) TransactionHandle status = ctx.bindConnection(session); (3) try { callback.handle(session.poll(), ctx); (4) } catch (Exception e) { status.rollback(); } } } @OnSuccess public void onSuccess(SourceCallbackContext context) { handleSuccess(context.getConnection()); (5) } @OnError public void onError(SourceCallbackContext context, Error error) { handleError(context, error); } } ```

1	複数の接続が取得されます。
2	接続ごとに新しい`CallbackContext` が作成されます。
3	作成された `SourceCallbackContext` の `bindConnection()` メソッドを介して各接続がコンテキストに登録されます。
4	コンテキストが `handle` メソッドに渡されます。
5	接続は後で `SourceCallbackContext.getConnection()` メソッドを介してすべての `onSuccess`、`onError`、`onTerminate methods` で使用できるようになります。

接続はコンテキストにバインドされているため、Runtime は必要に応じて自動的に接続を終了します。接続がトランザクションで、ソースもトランザクションになるように設定されている場合、`bindConnection()` メソッドをコールすると、その接続で自動的にトランザクションが開始されます。また、接続がトランザクションの場合、Runtime は `onSuccess()` メソッドの後に自動的にトランザクションをコミットしたり、`onError()` メソッドの後にロールバックしたりします。

このケースでは、トランザクションはキューからメッセージをポーリングする前に開始する必要があります。接続の取得直後に bindConnection() をコールすることをお勧めします。

## [](#カスタムトランザクション処理)カスタムトランザクション処理コネクタによっては、カスタムトランザクション処理を提供することが必要になる場合があります。たとえば、エラーの場合にエラー応答をパブリッシュしたいとします。この場合、ロールバックされると応答が宛先に到達しなくなるため、トランザクションをコミットする必要があります。例: カスタムトランザクション処理 ```java @OnError public void onError(SourceCallbackContext context, Error error) { ctx.getConnection().publish(buildErrorResponse(error)); (1) ctx.getTransactionHandle().commit(); (2) } ```

1	`onSuccess()` および `onError()` メソッドを実行するとき、接続はまだオープン状態です。
2	コンテキストには、手動でトランザクションを操作できる `TransactionHandle` が設定されています。トランザクションを手動で解決する場合、Runtime でそのことが考慮され、後で自動的に解決されなくなります。最も一般的なユースケースでは、この作業を行う必要はありません。