broker

    1热度

    1回答

    我正在使用orion上下文代理GE图像orion-psb-image-R5.4版本1.7.0,我在其中注册了一个设备实体,然后在我的树莓派中实现了pi简单的python服务器脚本,用于监听任何传入消息并将其打印在Pi的日志中。然后我发送了订阅消息给上下文代理,让我的树莓派订阅其上下文代理中的相应实体。问题是,无论何时我更新上下文代理中实体的条件属性,它们都应该触发通知到树莓派,然后PI中的服务器脚

    0热度

    1回答

    我使用Apache Activemq版本5.14.4将一些消息发送到队列并读取它们。我想实现一个安全级别,以便当我连接到要求提供用户名和密码的目的地时。 阅读ActiveMQ security的官方文档并查看了很多示例,包括:example1,example2,我选择使用简单身份验证插件来实现此目的。 所以,在我activemq.xml中,经纪人元素里面我写的插件: <broker xmlns="

    5热度

    2回答

    我正面临连接ActiveMQ网络的问题。 我有两个方案: S1:我的应用程序连接到第一ActiveMQ的 “A”。这个activeMQ“A”连接到一个ActiveMQ“B” - 这是导致我一些问题的场景。 S2:我的应用程序直接连接到ActiveMQ“B”。 在这两种情况下,我们都发送数据到同一队列,当然我们发送完全相同的数据。 预期结果:当ActiveMQ“B”接收到数据时,它应该在同一队列中响

    0热度

    1回答

    我并成立了WebSocket的支持2名mosquitto经纪人和我能够与mqtt.js 连接到它们现在我试图实现与可能的MQTT经纪人数组,故障证明版本,应该尝试连接,直到成功连接。如果连接失败,应尝试下一个代理...迄今为止这么好,但如果我尝试连接到脱机代理,以某种方式mqtt.js尝试无限重新连接。我无法关闭连接尝试并连接到下一个连接。 var client = mqtt.connect("w

    0热度

    1回答

    我想在我的ubuntu16.04服务器上设置一个mosquitto broker。 我可以启动,停止,重新开始......等与经纪人: /etc/init.d/mosquitto start/stop 但我怎样才能重新启动我自己的配置文件中的服务? ,我要开始与经纪人: mosquitto -c /etc/mosquitto/mosquitto.conf 1495978951: mosqu

    1热度

    1回答

    我正在尝试创建订阅,以通知我关于某些传感器值的更改。 curl broker.waziup.io/v2/subscriptions -s -S --header 'Content-Type: application/json' --header 'Accept: application/json' --header 'Fiware-Service:watersense' --header 'Fiw

    0热度

    1回答

    我设置我的春天启动的应用程序如下: application.properties: spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest WebSocketConfig.java: @Configurati

    0热度

    1回答

    我有一个mqtt客户端连接到一个经纪人。 我的经纪人拦截连接以从中获取令牌并执行一些操作。 我想连接时发送一个令牌作为查询参数。 我的客户端连接是这样的: MqttAsyncClient sampleClient = new MqttAsyncClient(broker, clientId, persistence); MqttConnectOptions connOpts = ne

    0热度

    1回答

    我们使用mq 5.1.1运行Glassfish 4.1.1(Payara)。这是一个包含负载平衡器和集群的HA设置。 Glassfish运行正常。问题是MQ不会启动。 我认为远程MQ正在启动。我可以做imqcmd列表bkr -b,并且我获得了成功的结果。 然而,当我这样做的imqcmd列表BKR(或imqcmd子列表JMX,没有 -b主机名),我得到: Host Primary Port -

    -2热度

    1回答

    我试着客户端1和客户端2程序,我可以很容易地与他们沟通。我可以轻松地发送消息并与他们一起接收消息,但我不知道一个客户端是否断开连接,如何将断开的消息发送给订阅的客户端。 客户1: var mqtt=require("mqtt"); var express=require("express"); var app=express(); var options={ keepalive:1