6.1 および 6.2 間の変更

新規コンポーネント

Debezium 受信チャネルアダプター

Debezium エンジンベースの変更データキャプチャー (CDC) チャネルアダプター。これにより、データベース変更イベントをキャプチャーし、メッセージに変換し、送信チャネルにストリーミングできます。詳細については、"Debezium サポート" を参照してください。

一般的な変更

  • <poller> および @Poller アノテーションの XML 設定で、fixed-delay、fixed-rate、initial-delay オプションの ISO 8601 期間形式がサポートされるようになりました。詳細については、"ポーリングコンシューマー" を参照してください。

  • Java、Groovy、Kotlin DSL には、単一の Consumer 引数を使用して IntegrationFlowDefinition にコンテキスト固有のメソッドが追加され、エンドポイントとそのハンドラーを 1 つのビルダーと読み取り可能なオプションで構成できるようになりました。たとえば、Java DSL の章の transformWith()、splitWith() を参照してください。

  • アプリケーション内のすべてのエンドポイントのデフォルトの 30 秒のタイムアウトをオーバーライドするために、新しい spring.integration.endpoints.defaultTimeout グローバルプロパティが導入されました。詳細については、"グローバルプロパティ" を参照してください。

  • Java DSL によって提供される @MessagingGateway および GatewayEndpointSpec は、MessagingGatewaySupport の内部 MethodInvocationGateway 拡張機能の errorOnTimeout プロパティを公開するようになりました。詳細については、"レスポンスがない場合のゲートウェイの動作" を参照してください。

  • LockRegistry は、ロック中に提供されたタスクを実行するためのテンプレートのような API を提供します。詳細については、"分散ロック" を参照してください。

  • ポーリングエンドポイントのデフォルトのトリガーは、1 秒の固定遅延期間を持つ PeriodicTrigger インスタンスになりました。以前は、デフォルトは 10 ミリ秒でした。詳細については、"ポーリングコンシューマー" を参照してください。

WebSockets の変更

  • サーバーおよびクライアントの WebSocket コンテナーの場合、送信バッファーオーバーフロー戦略を IntegrationWebSocketContainer および send-buffer-overflow-strategy 経由の XML で構成できるようになりました。この戦略は、セッションの送信メッセージバッファーが構成された制限に達したときの動作を決定します。詳細については、"WebSockets サポート" を参照してください。

Apache Kafka サポートの変更

KafkaMessageSource は、コンシューマープロパティから ErrorHandlingDeserializer 構成を抽出し、失敗したレコードヘッダーから抽出された DeserializationException を再スローするようになりました。詳細については、"Kafka 受信チャネルアダプター" を参照してください。

JDBC サポートの変更

JdbcMessageStore、JdbcChannelMessageStore、JdbcMetadataStore、DefaultLockRepository は SmartLifecycle を実装し、start() メソッドでそれぞれのテーブルに対して SELECT COUNT クエリを実行して、必要なテーブル (指定されたプレフィックスに従って) がターゲットデータベースに存在することを確認します。PostgresChannelMessageStoreQueryProvider は、ポーリングクエリ用に単一の DELETE…​RETURNING ステートメントを提供するようになりました。この目的のために、ChannelMessageStoreQueryProvider は JdbcChannelMessageStore から参照される isSingleStatementForPoll オプションを公開します。詳細については、"JDBC メッセージストア" を参照してください。

MongoDB サポートの変更

自動インデックス作成を無効にする新しいオプション setCreateIndexes(boolean) が AbstractConfigurableMongoDbMessageStore に導入されました。例については、MongoDB メッセージストアを参照してください。

リモートファイルのサポートの変更

FtpLastModifiedFileListFilter、SftpLastModifiedFileListFilter、SmbLastModifiedFileListFilter は、FTP、SFTP、SMB の最終変更戦略に基づいてファイルをフィルタリングできるようにするために導入されました。詳細については、"FTP 受信チャネルアダプター"、"SFTP 受信チャネルアダプター"、"SMB 受信チャネルアダプター" を参照してください。

SFTP サポートの変更

オーバーライド時にカスタム SftpClient をサポートするために、新しい DefaultSftpSessionFactory.createSftpClient(…​) メソッドが導入されました。詳細については、"SFTP セッションファクトリ" を参照してください。

セキュリティサポートの変更

spring-integration-security モジュール SecurityContextPropagationChannelInterceptor の最後のクラスは非推奨となり、同様のクラスが spring-security-messaging モジュールに移動されました。詳細については、"Spring Integration のセキュリティ" を参照してください。