代码之家  ›  专栏  ›  技术社区  ›  Yossale

ApacheActiveMQ 5.3-如何配置队列以拒绝重复消息?

  •  10
  • Yossale  · 技术社区  · 14 年前

    (我已经在谷歌上搜索了几个小时了…)

    编辑:

    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());
            }
    

    有什么想法,除了修改他们的代码?

    1 回复  |  直到 14 年前
        1
  •  1
  •   Rob Davies    14 年前

    ActiveMQ内置了重复消息检测—您是如何定义重复的?如果重复项具有相同的messageId-则应丢弃它