问题标签 [broker]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
3845 浏览

jms - 将消息从一个 ActiveMQ 转发到另一个?

我正在尝试设置一个简单的 ActiveMQ 代理网络。我有两台机器,比如A和B。

在 A 的activemq.xml文件中,我放置了具有指向机器 B 的 URI 的 networkConnector。在 A 的日志中显示它已连接到 B。

我有一个向 A 发送消息的应用程序。在 ActiveMQ 的网络控制台中的“网络”选项卡中,我可以看到我的消息正在入队和出队(我认为这意味着消息被转发到机器 B)。

我的问题是转发消息的队列/主题是什么?它们是否应该与机器 A 的队列/主题(即名称)相同。

我有一个消费者正在机器 B 上侦听与机器 A 相同的目标名称,但它没有收到消息。由于显示消息已出队,这意味着消息正在发送到机器 B。此外,我已将日志级别更改为 DEBUG,但我无法从日志中理解。

0 投票
1 回答
178 浏览

wso2 - 编写有关 WSO2 CEP 的定制代理

我有一个关于海关经纪人的问题。

我使用此博客文章中的示例尝试了 Custom Broker 。我从“ https://dl.dropbox.com/u/17922825/blog/cep-ext-broker.zip
” 下载了一个示例模板自定义代理,我输入了.cep-broker-1.0-SNAPSHOT.jarCEP_HOME/repository/components/lib

接下来,我broker.xml输入CEP_HOME/repository/conf. 以下内容broker.xml

并且,重新启动并登录到管理控制台。

但是,我在管理控制台上访问了配置->代理->添加,每次我收到以下错误消息时都转储到监视器->系统日志中

此外,当我访问 Configure -> Broker -> List, Main -> CEP Buckets -> Add and List 时,我得到了同样的错误。

我使用 2.1.0 版的 WSO2 CEP。

如果我需要解释更多,我稍后会添加更多信息。
我恳求你帮助我。

0 投票
1 回答
228 浏览

tridion-2011 - 从 Tridion 代理获取组件标题

此代码用于从代理获取名称以“MC”开头的所有组件的内容:

但是,我很难在 api 中找到可以实际访问返回的每个组件的名称(或标题)的位置。

0 投票
1 回答
116 浏览

jms - 在 WSO2 CEP 上使用 JMS 编写自定义代理

我想在 WSO2 CEP 上使用 JMS 创建自定义代理。我创建了两个类,NewJMSBrokerType 和 NewJMSBrokerTypeFactory。

我为 NewJMSBrokerType 扩展了 JMSBrokerType,并为 NewJMSBrokerTypeFactor 实现了 JMSBrokerTypeFactory。

我把broker.xml. CEP_HOME/repository/conf以下内容broker.xml

最后,我重新启动 CEP 服务器,以下错误消息被转储到控制台上。

我恳求你帮助我。

0 投票
1 回答
27 浏览

wso2 - “编写有关 WSO2 CEP 的海关经纪人”的答案包是什么

我对 编写有关 WSO2 CEP 的海关经纪人有同样的问题

在链接的文章中,Mr.mohanadarshan 回答了https://stackoverflow.com/users/2168723/mohanadarshan

但是,在链接文章的答案中,我无法理解包的链接。

而且我没有时间使用这个 Stack Overflow。所以我没有名声。

请回答我的问题。

问候,

0 投票
1 回答
786 浏览

apache-kafka - 多个经纪人 Kafka 0.7

我正在尝试使用 Kafka 0.7.2 启动多个代理。我收到以下错误:

我为这两个代理创建了两个不同的配置文件,并使用以下命令运行它:

我对 0.8 做了同样的事情,而且效果很好。我在这里错过了什么吗?

0 投票
1 回答
1160 浏览

sql - 连接到 SQL 服务器时出错 -> 使用 mqsisetdbparams 为在 Linux 上运行的代理设置 AD ID 用户以连接到 SQL 服务器

我需要使用 AD id 和密码配置代理以连接到 SQL 数据库服务器。

我输入的设置命令如下:

  1. 首先我创建了 DSN

  2. 停止了经纪人

  3. 执行:

    /li>
  4. 开始经纪人

设置上述属性并重新启动代理后,我尝试使用 mqsicvp 命令验证连接,该命令最终失败,错误在 SQL Server 中记录为

用户 'UK\sqltmsdb' 登录失败。原因:尝试使用带有 SQL 服务器身份验证的 NT 帐户名。

在下面找到我的 DSN 详细信息:

笔记:

  • Broker 在 linux 上运行。
  • Windows 应用程序能够使用该 AD Id 连接到 SQL Server
  • Broker 能够使用普通 SQL id 和密码连接到同一个 SQL 服务器,但使用 AD(活动目录)ID 失败

有人可以帮我告诉我要实施的任何事情是否可行吗?如果是的话,你能帮我解决这个问题吗?如果我在这里遗漏了什么?

0 投票
2 回答
872 浏览

messaging - Websphere Message Broker 和 Websphere Transformation Extender 安装

我在使 WMB 和 WTX 在 Windows 环境中协同工作时遇到问题。所有安装似乎都已成功安装。

现在,当我在消息流中添加 WTX 节点时,我得到 2 个异常:

  1. com.ibm.websphere.dtx.WTXPlugIn.BrowseLocalCompiledMap.checkCompiledMap 中的 java.lang.NullPointerException(未知来源)
  2. java.lang.NoClassDefFoundError: com/ibm/websphere/dtx/WTXPlugIn/WTXPlugInStringResources

我对此进行了一些搜索,发现第一个问题应该在其中一个修复包中修复。我得到了修复包并卸载并重新安装了所有东西,但我得到了相同的结果。

以下是我正在使用的版本:

  1. WMB 8.0.0.1(带有 FIX Pack 1 的 8.0)64 位
  2. 用于集成服务器的 WTX 8.4.0.3 64 位
  3. WTX Design Studio 8.4.0.3 32 Bit(我认为这并不重要,只是在这里列出)
  4. WMQ 7.5

有没有人使这种组合起作用?欢迎和赞赏任何想法或意见。

非常感谢!

0 投票
0 回答
902 浏览

backup - RabbitMQ:消息队列备份

要实现消息队列的备份和恢复,保存Mnesia数据库目录下的文件和broker配置就够了吗?我还必须在复制文件之前停止代理吗?

谢谢!

0 投票
2 回答
463 浏览

jms - CloudBees Java EE/Glassfish 4 Full 平台中的连接池错误

CloudBees 在其 clickstart 中添加了一个新的 Java EE 7/Glassfish 4 Full 平台。如果我理解正确,这意味着它支持所有 Java EE 7 功能(包含 JMS 应用程序)。但是当我运行我的 JMS 应用程序时,它会记录一个错误“无法从连接池获取/创建连接 [jms/__defaultConnectionFactory-Connection-Pool”

这是我的代码,它在我的本地主机中工作:

CloudBees 控制台 glassfish 的日志:

[#|2013-11-19T07:36:43.737+0000|INFO|glassfish 4.0|javax.enterprise.resource.jms.com.sun.enterprise.connectors.jms.system|_ThreadID=21;_ThreadName=http-listener- 1(1);_TimeMillis=1384846603737;_LevelValue=800;_MessageID=addresslist.setjmsservice.provider;| JMS010:setJmsServiceProvider 中的地址列表:mq://localhost:0/|#]

[#|2013-11-19T07:36:43.738+0000|INFO|glassfish 4.0|javax.enterprise.resource.jms.com.sun.enterprise.connectors.jms.system|_ThreadID=21;_ThreadName=http-listener- 1(1);_TimeMillis=1384846603738;_LevelValue=800;_MessageID=jms.connection.url;| JMS08:JMS 服务连接 URL 为:mq://localhost:0/|#]

[#|2013-11-19T07:36:44.552+0000|INFO|glassfish 4.0|javax.resourceadapter.mqjmsra.lifecycle|_ThreadID=21;_ThreadName=http-listener-1(1);_TimeMillis=1384846604552;_LevelValue=800 ;| MQJMSRA_RA1101:GlassFish MQ JMS 资源适配器:版本:5.0(Build 14-e)编译:2013 年 4 月 12 日 0104|#]

[#|2013-11-19T07:36:44.559+0000|INFO|glassfish 4.0|javax.resourceadapter.mqjmsra.lifecycle|_ThreadID=21;_ThreadName=http-listener-1(1);_TimeMillis=1384846604559;_LevelValue=800 ;| MQJMSRA_RA1101:GlassFish MQ JMS 资源适配器正在启动:代理是 EMBEDDED,连接模式是 Direct|#]

[#|2013-11-19T07:36:44.847+0000|INFO|glassfish 4.0|imq.log.Logger|_ThreadID=21;_ThreadName=http-listener-1(1);_TimeMillis=1384846604847;_LevelValue=800;| [B1002]: 找不到 imqbroker 的现有属性文件,不会加载存储的属性 |#]

[#|2013-11-19T07:36:45.558+0000|SEVERE|glassfish 4.0||_ThreadID=21;_ThreadName=Thread-4;_TimeMillis=1384846605558;_LevelValue=1000;| 经纪人退出。|#]

[#|2013-11-19T07:36:45.562+0000|INFO|glassfish 4.0|javax.resourceadapter.mqjmsra.lifecycle|_ThreadID=21;_ThreadName=http-listener-1(1);_TimeMillis=1384846605562;_LevelValue=800 ;| MQJMSRA_RA1101:GlassFish MQ JMS 资源适配器已启动:嵌入|#]

[#|2013-11-19T07:36:49.808+0000|警告|glassfish 4.0|javax.enterprise.resource.resourceadapter.com.sun.enterprise.connectors|_ThreadID=22;_ThreadName=http-listener-1(2) ;_TimeMillis=1384846609808;_LevelValue=900;_MessageID=poolmgr.get_connection_failure;| RAR5117:无法从连接池 [jms/__defaultConnectionFactory-Connection-Pool] 获取/创建连接。原因:com.sun.appserv.connectors.internal.api.PoolingException|#]

[#|2013-11-19T07:36:49.811+0000|SEVERE|glassfish 4.0|SenderBean|_ThreadID=22;_ThreadName=http-listener-1(2);_TimeMillis=1384846609811;_LevelValue=1000;| SenderBean.sendMessage:异常:com.sun.messaging.jms.MQRuntimeException:MQRA:DCF:分配失败:createConnection:分配连接时出错。原因:空|#]

谁能告诉我为什么?提前谢谢了