第7章 コアの使用

サーバーは、アドレスとキューセット間のマッピングを保持します。単一のアドレスには、ゼロ以上のキューをバインドできます。各キューはオプションのメッセージフィルターでバインドできます。メッセージがルーティングされる場合、メッセージはメッセージのアドレスにバインドされたキューのセットにルーティングされます。いずれかのキューがフィルター式でバインドされた場合、メッセージはそのフィルター式に一致するバインドされたキューのサブセットにのみルーティングされます。

迂回などの他のエンティティは、アドレスにもバインドでき、メッセージもルーティングされます。

キューは durable にすることができます。この場合、含まれるメッセージは、durable である限りサーバーのクラッシュや再起動後も保持されます。非 durable キューは、含まれるメッセージが durable の場合であってもサーバーの再起動後やクラッシュ後に保持されません。

また、キューは、一時的である場合もあります。この場合、クライアント接続が閉じられたときに、キューが自動的に削除されます (この前にキューが明示的に削除されていない場合)。

キューは、オプションのフィルター式でバインドできます。フィルター式が提供された場合、サーバーはフィルター式に一致するメッセージのみをアドレスにバインドされたキューにルーティングします。

多くのキューは単一のアドレスにバインドできます。特定のキューは 1 つのアドレスの最大値にのみバインドされます。

クライアントは ClientSessionFactory インスタンスを使用して ClientSession インスタンスを作成します。ClientSessionFactory インスタンスは、サーバーに接続してセッションを作成する方法を認識し、多くの設定が可能です。

ClientSessionFactory インスタンスは、HornetQClient ファクトリークラスを使用して作成されます。

クライアントは、メッセージを消費および生成し、トランザクションでこれらをグループ化するために ClientSession を使用します。ClientSession インスタンスは、トランザクションセマンティクスと非トランザクションセマンティクスの両方をサポートし、JTA トランザクションの一部としてメッセージング操作を実行できるよう XAResource インターフェースを提供できます。

ClientSession インスタンスは、ClientConsumers と ClientProducers をグループ化します。

ClientSession インスタンスは、オプションんの SendAcknowledgementHandler で登録できます。これにより、送信されたメッセージがサーバーに正常に到着したときにクライアントコードに非動的に通知できます。この機能により、応答を受け取るまで送信された各メッセージに対してブロックせずに、送信されたメッセージがサーバーに到着するようになります。

送信された各メッセージに対するブロックは、送信された各メッセージに対してネットワークラウンドトリップを必要とするため、コストが高くなります。送信承認をブロックしたり、受け取ったりしないことにより、標準的な JMS API を使用できない実際のエンドツーエンド非同期システムを作成できます。この機能の詳細については、18章送信およびコミットの保証 を参照してください。

クライアントは、ClientConsumer インスタンスを使用してキューからメッセージを消費します。コアメッセージングは同期および非同期メッセージ消費セマンティクスをサポートします。ClientConsumer インスタンスは、オプションのフィルター式で設定でき、その式に一致するメッセージのみを消費します。

クライアントは、メッセージを送信できるよう ClientSession インスタンス上で ClientProducer インスタンスを作成します。ClientProducer インスタンスは、送信されたすべてのメッセージがルーティングされるアドレスを使用できます。また、このインスタンスが指定されたアドレスを持たないようにすることもできます。この場合、アドレスはメッセージの送信時に指定されます。