当前位置: 首页 > 知识库问答 >
问题:

未保留在Apollo服务器中的消息

慕志泽
2023-03-14

我在使用fusesource代码将mqtt消息发布到Apollo服务器时遇到了问题。我使用如下代码编写了消息发布程序

connection.publish(topic, message.getBytes(),QoS.AT_LEAST_ONCE, true);

共有1个答案

仲孙思源
2023-03-14

我怀疑该主题是自动删除,一旦没有生产者或消费者附加到该主题。要禁用自动删除“特性”,请在apollo.XML的virual_host配置元素中添加以下XML元素

<topic auto_delete_after="0"/>

未来版本的apollo将避免删除保留消息APLO-319时的主题。

 类似资料:
  • 我之所以要这样做,是因为我们的服务在部署时配置订阅规则,并且具有消息代理的服务可能会在具有订阅客户端的服务更改规则集和新的业务逻辑之前部署该服务,该服务会发送一组新的消息。我们不希望丢失在部署期间发送的消息,并在新服务退出时处理它们。 干杯。

  • 我试着按照这个例子,https://www.apollographql.com/docs/apollo-server/deployment/lambda/,以创建返回“Hello world”的无服务器GraphQL服务器。 根目录基本上只包含两个文件,

  • 我正在尝试将一个xml文件保存到Android的内部存储中。但是,该文件没有得到保留。每次我重新启动模拟器时,该文件都会是空的。只有当我在应用程序中手动选择向其写入内容时,该文件才会被写入内容。然后,如果我关闭应用程序或其他什么,文件内容会被保留。但是,当我关闭模拟器时,文件会在那里,但是空的。 因此,我不确定我是否正确地保存了它。 请看看我的代码,也许它有问题,或者它与我的Android模拟器的

  • 我正在使用网络库和浏览器上的WebSocket实现一个套接字节点服务器。我正在成功使用telnet,但浏览器工作不正常。浏览器成功连接到套接字服务器并发送消息。我的服务器实现了一个事件,并立即触发和事件<代码>关闭,事件在断开连接时执行删除客户端(关闭浏览器,连接松动…)。 我不希望浏览器发送消息,然后断开连接。有人知道问题出在哪里吗? 套接字服务器 客户端(浏览器) 浏览器连接到服务器时的输出

  • 第一,我试过了 第二,我尝试了下面的。(使用onErrorResumeNext),但取消了订阅。 (未调用onError,但调用OnComplete。因此已取消订阅) 第三,我试了下面。(带重试) 这比第一好。但没有刻录。 我想使刷新按钮,工作后错误。 我想知道 null 对不起,我的英语太差了。

  • 我正在使用Yii2和Kartik的FileInput扩展。我在保存到目录时遇到问题。我正在使用yii高级模板,并使用gii生成CRUD代码。我现在正在编辑它。 当我保存它时,它拒绝保存并显示“请上传文件”消息。 将保存的文件. doc和. pdf大部分。 如果我在模型中设置'skipOnEmpty=True',它将保存表单而不是文件。 mysql表上的数据类型设置为VARCHAR,因为我只想保存其