1

好的，这就是交易。我正在阅读本教程和 ActiveMQ 网站上的文档。

在我们拥有的文档中，在Message Transformations下，这句话：

SEND 和 SUBSCRIBE 消息上的转换消息头可用于指示 ActiveMQ 将消息从文本转换为您想要的格式。目前，ActiveMQ 带有一个转换器，可以将 XML/JSON 文本转换为 Java 对象

和

ActiveMQ 使用 XStream 来满足其转换需求。由于它是可选依赖项，因此您必须通过将适当的 JAR 放入 lib/ 文件夹来将其添加到代理的类路径中。此外，如果您计划使用 JSON 转换，则必须将 Jettison JSON 解析器添加到类路径中。

所以我这样做了，我用XStreamAlias注释了我的 pojo ：

@XStreamAlias("ProvaPojo")
public class ProvaPojo implements Serializable {

    private static final long serialVersionUID = 1687248536279612587L;

    @XStreamAlias("fieldOne")
    private int fieldOne;

    @XStreamAlias("fieldTwo")
    private String fieldTwo;

    public int getFieldOne() {
    return fieldOne;
    }

    public void setFieldOne(int fieldOne) {
    this.fieldOne = fieldOne;
    }

    public String getFieldTwo() {
    return fieldTwo;
    }

    public void setFieldTwo(String fieldTwo) {
    this.fieldTwo = fieldTwo;
    }

}

这是我的 PHP 代码（原始示例在这里）：

$body = array(
        'ProvaPojo' => array(
            array('fieldOne' =>  14),
            array('fieldTwo' => 'Stringa')
        )
);

$header = array();
$header['transformation'] = 'jms-map-json';
$mapMessage = new StompMessageMap($body, $header);
$con->send($queue, $mapMessage);

这是我的听众

@Override
protected void _onMessage(Message message) {
if (!(message instanceof ObjectMessage))
    throw new IllegalStateException();
ObjectMessage objectMessage = (ObjectMessage) message;
try {
    if (!(objectMessage.getObject() instanceof BlacklisterRecipientBean))
    throw new IllegalArgumentException(
            "The message content is not an instance of "
                    + BlacklisterRecipientBean.class.getSimpleName());
    BlacklisterRecipientBean recipient = (BlacklisterRecipientBean) objectMessage
        .getObject();
    log.info("_onMessage(Message)");
    IncomingBlacklistAddJMSTrigger trigger = new IncomingBlacklistAddJMSTrigger();
    trigger.setArgs(recipient);
    notifyObservers(trigger);
} catch (JMSException e) {
    log.error("_onMessage(Message) - exception ignored", e);
}

}

但我总是收到一个 ActiveMQTextMessage。我错过了什么？

4

1 回答 1

1

所以显然这是我的activeMQ版本的问题。一旦切换到5.8.0一切工作就像一个魅力。

于 2013-06-06T08:56:57.913 回答