第28章 管理

デプロイされたコアキューのリストは、getQueueNames() メソッドを使用して取得できます。

コアキューは、管理操作を使用して作成または破棄できます。

キューがすでに存在し、deployQueue が何も行わない場合は、createQueue が失敗します。

QueueControl は、基礎となるキューを一時停止および再開できます。キューが一時停止した場合、キューはメッセージを受け取りますが、配信しません。キューが再開された場合に、キューに格納されたメッセージの配信が開始されます。

クライアントリモートアドレスは、listRemoteAddresses() を使用して取得できます。closeConnectionsForAddress() メソッドを使用してリモートアドレスに関連付けられた接続を閉じることもできます。

または、接続 ID を listConnectionIDs() を使用してリストしたり、該当する接続 ID のすべてのセッションを listSessions() を使用してリストしたりできます。

サーバークラッシュの場合に、一部のトランザクションでは、サーバーの再起動時に手動で作業する必要があることがあります。listPreparedTransactions() メソッドは、準備状態のトランザクションをリストします (トランザクションは不透明な Base64 文字列として表されます)。該当する準備状態のトランザクションをコミットまたはロールバックするために、commitPreparedTransaction() または rollbackPreparedTransaction() メソッドを使用してヒューリスティックトランザクションを解決できます。ヒューリスティックに完了したトランザクションは、listHeuristicCommittedTransactions() メソッドと listHeuristicRolledBackTransactions メソッドを使用してリストできます。

メッセージカウンターは、enableMessageCounters() または disableMessageCounters() メソッドを使用して有効化または無効化できます。メッセージカウンターをリセットするために、resetAllMessageCounters() および resetAllMessageCounterHistories() メソッドを呼び出すことができます。

HornetQServerControl は、HornetQ サーバー設定をそのすべての属性を介して公開します (たとえば、サーバーのバージョンを取得する getVersion() メソッドなど)。

メッセージは、expireMessages() メソッドを使用してキューで期限切れにすることができます。期限が切れたアドレスが定義された場合、メッセージはそのアドレスに送信され、送信されない場合は破棄されます。キューの期限切れのアドレスは setExpiryAddress() メソッドで設定できます。

また、メッセージは sendMessagesToDeadLetterAddress() メソッドを使用してデッドレターアドレスに送信することもできます。これは、デッドレターアドレスに送信されたメッセージの数を返します。デッドレターアドレスが定義されない場合、メッセージはキューから削除され、破棄されます。キューのデッドレターアドレスは、setDeadLetterAddress() メソッドで設定できます。

メッセージは、moveMessages() メソッドを使用してあるキューから別のキューに移動することもできます。

メッセージは、listMessages() メソッドを使用してキューからリストできます。このメソッドは Map のアレイを返します。各メッセージに対して 1 つの Map が存在します。

メッセージは、単一のメッセージ ID バリアントに対して boolean またはフィルターバリアントに対して削除済みメッセージの数を返す removeMessages() メソッドを使用してキューから削除することもできます。removeMessages() メソッドは filter 引数を受け取ってフィルタリングされたメッセージのみを削除します。フィルターを空の文字列に設定すると、すべてのメッセージが削除されます。

キュー内のメッセージの数は、getMessageCount() メソッドにより返されます。また、countMessages() は、該当するフィルターに一致したキュー内のメッセージの数を返します。

メッセージ優先度は、単一のメッセージ ID バリアントに対して boolean、フィルターバリアントに対して更新済みメッセージの数を返す changeMessagesPriority() メソッドを使用して変更できます。

メッセージカウンターは、listMessageCounter() と listMessageCounterHistory() メソッドでキューに対してリストできます (「メッセージカウンター」 を参照)。また、メッセージカウンターは、resetMessageCounter() メソッドを使用して単一のキューに対してリセットできます。

QueueControl は、属性を介してコアキューの設定を公開します (たとえば、キューのフィルターを取得する getFilter() (作成された場合) やキューが耐性かどうかを認識する isDurable() など)。

QueueControl は、基礎となるキューを一時停止および再開できます。キューが一時停止した場合、キューはメッセージを受け取りますが、配信しません。キューが再開された場合に、キューに格納されたメッセージの配信が開始されます。

アクセプターは、AcceptorControl クラスの start() または stop() メソッドを使用して開始または停止できます (org.hornetq:module=Core,type=Acceptor,name="<the acceptor name>" またはリソース名 core.acceptor.<the address name> とともに使用)。アクセプターのパラメーターは、AcceptorControl 属性を使用して取得できます (「アクセプターについて」 を参照)。

迂回は DivertControl クラスの start() または stop() を使用して開始または停止できます (ObjectName org.hornetq:module=Core,type=Divert,name=<the divert name> またはリソース名 core.divert.<the divert name> とともに使用)。迂回パラメーターは、DivertControl 属性を使用して取得できます (33章メッセージフローの迂回と分割 を参照)。

これらは、BridgeControl クラスの start() (resp. stop()) メソッドを使用して開始または停止できます (ObjectName org.hornetq:module=Core,type=Bridge,name="<the bridge name>" またはリソース名 core.bridge.<the bridge name> とともに使用)。ブリッジパラメーターは、BridgeControl 属性を使用して取得できます (34章コアブリッジ を参照)。

ブロードキャストグループは、BroadcastGroupControl クラスの start() または stop() を使用して開始または停止できます (ObjectName org.hornetq:module=Core,type=BroadcastGroup,name="<the broadcast group name>" またはリソース名 core.broadcastgroup.<the broadcast group name> とともに使用)。ブロードキャストグループパラメーターは、BroadcastGroupControl 属性を使用して取得できます (「ブロードキャストグループ」 を参照)。

これらは、DiscoveryGroupControl クラスの start() または stop() めそっどを使用して開始または停止できます (ObjectName org.hornetq:module=Core,type=DiscoveryGroup,name="<the discovery group name>" またはリソース名 core.discovery.<the discovery group name> とともに使用)。検出グループパラメーターは、DiscoveryGroupControl 属性を使用して取得できます (「検出グループ」 を参照)。

これらは、ClusterConnectionControl クラスの start() または stop() メソッドを使用して開始または停止できます (ObjectName org.hornetq:module=Core,type=ClusterConnection,name="<the cluster connection name>" またはリソース名 core.clusterconnection.<the cluster connection name> とともに使用)。クラスター接続パラメーターは、ClusterConnectionControl 属性を使用して取得できます (「クラスター接続の設定」 を参照)。

デプロイされた接続ファクトリーの名前は、getConnectionFactoryNames() メソッドにより取得できます。

JMS 接続ファクトリーは、createConnectionFactory() メソッドまたは destroyConnectionFactory() メソッドを使用して作成または破棄できます。これらの接続ファクトリーは、JNDI にバインドされ、JMS クライアントはこれらをルックアップできます。接続ファクトリーを作成するためにグラフィカルコンソールが使用された場合は、トランザクションパラメーターがテキストフィールド入力で、キー = 値 (つまり、key1=10, key2="value", key3=false) のカンマ区切りのリストとして指定されます。複数のトランスポートが定義された場合は、キーと値のペアを中かっこで囲む必要があります (たとえば、{key=10}, {key=20})。この場合、最初の key は最初のトランスポート設定に関連付けられ、2 つ目の key は 2 つ目のトランスポート設定に関連付けられます (トランスポートパラメーターのリストについては、14章トランスポートの設定 を参照してください)。

デプロイされた JMS キューの名前は、getQueueNames() メソッドを使用して取得できます。

JMS キューは、createQueue() メソッドまたは destroyQueue() メソッドを使用して作成または破棄できます。これらのキューは JNDI にバインドされるため、JMS クライアントはこれらをルックアップできます。

デプロイされたトピックの名前は、getTopicNames() メソッドを使用して取得できます。

JMS トピックは、createTopic() または destroyTopic() メソッドを使用して作成または破棄できます。これらのトピックは JNDI にバインドされるため、JMS クライアントはこれらをルックアップできます。

JMS クライアントリモートアドレスは、listRemoteAddresses() を使用して取得できます。また、closeConnectionsForAddress() メソッドを使用してリモートアドレスに関連付けられた接続を閉じることもできます。

または、接続 ID を listConnectionIDs() を使用してリストしたり、該当する接続 ID のすべてのセッションを listSessions() を使用してリストしたりできます。

ConnectionFactoryControl は、JMS ConnectionFactory 設定をその属性を介して公開します (つまり、フロー制御に対してコンシューマーウィンドウサイズを取得するために getConsumerWindowSize()、非耐性メッセージの送信時に接続ファクトリーから作成されたプロデューサーがブロックされるかどうかを認識するために isBlockOnNonDurableSend())。

メッセージは、expireMessages() メソッドを使用してキューで期限切れにすることができます。期限が切れたアドレスが定義された場合、メッセージはそのアドレスに送信され、送信されない場合は破棄されます。キューの期限切れのアドレスは setExpiryAddress() メソッドで設定できます。

また、メッセージは sendMessagesToDeadLetterAddress() メソッドを使用してデッドレターアドレスに送信することもできます。これは、デッドレターアドレスに送信されたメッセージの数を返します。デッドレターアドレスが定義されない場合、メッセージはキューから削除され、破棄されます。キューのデッドレターアドレスは、setDeadLetterAddress() メソッドで設定できます。

メッセージは、moveMessages() メソッドを使用してあるキューから別のキューに移動することもできます。

メッセージは、listMessages() メソッドを使用してキューからリストできます。このメソッドは Map のアレイを返します。各メッセージに対して 1 つの Map が存在します。

メッセージは、単一のメッセージ ID バリアントに対して boolean またはフィルターバリアントに対して削除済みメッセージの数を返す removeMessages() メソッドを使用してキューから削除することもできます。removeMessages() メソッドは filter 引数を受け取ってフィルタリングされたメッセージのみを実際に削除します。フィルターを空の文字列に設定すると、すべてのメッセージが削除されます。

キュー内のメッセージの数は、getMessageCount() メソッドにより返されます。また、countMessages() は、該当するフィルターに一致したキュー内のメッセージの数を返します。

メッセージ優先度は、単一のメッセージ ID バリアントに対して boolean、フィルターバリアントに対して更新済みメッセージの数を返す changeMessagesPriority() メソッドを使用して変更できます。

メッセージカウンターは、listMessageCounter() と listMessageCounterHistory() メソッドでキューに対してリストできます (「メッセージカウンター」 を参照)。

JMSQueueControl は、JMS キューの設定をその属性を介して公開します (たとえば、キューが一時的かどうかを識別するために isTemporary()、キューが耐性かどうかを識別するために isDurable())。

JMSQueueControl は、基礎となるキューを一時停止および再開できます。キューが一時停止した場合、キューはメッセージを受け取りますが、配信しません。キューが再開された場合に、キューに格納されたメッセージが配信されます。

JMS トピックサブスクリプションは、listAllSubscriptions()、listDurableSubscriptions()、listNonDurableSubscriptions() メソッドを使用してリストできます。これらのメソッドは、サブスクリプション情報 (サブスクリプション名、クライアント ID、耐性、メッセージ数など) を表す Object のアレイを返します。また、listMessagesForSubscription() メソッドを使用して該当するサブスクリプションの JMS メッセージをリストすることもできます。

耐性サブスクリプションは、dropDurableSubscription() メソッドを使用してトピックからドロップできます。

countMessagesForSubscription() メソッドは、該当するサブスクリプションに対して保持されたメッセージの数を調べるために使用できます (セレクターに一致するメッセージの数を調べるためのオプションのメッセージセレクターがあります)。