Rabbitmq Endpoint v0.24.0+ 用来创建和启动Rabbitmq订阅服务，它可以订阅不同流名称数据，然后路由到不同规则链进行处理。

提示

1. 该组件是扩展组件，需要引入额外的扩展库：rulego-components (opens new window)

Type

endpoint/rabbitmq

启动配置

该组件允许通关过server字段复用共享的连接客户端。参考组件连接复用 。

字段	类型	说明	默认值
server	string	RabbitMQ服务器地址，示例：amqp://guest:guest@127.0.0.1:5672/	无
exchange	string	交换机名称	无
exchangeType	string	交换机类型，可选值：direct, fanout, topic	无
durable	bool	表示交换器是否持久化。如果设置为 true，即使消息服务器重启，交换器也会被保留。	false
autoDelete	bool	表示交换器是否自动删除。如果设置为 true，则当没有绑定的队列时，交换器会被自动删除。	false

响应

exchange.Out.SetBody响应之前，需要通过exchange.Out.Headers()或者exchange.Out.Msg.Metadata指定responseTopic参数，组件就会往指定的主题发送数据：

exchange.Out.GetMsg().Metadata.PutValue("responseTopic", "device.msg.response")
// or
exchange.Out.Headers().Add("responseTopic", "device.msg.response")

exchange.Out.SetBody([]byte("ok"))

响应参数配置：

字段	类型	是否必填	说明	默认值
responseTopic/responseKey	string	是	响应Key	-
responseExchange	string	是	响应交换机	-

示例

以下是使用endpoint的示例代码：

• RestEndpoint (opens new window)
• WebsocketEndpoint (opens new window)
• MqttEndpoint (opens new window)
• ScheduleEndpoint (opens new window)
• NetEndpoint (opens new window)
• KafkaEndpoint (opens new window) （扩展组件库）