java - プログラムで ActiveMQ のプライオリティ キューを有効にするにはどうすればよいですか?

Question

ActiveMQ で優先メッセージ キューを使用したいと考えています。このリンクによると、デフォルトでは無効になっています。組み込みの MessageBroker を使用しています。プログラムで優先度を有効にすることは可能ですか。そのようなxml構成ファイルはありません。

よろしく

Answer 1

それで、あなたは普通のJavaを使って埋め込んでいますか?

次のようなことを試してみてください。

BrokerService bs = new BrokerService();
    bs.addConnector("tcp://localhost:61616");
    PolicyMap pm = new PolicyMap();
    PolicyEntry pe = new PolicyEntry();
    pe.setPrioritizedMessages(true);
    pm.setDefaultEntry(pe);
    bs.setDestinationPolicy(pm);
    bs.start();

Spring を使用して ActiveMQ を埋め込む場合は、activemq.xml が ActiveMQ ディストリビューションにあることに注意してください。さまざまなプロパティを持つブローカーを作成する単純なスプリング コンテキスト ファイルに他なりません。