问题标签 [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.
jms - 将消息从一个 ActiveMQ 转发到另一个?
我正在尝试设置一个简单的 ActiveMQ 代理网络。我有两台机器,比如A和B。
在 A 的activemq.xml
文件中,我放置了具有指向机器 B 的 URI 的 networkConnector。在 A 的日志中显示它已连接到 B。
我有一个向 A 发送消息的应用程序。在 ActiveMQ 的网络控制台中的“网络”选项卡中,我可以看到我的消息正在入队和出队(我认为这意味着消息被转发到机器 B)。
我的问题是转发消息的队列/主题是什么?它们是否应该与机器 A 的队列/主题(即名称)相同。
我有一个消费者正在机器 B 上侦听与机器 A 相同的目标名称,但它没有收到消息。由于显示消息已出队,这意味着消息正在发送到机器 B。此外,我已将日志级别更改为 DEBUG,但我无法从日志中理解。
wso2 - 编写有关 WSO2 CEP 的定制代理
我有一个关于海关经纪人的问题。
我使用此博客文章中的示例尝试了 Custom Broker 。我从“ https://dl.dropbox.com/u/17922825/blog/cep-ext-broker.zip
”
下载了一个示例模板自定义代理,我输入了.cep-broker-1.0-SNAPSHOT.jar
CEP_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。
如果我需要解释更多,我稍后会添加更多信息。
我恳求你帮助我。
tridion-2011 - 从 Tridion 代理获取组件标题
此代码用于从代理获取名称以“MC”开头的所有组件的内容:
但是,我很难在 api 中找到可以实际访问返回的每个组件的名称(或标题)的位置。
jms - 在 WSO2 CEP 上使用 JMS 编写自定义代理
我想在 WSO2 CEP 上使用 JMS 创建自定义代理。我创建了两个类,NewJMSBrokerType 和 NewJMSBrokerTypeFactory。
我为 NewJMSBrokerType 扩展了 JMSBrokerType,并为 NewJMSBrokerTypeFactor 实现了 JMSBrokerTypeFactory。
我把broker.xml
. CEP_HOME/repository/conf
以下内容broker.xml
:
最后,我重新启动 CEP 服务器,以下错误消息被转储到控制台上。
我恳求你帮助我。
wso2 - “编写有关 WSO2 CEP 的海关经纪人”的答案包是什么
在链接的文章中,Mr.mohanadarshan 回答了https://stackoverflow.com/users/2168723/mohanadarshan
但是,在链接文章的答案中,我无法理解包的链接。
而且我没有时间使用这个 Stack Overflow。所以我没有名声。
请回答我的问题。
问候,
apache-kafka - 多个经纪人 Kafka 0.7
我正在尝试使用 Kafka 0.7.2 启动多个代理。我收到以下错误:
我为这两个代理创建了两个不同的配置文件,并使用以下命令运行它:
我对 0.8 做了同样的事情,而且效果很好。我在这里错过了什么吗?
sql - 连接到 SQL 服务器时出错 -> 使用 mqsisetdbparams 为在 Linux 上运行的代理设置 AD ID 用户以连接到 SQL 服务器
我需要使用 AD id 和密码配置代理以连接到 SQL 数据库服务器。
我输入的设置命令如下:
首先我创建了 DSN
停止了经纪人
执行:
/li>开始经纪人
设置上述属性并重新启动代理后,我尝试使用 mqsicvp 命令验证连接,该命令最终失败,错误在 SQL Server 中记录为
用户 'UK\sqltmsdb' 登录失败。原因:尝试使用带有 SQL 服务器身份验证的 NT 帐户名。
在下面找到我的 DSN 详细信息:
笔记:
- Broker 在 linux 上运行。
- Windows 应用程序能够使用该 AD Id 连接到 SQL Server
- Broker 能够使用普通 SQL id 和密码连接到同一个 SQL 服务器,但使用 AD(活动目录)ID 失败
有人可以帮我告诉我要实施的任何事情是否可行吗?如果是的话,你能帮我解决这个问题吗?如果我在这里遗漏了什么?
messaging - Websphere Message Broker 和 Websphere Transformation Extender 安装
我在使 WMB 和 WTX 在 Windows 环境中协同工作时遇到问题。所有安装似乎都已成功安装。
现在,当我在消息流中添加 WTX 节点时,我得到 2 个异常:
- com.ibm.websphere.dtx.WTXPlugIn.BrowseLocalCompiledMap.checkCompiledMap 中的 java.lang.NullPointerException(未知来源)
- java.lang.NoClassDefFoundError: com/ibm/websphere/dtx/WTXPlugIn/WTXPlugInStringResources
我对此进行了一些搜索,发现第一个问题应该在其中一个修复包中修复。我得到了修复包并卸载并重新安装了所有东西,但我得到了相同的结果。
以下是我正在使用的版本:
- WMB 8.0.0.1(带有 FIX Pack 1 的 8.0)64 位
- 用于集成服务器的 WTX 8.4.0.3 64 位
- WTX Design Studio 8.4.0.3 32 Bit(我认为这并不重要,只是在这里列出)
- WMQ 7.5
有没有人使这种组合起作用?欢迎和赞赏任何想法或意见。
非常感谢!
backup - RabbitMQ:消息队列备份
要实现消息队列的备份和恢复,保存Mnesia数据库目录下的文件和broker配置就够了吗?我还必须在复制文件之前停止代理吗?
谢谢!
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:分配连接时出错。原因:空|#]
谁能告诉我为什么?提前谢谢了