问题标签 [wso2mb]

我已经使用 WSO2 消息代理将 JSON 数据传输到其他许多服务（使用主题）。当我连接到其他服务时。

所以我需要检查该服务的可用性。连接丢失再试几次，直到连接服务服务器忙如果该服务器稍后启动，如果没有连接到服务，则需要再次调用该服务，警报消息

出于上述目的，如果有任何方式在 WSO2MB、WSO2ESB 或任何其他服务中进行配置。

我已将以下示例用于队列 https://docs.wso2.com/display/MB300/Sending+and+Receiving+Messages+Using+Queues

我试过单独使用WSO2 消息代理，它运行良好。

实际上，我已经创建了两个单独的 Java 应用程序，它们充当发送者和接收者。两个应用程序都使用 amqp 连接字符串来启动连接。使用 Apache Ant 服务器构建应用程序。

现在我想将 Message Broker 与 WSO2 ESB 集成。

建议我使用 ESB 在我的 Web 应用程序中使用 Message Broker 的最佳方式。

我有时会感到困惑，

困惑1：Message Store 和Message Broker 的区别。

混淆 2：Web 应用程序是否需要连接字符串才能使用消息代理

我尝试运行 wso2mb-3.1.0/samples/JmsMessageListenerClient 但在服务器启动时出现以下错误。我错过了一些配置吗？

2017-02-21 16:03 错误 AMQStateManager：162 - 通知服务员（[org.wso2.andes.client.state.StateWaiter@520acd8f]）错误：针对 AMQConnection 引发的异常：主机：本地主机端口：5672 虚拟主机：碳客户端 ID：carbon 活动会话计数：0：org.wso2.andes.AMQDisconnectedException：服务器关闭连接并且不允许重新连接。2017-02-21 16:03 错误 AMQProtocolHandler：485 - 异常处理框架 org.wso2.andes.framing.AMQProtocolClassException：预期协议类 1；在 org.wso2.andes.client.protocol.AMQProtocolHandler$2.run(AMQProtocolHandler.java:476) 在 org.wso2.andes 的 org.wso2.andes.framing.ProtocolInitiation.checkVersion(ProtocolInitiation.java:190) 收到 3。 pool.Job.processAll(Job.java:109) 在 org.wso2.andes.pool.Job.run(Job.java: 157) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 在 java.lang.Thread.run(Thread.java :745) 2017-02-21 16:03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.AMQDisconnectedException：服务器关闭连接并且不允许重新连接。2017-02-21 16:03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.framing.AMQProtocolClassException：预期协议类 1；收到 3 03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.AMQDisconnectedException：服务器关闭连接并且不允许重新连接。2017-02-21 16:03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.framing.AMQProtocolClassException：预期协议类 1；收到 3 03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.AMQDisconnectedException：服务器关闭连接并且不允许重新连接。2017-02-21 16:03 错误 AMQConnection:1307 - Throwable 已接收但未设置侦听器：org.wso2.andes.framing.AMQProtocolClassException：预期协议类 1；收到 3

谢谢，马尼什

我正在尝试在 spring boot 中使用 WSO2MB，但是 maven 无法下载像 andes-client-3.1.1.jar 这样的依赖项。

当我使用 msf4j 时它工作正常。spring-boot 不能使用 wso2mb 吗？

我收到错误：在https://repo.maven.apache.org/maven2中找不到 org.wso2.andes.wso2:andes-client:jar:0.13.wso2v10 失败被缓存在本地存储库中，解决方法不会重新尝试，直到中央的更新间隔已过或强制更新 -> [帮助 1]

谢谢

我想创建一个发布和订阅模型来开发 IoT 项目。我使用 Python 语言创建了它。一切都运行良好，但似乎有 3 秒的延迟才能将消息从发布者发送给订阅者。

有什么方法可以最大限度地减少消息传递的延迟并提高其在WSO2 Message Broker中的性能或任何建议......

我使用 WSO2 Message Broker 创建了一个示例发布和订阅模型项目。

但是这个实现没有安全性。

有人可以帮我在 WSO2 消息代理中的 MQTT 订阅中设置身份验证吗？而且我在 WSO2 消息代理应用程序https://localhost:9443/carbon中也没有看到任何订阅的节点信息

I am using spring JMS to connect to WSO2MB server. Everything is working fine, but all listeners are assigned the same id. To make it unique, I provided clientId but it is not working. I am not finding any other field where I can provide the name.

I even provided id on the JMS listener but no success.

我在WSO2 ESB中很新，我有以下问题。

在我的ESB流程中，我有一个将 XML 文档放入WSO2 MB队列的存储中介，这是我的消息存储的配置：

如您所见，我的文档已放入glisQueue队列中。

然后我（在这个项目中）部署了一个名为glisMessageProcessor的消息处理器，它检查队列是否不为空，以及它是否包含一些它发送到的 XML 文档以及执行 Http 调用的外部 Web 服务，这是我的消息处理器的配置：

如您所见，它使用glisMessageStore作为数据源（因此它使用其中的glisQueue队列定义来获取要发送的数据）并将这些数据发送到我的 Web 服务的端点glisEndpoint（它在我的项目）。

它工作正常，数据正确发送到由glisEndpoint表示的外部 Web 服务。

我唯一的问题是：我的网络服务在被调用时返回一条消息（包含一些我需要以某种方式存储的信息）。

我可以以某种方式配置我的glissMessageProcessor以检索这些响应消息并将其放入日志文件中吗？

我有查询和执行计划，我想对其进行快照，以便我可以在接收方恢复它并再次开始执行它。

1. 应该以什么格式发送给接收方？
2. 如何在接收端恢复？

以下是我从 Siddhi 存储库中获取的一些代码。

我使用of插入了一些json内容：queueWSO2 Message BrokerAPIWSO2 ESB

在此API，我迭代了 的json响应endpoint并使用以下命令将订单插入到一个Message Broker's queue中sequence：

然后，我创建了一个Message Processorat WSO2 ESB，因为我想在 orders_mb 上使用这些消息，queue然后在另一个中使用sequence。这是Message Storeand的代码Message Processor：

最后，这里是sequence发送Message Processor消息的queue：

当我调用API resource将订单插入 时queue，它可以工作。但是，当Message Processor消费时，它会注销

[2017-07-13 10:06:34,856] 警告 - JmsConsumer [orders_mb-C-1]。没有收到 javax.jms.ObjectMessage

我不知道出了什么问题，我看到这个问题询问了同样的问题，但是，我已经插入了强制性的属性，但它还没有在这里工作。