问题标签 [wso2mb]

我目前正在使用 WSO2 Message Broker，我需要在不使用 ESB 的情况下将此产品连接到 WSO2 BPS。所以我的问题是，有可能这样做吗？或者我必须使用 WSO2 ESB 将 MB 与 BPS 集成？

我正在尝试将 wso2mb 与 wso2esb 集成，并在订阅者不活动时使用持久主题将消息保留在队列中并在将来恢复它们。我在 wso2mb 文档中使用了第一种集成方法（使用 JMS 端点和 JMS 代理服务集成）。这是我的发布者代理：

我使用这个答案来创建消费者代理和持久主题，这是我的订阅者代理：

我可以使用 SoapUI 调用发布者代理，订阅者代理将使用消息并将它们发送到 SimpleStockQuoteService（wso2esb 服务器示例），但问题是当我关闭服务器时，消息会累积在主题队列中，当我再次启动服务器时，订阅者不消费也不向服务器发送累积的消息，我想知道当我使用没有 wso2esb 的 wso2mb 和带有 java 代码的 JMS 客户端订阅者时，持久主题完美地工作并在启动服务器后消费消息。有任何想法吗？

我试图按照这个链接，我一步一步做了四次，前 3 次我使用 WSO2 MB 作为代理，最后一次我尝试 Apache ActiveMQ 但问题是，当我关闭 SimpleQuoteService 服务器时并通过 SoapUI 向代理发送消息，它们累积在我的队列中，并且我的预定消息转发处理器在达到最大传递尝试后变得不活动，但 WSO2-ESB 文档说：“要测试故障转移方案，请关闭 JMS 代理（即，原始消息存储）并发送一些消息到代理服务。您将看到消息没有发送到后端，因为原始消息存储不可用。您还将看到消息存储在故障转移中消息存储。”

有没有人解释一下？！！！

在我的项目中，我使用 WSO2 Message Broker 作为消息代理系统。

我想获取一些信息，例如创建的队列数、队列中的消息数等，以显示在我的门户上。为此，我想在我的 java 类中调用消息代理 API。

我可以在 Java 类中调用消息代理 API 吗？如果是，我在哪里可以获得可以在我的 java 代码中使用的 api 列表？

我在我的项目中使用 wso2 消息代理作为消息代理系统。在使用 wso2 消息代理之前，我想探索一下与 wso2 消息代理队列/主题相关的异常案例——

1. 如果消费者关闭并且发布者不断向队列/主题发送消息，那么队列/主题可以存储多少条消息？

2. 如果队列/主题不可用并且发布者试图在队列/主题中发布消息会发生什么？

3. 消息队列/主题可以存储的最大大小是多少？是否可配置？

4. wso2消息代理的JSON消息格式是什么？

5. 从队列/主题获取消息后，消费者可以向发布者发送响应吗？如果是，如何？

6. 队列/主题会话超时的持续时间是多少？是否可配置？

我在 wso2 消息代理中MyFirstQueue创建了两个队列。MySecondQueue我可以使用 此处给出的示例应用程序发布和使用消息。

现在使用 wso2AndesAdminService类，我想在我的代码中获取队列相关信息，例如创建的队列数、每个队列中的消息数、清除队列等。

我没有得到我应该如何AndesAdminService在我的代码中引入类？还需要什么其他罐子？

我的项目中有以下 jar 文件：

1. andes-client-3.1.1.jar
2. geronimo-jms_1.1_spec-1.1.0.wso2v1.jar
3. log4j-1.2.13.jar
4. org.wso2.carbon.logging-4.4.1.jar
5. org.wso2.securevault-1.0.0-wso2v2.jar
6. slf4j-1.5.10.wso2v1.jar

也请提供我的示例代码。

我在这里得到了 AndesAdminService 类代码。

我在我的项目中使用 WSO2 消息代理作为消息代理系统。为了获取队列信息（例如获取在 wso2mb 服务器中创建的所有队列、每个队列中的消息数量等信息），我从 AndesAdminServics WSDL 生成客户端并尝试从我的 api 调用 getAllQueues() api。每次我都无法找到请求的目标异常的有效认证路径。我无法弄清楚问题所在。例外是 -

我调用 getAllQueues() 方法的 api 是 -

我在我的项目中使用 WSO2 消息代理作为消息代理系统。为了获取队列浏览信息，我从AndesAdminServics WSDL生成了客户端，并尝试从我的 api调用 AndesAdminServicePortTypeProxy类的 browseQueue() 方法。生成的 browseQueue() 方法是

browseQueue() 方法采用三个参数 - java.lang.String queueName、java.lang.Long nextMessageIdToRead、java.lang.Integer maxMsgCount

我了解参数 queueName，但我没有得到，参数 nextMessageIdToRead 和 maxMsgCount 代表什么。在browseQueue() 方法调用时，我应该传递什么作为参数。

我在 wso2 esb 中将 json 转换为 json 时遇到问题，实际上我在代理中使用了有效负载工厂，我用 rest 和 json 内容调用代理。这是我的集成流程，我调用代理，代理将请求（带有 json 内容）发送到 jms 消息存储，然后我定义了一个消息处理器来使用来自消息存储的消息并将它们发送到定义的端点（.net web api）。但问题是带有数字的字符串会自动转换为整数元素：“orderId”：10000（我希望它是字符串“orderId”：“10000”），但是当我将请求直接从代理发送到我的端点时（没有使用消息代理）它可以正常工作。你能帮我解决这个问题吗？

WSO2 Message Broker v3.1 文档建议可以将 Message Broker 用作 ESB 功能，称为“Stratos Message Broker - Dashboard UI Features”：从这里

我正在尝试在最新的 WSO2 ESB 版本 (v4.9) 上将 MB 作为功能安装，就像它一样。

为此，我正在使用最新的 P2 存储库： 从这里

选择“Stratos Message Broker - 仪表板 UI 功能”v 3.1 后，我收到以下错误消息：

这是否意味着不能将最新版本的 MB 用作 ESB 功能？我尝试了其他人，没有成功..

回购：WSO2 Carbon 4.2.0（图灵）-MB 版本：2.2.0-错误消息：

回购：WSO2 Carbon 4.1.7 - MB 版本：2.1.1 - 错误消息：

有什么建议吗？ 是否有人已经使用 MB 作为 ESB 功能？哪个版本？

谢谢！