问题标签 [broker]

我们有一个带有特定关键字字段的组件，它位于元数据选项卡中。

使用 Broker API，我们想检索某个组件的关键字。custom_meta 正在返回关键字标题。我们不能使用taxonomy api根据关键字标题来获取关键字对象。如果我们使用 API 查询 item_categories_and_keywords 表，API 只返回 ITEM_REFERENCE_ID。我们不需要这个 ID，因为这是我们已经拥有的组件的 ID。

所以我的问题是：有没有办法使用 broker.querying API 来获取结果行，而不是获取包含 item_reference_id 的字符串值的列表？

在 API 中有关于 query.getQueryResult() 的信息，但是该方法是受保护的，所以我们不能使用它。

我按照activemq站点的示例启动了一个嵌入式代理：

然后我对以下 URL 执行一些帖子以使用 ActiveMQ 的 REST 功能：

当我使用独立代理发送帖子时，一切正常，但是当我使用嵌入式代理时，它会挂起进程。

我正在使用活动 mq 版本 5.8.0

我错过了什么？

谢谢

我正在尝试开发一个代理，作为使用 0MQ 的一些工作人员和客户端之间通信的代理。这个任务在没有 Promise 的情况下相对简单，但由于我对 Promise 的使用缺乏经验，我无法理解如何在这个示例中实现 Promise。

经纪人代码：

客户端代码：

客户端连接到代理，发送消息但代理不处理消息。关于我做错了什么的任何想法？任何帮助，将不胜感激。

我正在初始化一个 activeMQ 嵌入式代理，如下所示：

然后我对以下 URL 执行一些 Json 字符串的帖子，以使用 ActiveMQ 的 REST 功能：

我收到以下异常：

我认为嵌入式代理可能需要一些配置才能与 Json 一起使用，但我在 activeMQ 帮助中找不到有关这些的信息。

非常感谢！

I fallowed the exact steps in [1] in order to setup multiple ActiveMQ brokers in the same server. When I start the second instance I always get the same error.

One thing I noticed is configurations on both instances are same. for instance configurations like port s are same in both activemq.xml and jetty.xml.

I even change the ports of the second instance so it won't get crashed with the first intance. But I get the same Exception.

https://sbforge.org/display/BITMAG/Running+multiple+activemq+instances+on+the+same+server

INFO | Apache ActiveMQ 5.9.0 (instance1, ID:udara-54224-1391513355578-0:1) is shutdown INFO | Closing org.apache.activemq.xbean.XBeanBrokerFactory$1@33e228bc: startup date [Tue Feb 04 06:29:14 EST 2014]; root of context hierarchy WARN | Exception thrown from LifecycleProcessor on context close java.lang.IllegalStateException: LifecycleProcessor not initialized - call 'refresh' before invoking lifecycle methods via the context: org.apache.activemq.xbean.XBeanBrokerFactory$1@33e228bc: startup date [Tue Feb 04 06:29:14 EST 2014]; root of context hierarchy at org.springframework.context.support.AbstractApplicationContext.getLifecycleProcessor(AbstractApplicationContext.java:360) at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1057) at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:1010) at org.apache.activemq.hooks.SpringContextHook.run(SpringContextHook.java:30) at org.apache.activemq.broker.BrokerService.stop(BrokerService.java:782) at org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:122) at org.apache.activemq.broker.BrokerService.start(BrokerService.java:574) at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:73) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1608)

设置：我有一个在 asp.net/c# 中构建的表单，在提交时，XML 序列化它的对象模型，并以 XML 序列化数据作为唯一参数调用存储过程。存储过程将该数据发送到 sql 代理队列。发送到代理队列的消息必须是符合队列上设置的消息协定的有效 XML。该消息由 BizTalk 拾取并进行相应处理。

问题：最初提交给我的数据只是普通的英文字符（基本上保存为 ASCII 字符集），但也需要支持外来字符。在我的测试中，我注意到如果我尝试提交带有外来字符（中文、阿拉伯文等）的内容，我会在队列中收到一个错误，并且到达 BizTalk 的消息以“?????”结尾。代替外来字符。我已将 utf=16 xml 标头添加到文档顶部，但这似乎没有帮助。

问题：有没有办法可以将传入的 XML 消息转换为 nvarchar 并且仍然让它被队列视为有效的 XML？我不想更改队列中的实际类型或重新创建它。我宁愿以某种方式单独更改存储过程中的消息，使其能够进入队列。

在此先感谢您的帮助。

我有一个应用程序（例如，TcpApp）发送纯 TCP 消息（即，没有 SOAP，没有信封......只是一个原始字符串甚至字节）。我需要连接 ESB 以通过特定端口（例如 3333）侦听这些消息，并进行一些调解（目前，只做日志记录就足够了）。我认为从 TcpApp 创建一个 ActiveMQ 队列，然后从 ESB 中的 JMS 创建一个代理服务是一个好主意（而不是直接将 ESB 连接到 TcpApp）。我阅读了几个示例和答案，但始终是 XML，而 TCP 只是传输。有时会发生的是应用程序不通过 TCP 发送特殊格式（有时称为电报）。我尝试更改内容类型，但 ESB 仍然拒绝读取 TCP 端口。

<parameter name="transport.tcp.contentType">text/plain</parameter>

可能我仍然对解决方案的体系结构感到困惑，但我认为代理或像 WSO2 这样的 ESB 应该可以在这种情况下作为这个 TcpApp 的中介。我更喜欢在获得真正的配置以使其工作之前讨论解决方案。所有评论，欢迎！

有源应用程序和目标应用程序理解不同 CCSID 中的字符。

源应用程序连接到一些默认 CCSID 集的队列管理器。目标应用程序也连接到具有不同 CCSID 集的队列管理器。

我需要澄清这些消息是如何传递和检索的。1）源应用程序将消息放在其Q中。此消息格式不可读。由于两者具有不同的CCSID，我希望MQPUT将提供由Source QM的默认CCSID覆盖的CCSID。-如果错误请更正

2）WMB接收到MRM格式的消息。它根据指定的物理和逻辑结构进行解析。-请澄清是否根据目标应用程序的CCSID在此阶段本身发生数据转换？如果不是，那么当消息从消息代理中出来时，消息的可读格式如何？

3)WMB解析后根据目标应用的CCSID设置CCSID和Encoding的OutputRoot.properties，错误请指正

4) 最后，当目标应用程序收到带有一些 CCSID 的消息 MQGET 时，它会覆盖目标 QM 的 CCSID。如果错误请更正

我们需要从 MB 流中发出一些 MQ 命令。要走的路是发送一个PCF命令，但我不知道如何创建它。任何指针？塞巴斯蒂安。

使用activemq broker主从时是否也共享调度消息？我通过jdbc成功创建了主从，但是预定的消息没有出现在数据库中。这使得主从代理配置不是真正的 100% 故障转移系统。或者我应该专门设置什么来实现这一点？

使用此代码，我通常会创建代理：

通过这个添加，我创建了主从数据源：

我用来设置主从 jbdcPersistenceAdapter：

接下来是启动 brokerService：

这段代码一切正常。队列在代理之间成功共享，消费者完成他们的工作。消费者有时会创建一个生产者，该生产者成功地使用故障转移 URL 来找出哪个代理在空中。这一切都很好。

但是，计划消息不会出现在数据库中，并且计划消息只会在具有计划消息的代理关闭时停止出现。

谢谢！