使用erlang RabbitMQ客户端连接ActiveMQ

Question

我正在尝试使用RabbitMQ erlang客户端连接ActiveMQ服务器。

URI = "amqp://server:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600",
{ok,ConnParams} = amqp_uri:parse(URI),
amqp_connection:start(ConnParams).

并得到一个错误消息:

{error,{socket_closed_unexpectedly,'connection.start'}}

根据ActiveMQ文档，它支持AMQP协议1.0版本。

RabbitMQ AMQP协议版本为0.9

是否有办法从RabbitMQ erlang客户端建立到ActiveMQ的连接?

Answer 1

不，ActiveMQ只理解AMQP v1.0，因为它是OASIS标准，早期的AMQP版本将不被支持。您可以使用STOMP、AMQP、MQTT或原生OpenWire客户端与ActiveMQ对话，因此您有很多选择。