8.4. 大きなメッセージと Java クライアント
大きなメッセージを使用するクライアントを作成している Java 開発者には、2 つのオプションがあります。
1 つのオプションとして、InputStream
および OutputStream
のインスタンスを使用することができます。たとえば、FileInputStream
を使用して、物理ディスク上の大きなファイルから作成されたメッセージを送信します。その後、受信者が FileOutputStream
を使用して、メッセージをローカルファイルシステムの場所にストリーミングできます。
別のオプションとして、JMS BytesMessage
または StreamMessage
を直接ストリーミングする方法もあります。以下に例を示します。
BytesMessage rm = (BytesMessage)cons.receive(10000); byte data[] = new byte[1024]; for (int i = 0; i < rm.getBodyLength(); i += 1024) { int numberOfBytes = rm.readBytes(data); // Do whatever you want with the data }
関連情報
AMQ Core Protocol JMS クライアントでの大きなメッセージの使用方法は、以下を参照してください。
AMQ OpenWire JMS クライアントでの大きなメッセージの使用方法は、以下を参照してください。
-
大きなメッセージの例については、AMQ Broker インストールの
<install_dir> /examples/features/standard/
ディレクトリーのlarge-message
の例を参照してください。サンプルプログラムの実行に関する詳細は、Running an AMQ Broker example program を参照してください。