11

重複禁止ポリシーを適用するには、キューが必要です。出来ますか？もしそうなら、どのように？(私は何時間もグーグルで検索してきました...)

編集：

ActiveMQSession 実装には次の行があります。

        // transform to our own message format here
            ActiveMQMessage msg = ActiveMQMessageTransformation.transformMessage(message, connection);

        // Set the message id.
        if (msg == message) {
            msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(), sequenceNumber));
        } else {
            msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(), sequenceNumber));
            message.setJMSMessageID(msg.getMessageId().toString());
        }

ActiveMQMessageTransformation はプラグイン可能 (設定可能) ですが、次の if ステートメントは議論の余地がありません。

コードを変更する以外のアイデアはありますか?

4

1 に答える 1

1

ActiveMQ には重複メッセージ検出機能が組み込まれています。重複をどのように定義していますか? 重複に同じ messageId がある場合 - 破棄する必要があります

于 2009-12-30T15:10:30.010 に答える