Qpid Broker-J Websocket插件AMQP 1.0
Qpid Broker-J Websocket插件是一个用于Qpid Broker-J消息代理的插件，它提供了基于WebSocket协议的AMQP 1.0通信能力。
AMQP（Advanced Message Queuing Protocol）是一种面向消息的中间件协议，用于在应用程序之间可靠地传递消息。它具有高度可扩展性、安全性和可靠性的特点，被广泛应用于云计算和分布式系统中。
Websocket是一种在单个TCP连接上进行全双工通信的协议，它允许服务器主动向客户端推送消息，而不需要客户端发起请求。通过使用Websocket插件，Qpid Broker-J可以通过WebSocket协议与客户端进行通信，实现更高效的消息传递。
Qpid Broker-J是一个开源的AMQP消息代理，它提供了可靠的消息传递和高级消息队列功能。它支持多种消息传递模式，包括点对点、发布/订阅和请求/响应模式。Qpid Broker-J还提供了丰富的管理和监控功能，使用户能够轻松管理和监控消息代理。
Qpid Broker-J Websocket插件的优势包括：
- 高效的消息传递：通过使用WebSocket协议，Qpid Broker-J可以实现低延迟、高吞吐量的消息传递，提供更好的性能和用户体验。
- 灵活的通信方式：WebSocket协议支持全双工通信，可以实现实时的消息推送和响应，适用于实时通信和即时通讯等场景。
- 安全性：Qpid Broker-J Websocket插件支持基于TLS的加密通信，保障消息的安全性和机密性。
- 可扩展性：Qpid Broker-J是一个高度可扩展的消息代理，可以根据需求灵活扩展和部署。
Qpid Broker-J Websocket插件适用于以下场景：
- 实时通信：由于WebSocket协议的特性，Qpid Broker-J Websocket插件非常适用于实时通信场景，如在线聊天、实时数据推送等。
- 分布式系统：Qpid Broker-J作为一个可靠的消息代理，可以在分布式系统中实现异步通信和解耦，提高系统的可靠性和可扩展性。
- 云计算：Qpid Broker-J Websocket插件可以与云计算平台集成，实现云上应用程序之间的可靠消息传递和通信。
腾讯云提供了一系列与消息队列相关的产品，可以与Qpid Broker-J Websocket插件结合使用，实现可靠的消息传递和通信。其中，腾讯云的消息队列CMQ（Cloud Message Queue）是一种高可用、高可靠、高性能的消息队列服务，可以满足各种消息通信需求。您可以通过以下链接了解更多关于腾讯云CMQ的信息： https://cloud.tencent.com/product/cmq
请注意，以上答案仅供参考，具体的产品选择和配置应根据实际需求和情况进行。
相关·内容
我正在使用amqp.net lite向AMQP1.0代理(qpid，rabbitmq with 1.0 plugin)发送消息。 我想发送到一个主题，并想添加一个“绑定键”，就像qpid文档(s.http://qpid.apache.org/releases/qpid-broker-j-7.1.0/book/Java-Broker-Concepts-Exchanges.html#Java-Broker-Concepts-Exchanges-Types-Topic)中描述的那样，以便将我的消息路由到特定的队列。在哪里以及如何指定绑定关键字，如示例链接中的"weather“？ 我怎么用a
浏览 12提问于2019-01-25得票数 0
我正在运行rabbitmq服务器3.1.5，并试图从Qpid 6.0.0客户机(都在Linux上运行)连接到这个代理。狂犬病经纪人正在使用AMQP0-9-1。当我试图连接从Qpid客户端，它失败的“连接重置”。从Qpid客户端堆栈跟踪(我屏蔽了IP地址的前两个八进制)：
Caused by: org.apache.qpid.AMQException: Cannot connect to broker (tcp://xx.yy.224.41:5672): Connection reset [error code 200: reply success]
at org.apache.
浏览 1提问于2016-02-06得票数 0
我正试图用Java通过AMQP1.0连接到ArtemisMQ，但到目前为止我还没有成功。我尝试了以下客户端框架：
Org.apache.qpid:qpid-客户机
Org.apache.qpid:质子-j
com.rabbitmq:amqp-client
org.apache.qpid:qpid-amqp-1-0-client-jms
我得到了一个TimeoutException错误，但不确定原因。我也传递用户+密码，但仍然没有成功。
我不想分享我的代码，因为我尝试了很多事情，它有点混乱。我的问题是，有人能共享/指向我可以用来连接到AMQP1.0代理的客户端代码吗？
我
浏览 0提问于2019-05-23得票数 0
1回答
问题1一个困扰我很长时间的话题。我正在使用(QPID) AMQP1.0，并试图启用分布式事务。有人设法做到了吗? 1.0规范()指出，amqp:distributed-transactions将在第6部分中描述，但尚未编写。
是否有人成功地使用了使用AMQP1.0的分布式事务？
问题2: QPID AMQP1.0客户端是否支持分布式事务？
问题3 Microsoft Azure Service Bus支持分布式事务吗？
浏览 9提问于2013-09-03得票数 2
回答已采纳
1回答
最新的AMQP (4.8.1)提供了使用RabbitMQ配置WSO2的文档，它不支持AMQP1.0。例如，这是否意味着WSO2不能在QPid上使用AMQP1.0？我对此感到非常困惑，因为在WSO2文档中似乎经常引用QPid。也许只是作为一个客户？我真的需要一个是/否的答案，关于通过AMQP1.0发送和接收的WSO2支持，包括远程代理。谢谢。
浏览 0提问于2015-01-24得票数 1
这个问题与相同的错误消息有关：
我的java版本是：
java版本"1.8.0_341“
Java(TM) SE运行时环境(build 1.8.0_341-b10)
Java HotSpot(TM) 64位服务器VM (构建25.341-b10，混合模式)
但是，解决方案，设置QPID_HOME环境变量不是我的解决方案。我的QPID_HOME设置为:qpid_HOME=C：\Progra~1\QPID_HOME\8.0.6
C:\Progra~1\qpid-broker\8.0.6\lib的目录是：
Volume in drive C has no label.
Volume Se
浏览 16提问于2022-11-14得票数 0
回答已采纳
spring-amqp能否与AMQP1.0代理通信，保持spring不支持AMQP1.0版本的事实？
我了解了我计划使用的QPID Proton，但我更喜欢使用Spring提供的解决方案来连接AMQP1.0。
浏览 2提问于2017-08-02得票数 1
回答已采纳
我正在为RabbitMQ消息代理评估多个C/C++客户端。我们已经通过了SimpleAmqpClient，AMQP-CPP，现在评估Apache QPID。部署设置包含一个QPIDBrokerv3.6.12(启用了rabbitmq-amqp1.0插件)和一个QPID C++客户端。
QPID客户端是否支持基于C++的通道加密以及对代理的身份验证？我已经浏览了文档，但我没有找到使用QPID C++客户端的基于SSL的通道加密的具体示例。但是，我找到了适用于Java客户端的示例。
浏览 1提问于2017-10-31得票数 1
我正在使用，一个node.js库来开发AMQP1.0客户端。
我正在尝试使用 x匹配的表达式而不是JMS表达式来调整示例。
其目的是实现基于AMQP1.0兼容代理(，Qpid，.)的报头路由机制。
我在recv.js中的适当部分尝试了这段代码：
connection.open_receiver({
source: {
address: 'amq.match',
filter: {
'x-match': 'all',
value: {
浏览 0提问于2019-03-04得票数 1
回答已采纳
我正在使用qpid客户端Java库(版本0.32)集成AMQP1.0。
我必须传输一个字节数组(小于5mb)，但是这条消息从未传递给订阅者。我通过wireshark记录了这些帧，传输帧被标记为TCP窗口完全。库可能没有划分有效载荷。密码正确吗？我要配置什么？
代理:Apache阿波罗1.7.1 (默认配置)
pom.xml
<dependency>
<groupId>org.apache.geronimo.specs</groupId>
<artifactId>geronimo-jms_1.1_spec&l
浏览 1提问于2018-04-27得票数 0
回答已采纳
1回答
我正在尝试使用AMQP为我的项目实现Windows Service Bus 1.1，我已经安装了Windows Service Bus 1.1并使用Service bus Explorer创建了一个名为test的队列，我正在使用以下链接中给出的Java程序测试示例Service Bus功能。
https://msdn.microsoft.com/en-us/library/dn574799.aspx
In the example given above link i have removed if else code starting with if(type.compareTo("
浏览 3提问于2017-05-16得票数 0
1回答
在运行qpid应用程序接口教程时，我遇到了"Session and by peer with amqp:internal-error“，我认为这是由于qpid和我的代理( c++ )的不同版本造成的。 我已经将rabbitmq更改为使用协议1.0，但它看起来qpid缺省值为0-10。我发现有一堆文章说我应该升级到api的1.0版，但我还不能弄清楚该如何升级。有人知道怎么做吗？
浏览 10提问于2019-06-08得票数 1
回答已采纳
1回答
我正在尝试将我的应用程序的AMQP版本升级到1.0(QPID 0.24.0)。目前，Connectionfactory URL的格式如下。
amqp://guest:guest@test/test?brokerlist='tcp://ip1:5672?ssl='true'&ssl_cert_alias='cert1''
我尝试过将URL更改为以下格式，并尝试了不同的组合(蛮力)
amqps://hostname:port?option=value&option2=value..
我总是犯错误
根异常是java.lang.Ille
浏览 1提问于2017-09-04得票数 1
4回答
我正在尝试用AMQP协议连接Java客户端的Azure服务总线
我遵循以下链接中的指示：
1)在Azure门户中创建了服务总线，其名称空间为“availo”，队列名为“queue1”
2)从服务总线连接信息中可以得到以下信息：
SharedAccessKeyName=RootManageSharedAccessKey
SharedAccessKey={key}
3)为JNDI查找创建了"servicebus.properties“文件
connectionfactory.SBCF = amqps://RootManageSharedAccessKey:encoded(key)@
浏览 5提问于2014-10-05得票数 2
我们将从java代码启动qpid代理。使用的库是qpid-broker-core，qpid-broker-plugins-AMQP-1-0协议，qpid-broker-plugins-management-http。
Map<String, Object> attributes = new HashMap<>();
attributes.put("type", "Memory");
attributes.put("qpid.broker.defaultPreferenceStoreAttribute
浏览 20提问于2022-07-21得票数 1
1回答
我正在尝试配置
celery==3.1.24
使用
apache-activemq-5.10.0
在python django应用程序中。
当我运行应用程序时，我在activemq控制台中得到以下异常。
org.apache.activemq.transport.amqp.AmqpProtocolException:无法解码AMQP帧:十六进制: 414d515001010009 at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:233)
浏览 1提问于2018-03-30得票数 0
回答已采纳
1回答
嗨，骆驼/jms开发者。使用Apache Camel amqp jms连接器。作为一名经纪人ActiveMQ。
我的配置是相当默认的。
下面是一个消费者代码示例：
public static void main(String[] args) throws Exception {
AMQPComponent amqpComponent = AMQPComponent.amqpComponent(HOST, USER, PWD);
CamelContext context = new DefaultCamelContext();
context.addComponent(
浏览 0提问于2018-08-08得票数 1
1回答
我正在使用activeMQ而不是rabbitMQ，但在使用log4net的“应用程序发行商”上仍然使用amqp协议。
但在将消息发布到activeMQ时出现以下错误，并在此处进行了相关讨论：
INFO | ActiveMQ WebConsole available at http://localhost:8161/
INFO | Initializing Spring FrameworkServlet 'dispatcher'
INFO | jolokia-agent: No access restrictor found at classpath:/jolokia-acc
浏览 1提问于2014-05-31得票数 2
我正在尝试使用启动器连接到Azure服务总线(我理解它在幕后使用 )。
当我将连接字符串(amqphub.amqp10jms.emote-url)设置为使用'amqps://‘时，将向Azure队列发送hello world消息，然后由应用程序重新打印。
然而，当我使用"amqpwss://Endpoint:443“连接字符串时，我会收到一个异常.
Caused by: io.netty.handler.codec.http.websocketx.WebSocketHandshakeException: Invalid handshake response getStatus:
浏览 1提问于2020-07-24得票数 2
回答已采纳
我正在尝试从源代码构建Qpid消息传递API (C++, bindings)。生成是在RHEL上触发的，下面的链接中提到的所有先决条件都已安装。
然而，当达到一步时:使所有
我得到的是这个
错误：
Linking CXX shared library libqpidclient.so
[ 86%] Built target qpidclient
Scanning dependencies of target qpidmessaging
[ 86%] Building CXX object src/CMakeFiles/qpidmessaging.dir/qpid/messaging/amqp
浏览 4提问于2017-12-07得票数 1
回答已采纳
我正在使用Camel 2.13.3，并试图通过AMQP建立到远程ActiveMQ实例的连接。
根据，应该足以添加以下依赖项
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-amqp</artifactId>
<version>2.13.1</version>
</dependency>
然后，它指示您应该将jms组件配置为使用由QPID项目提供的连接工厂。docs页面使用org.apach
浏览 0提问于2015-08-13得票数 2
回答已采纳
我正在尝试通过AMQP1.0协议向Qpid代理发送一条消息。该队列名为queue2，并且已在默认的虚拟主机下创建。然而，producer.send(message)永远被卡住了。同样的代码也适用于连接到Azure服务总线。我使用的是qpid-jms-client 0.58。生产者代码是：
Hashtable<String, String> hashtable = new Hashtable<>();
hashtable.put("connectionfactory.myFactoryLookup", protocol + "://" +
浏览 15提问于2021-09-10得票数 0
我试图使用连接到windows服务总线，尝试使用java中的AMQP连接服务总线。
private String SbConnStrACS = "amqps://" + SbUsername + ":" + encode(SbPassword) + "@" + SbDomain;
private String SbQueueName = SbNamespace + "/testq";
我正在使用以下版本的库
<dependency>
<groupId>org.apache.geronimo.spec
浏览 1提问于2017-10-16得票数 1
回答已采纳
关于上面的问题: AMQP 1.0是否有完全支持点对点(点对点，无代理)功能的Java库？ 我缺少的部分是为直接传入的消息打开本地端口而不通过代理的功能。 到目前为止，我已经使用了SwiftMQ AMQP1.0客户端库，它可以通过代理发送和接收(这里使用的是RabbitMQ服务器，没有任何缺陷)，也可以直接发送到另一个端点。 另一个端点是使用AMQPNetLite库用C#编写的。我发现AMQPNetLite库通过ContainerHost类提供了上述功能(另请参阅here)。 我最好的猜测是QPID Proton-J以某种方式支持我正在寻找的东西，但文档和示例很少。QPID Proton库的
浏览 13提问于2020-04-08得票数 1
回答已采纳
我使用基于Qpid-Proton-0.10(Python)- AMQP1.0的消息传递库向Azure事件中心发送数据。要接收数据，我按照以下指南使用EventProcessorHost：。当通过该方法接收数据时，我看到两个垃圾值在数据之前被附加：
在使用Qpid的recv.py接收相同字符时，我没有看到这样的字符。有谁面临同样的问题吗？
P.S:我还使用Azure Python 向Azure事件中心发送数据，并使用Qpid的EventProcessorHost和recv.py接收数据，并且没有遇到这样的问题。只是因为Azure SDK不包含任何接收事件的方法，所以我必须切换到Qpid
浏览 1提问于2015-09-23得票数 1
我正在使用Apache Camel和camel-amqp组件来与ASB队列通信。
<bean id="jmsConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
<property name="remoteURI" value="amqps://${service.bus.uri}?amqp.idleTimeout=120000" />
<property name="username"
浏览 1提问于2019-06-11得票数 2
回答已采纳
I尝试使用故障转移URI(故障转移URI. )连接到一个RabbitMQ集群(启用AMQP1.0插件)，使用Qpid JMS0.48.0客户端并启用SSL。
这样做是行不通的：
failover:(amqps://host1:5671?transport.verifyHost=false,amqps://host2:5671?transport.verifyHost=false,amqps://host3:5671?transport.verifyHost=false)
但是，这是有效的(没有SSL)：
failover:(amqp://host1:5672,amqp://host2:5672
浏览 6提问于2020-01-08得票数 0
1回答
我们使用ActiveMQ，php和stomp。我们发现，当ActiveMQ重启时，使用stomp的用户无法识别丢失的连接。我发现，只有stomp 1.2支持心跳。而ActiveMQ使用的是stomp 1.1，最新的php stomp实现只支持1.0版本。我也尝试了amqp，但最新的实现，我发现ActiveMQ支持0.9.1，ActiveMQ使用1.0版本，当客户端连接amqp时返回错误：
WARN | Connection attempt from non AMQP v1.0 client. AMQP,0,0,9,1
WARN | Transport Connection to: tcp://
浏览 28提问于2015-12-11得票数 2
我目前正在研究如何使用Qpid JMS连接到Azure服务总线(qpid-jms-client-0.11.1.jar)。
我已经创建了一个Demo应用程序SimpleSenderReceiver，它使用下面的指南()连接到已经配置的Azure。这段代码似乎使用了一个“非常”老版本的Qpid JMS客户端(版本0.32)。我现在正试图让它与Qpid JMS的最新稳定版本(qpid-jms-client-0.11.1.jar)一起工作，到目前为止，我还没有成功。通过查看QPIDJMS0.11.1的文档，您可以看到属性连接工厂在属性文件中的方式与0.32版本中的不同。
如何在属性文件中设置正确的
浏览 6提问于2016-10-27得票数 2
回答已采纳
1回答
我尝试将Azure Service Bus与Apache Qpid结合使用，并将Spring Integration与transactions结合使用。
但似乎Azure Service Bus AMQP实现不支持事务。是真的吗？我没有找到相关信息。
这是我的JMS配置
<bean id="serviceBusConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
<constructor-arg value="amqps://${serviceB
浏览 4提问于2017-07-03得票数 1
我使用的是ActiveMQ 5.8.0，它支持AMQP1.0作为队列代理。我试图使用Qpid AMQP1.0客户端jms库与Java客户机进行通信，但没有看到指定keystore和信任存储信息的方法。
我通过Java选项(例如-Djavax.net.ssl.keyStore)传递SSL凭据，成功地配置了一个客户端，但是对于我的最终解决方案来说，这是一个不可接受的方法.我需要能够从代码中指定这些信息。
我目前正在使用createFromURL方法从包含参数的URL中生成连接，但密钥存储信息(以及潜在的故障转移参数)似乎没有从解析。
String connectionUrl = "amqp
浏览 3提问于2013-10-03得票数 2
回答已采纳
我正在尝试将旧的Qpid设置(基于AMQP0-X)升级到基于AMQP1.0的Qpid的最新质子版本，并且遇到了从客户端动态创建持久或非持久队列/主题的问题。我们过去可以利用Spring的jms-generic:queue:someQueueName (在某些情况下是主题)来实现这一点，在通过动态目标解析器之后，它最终会为我们创建队列或主题。然而，情况似乎不再是这样，因为createQueue/Topic不再创建实际的队列或主题(至少我在关于createQueue/Topic的JMS文档中读到的)。
因此，我的担忧最终归结为：
1)是否仍然可以使用最新的Qpid JMS和Broker-J动态创建
浏览 15提问于2019-03-28得票数 0
我正在尝试用camel (Version2.17)组件连接到我的骆驼路由中的rabbitmq。
我已将其配置如下：
@Bean
CachingConnectionFactory jmsCachingConnectionFactory(){
JmsConnectionFactory pool = new JmsConnectionFactory();
pool.setRemoteURI("amqp://127.0.0.1:5672");
pool.setUsername("guest");
浏览 0提问于2016-07-08得票数 5
回答已采纳
我正在尝试执行这个，但是我得到了以下类未找到的异常：
javax.naming.NoInitialContextException: Cannot instantiate class: org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory [Root exception is java.lang.ClassNotFoundException: org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory]
at javax.
浏览 8提问于2015-06-13得票数 2
回答已采纳
1回答
在Quarkus应用程序中使用我的ActiveMQ代理有问题。第一次使用时，我想尝试使用中的示例，并且我的所有内容都与示例中的示例(PriceConsumer、PriceProducer、Resource、quarkus-qpid-jms依赖项和quarkus.qpid-jms -用户名/密码)完全相同，除了quarkus.qpid-jms.url，因为有带有amqp的端点，但是我不能使用，我有带有amqp+ssl<code>e 210</code>协议的端点。
当我尝试使用这个端点运行应用程序时，它会返回错误：
"loggerName":"or
浏览 9提问于2022-05-16得票数 0
回答已采纳
1回答
我正在尝试将Apache集成到Spring应用程序中。由于我在这两方面都是新手，所以我想在开始实施我的项目之前尝试几个例子。这是文件-
Config.java
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.naming.Context;
import javax.naming.InitialContext;
impor
浏览 4提问于2016-02-14得票数 0
我们试图在ActiveMQ 5.9.1之上构建一个作业队列系统。我们在activemq中使用AMQP1.0支持，目前客户端代码使用qpid jms库。
对于作业队列系统来说，重要的是我们可以将预取设置为1-我们希望我们的工作人员一次只能得到一个任务，竞争的消费者模式。qpid库使用连接工厂定义支持这一点，如下所示：
connectionfactory.activemq-amqp-manager = amqp://{user}:{password}@{hostname}:{port}?clientid=job-manager&remote-host=default&max-pre
浏览 6提问于2014-06-10得票数 0
回答已采纳
2回答
每个人：
我对qpid很陌生，遇到了一些问题。我创建的交换不能将消息路由到队列，如下所示：
首先，我使用quid-config命令在qpid中创建了一个durbale队列“test- queue -1”：
qpid-config add queue test-queue-1 --durable
接下来，我在qpid中创建一个持久的直接交换“test- exchange -1”，还使用qpid-config命令：
qpid-config add exchange direct test-exchange-1 --durable
最后，按以下命令绑定它们：
qpid-config bind t
浏览 3提问于2015-04-06得票数 1
回答已采纳
我们使用qpid-jms-client-0.57.0发布和接收来自Azure ServiceBus的消息。ServiceBus提供了从会话接收消息以维护消息顺序的功能。有关更多细节，请参阅这里-
我能够用JMXGroupId发布消息，但不能从启用会话的队列中接收消息。获取错误- javax.jms.JMSException：需要会话的实体不可能创建非会话消息接收方 TrackingId:*，时间戳:2021-07-28T11:07:49 TrackingId:** SystemTracker:gateway7 7，时间戳:2021-07-28T11:07条件=amqp:不允许
您是否可以建议
浏览 7提问于2021-07-28得票数 0
我很难让Azure ServiceBus通过AMQP通过QPID连接到IBM。我在上学习了教程，但得到了以下异常( URL是模糊的)：
Caused by: Not an AMQP URL amqps://POLICY:ENCODEDKEY@NAMESPACE.servicebus.windows.net
at org.apache.qpid.url.URLHelper.parseError(URLHelper.java:143)
at org.apache.qpid.url.URLHelper.parseError(URLHelper.java:138)
at org.apache.qpid
浏览 4提问于2017-04-26得票数 0
回答已采纳
我在我的母语扩展中包括以下内容:-
#include "qpid/client/Connection.h"
#include "qpid/client/Message.h"
#include "qpid/client/Session.h"
我使用本机扩展的Dart代码工作，一切都很好，但是如果我包括以下内容的话:-
#include "qpid/client/SubscriptionManager.h"
我突然明白:-
找不到扩展library'file:///home/steve/Development/google
浏览 2提问于2014-01-16得票数 0
回答已采纳
我尝试从一个Qpid JMS客户机0.45.0 (它支持AMQP1.0和JMS2.0)连接到一个RabbitMQ 3.7.18代理(启用了AMQP1.0插件)。
我将消息发送到"/queue/ gruik“(即与路由键"gruik”的默认交换，也就是gruik队列)。队列是使用javax.jms.Session#createQueue("/queue/gruik").从客户端动态创建的。我可以看到连接是在RabbitMQ中很好地启动的，并且队列也是创建的。
但由于以下错误，我实际上无法发送消息：
在客户端：
javax.jms.JMSException: {{b
浏览 1提问于2019-09-24得票数 0
我们使用下面的AMQP jars将消息从java发送到windows server(1.1)上的服务总线中的队列设置。发送小消息时没有问题，但无法发送在pre prod中大小超过45kb，在prod中大小超过160kb的消息。消息根本没有命中队列，在Java端也没有异常。
geronimo-jms_1.1_spec-1.0.1.jar qpid-amqp-1-0-client-0.22.jar qpid-amqp-1-0-client-jms-0.22.jar qpid-amqp-1-0-common-0.22.jar
收到的消息在网关配置中配置正确。
我只是想知道是什么导致了这个消息大小限制
浏览 2提问于2017-04-04得票数 0
我正在尝试使用从浏览器中向正在运行的实例发送AMQP1.0消息。我能够使用node.js版本发送和接收消息。
我想我必须添加/激活，我只是找不到任何关于在哪里以及如何做到这一点的文档。
到目前为止，有人这么做过吗？
以下是我的浏览器版本片段：
var server = "ws://localhost:5673";
var client = require("rhea");
client.options.username = "guest";
client.options.password = "guest";
client
浏览 13提问于2019-03-26得票数 0
回答已采纳
我正在尝试使用AMQP1.0连接到一个ActiveMQ代理，但我想在我的应用程序代码中使用JMS1.0。我对使用JMS感兴趣，主要是因为我希望开发人员能够使用他们已经熟悉的API。
我在localhost上运行了ActiveMQ 5.14.0，并编写了以下代码：
public static void main(String[] args) throws JMSException, InterruptedException {
Connection connection = null;
try {
// Producer
Connecti
浏览 2提问于2016-09-16得票数 1
回答已采纳
6回答
使用Service Bus for Windows开发Java应用程序可用的选项有哪些？
Java -这需要ACS来处理，而SB for Win不支持这一点。
AMQP -这似乎不适用于，我一直让errororg.apache.qpid.amqp_1_0.client.Sender$SenderCreationException: Peer没有为链接创建远程端点，target：
而相同的代码则适用于Azure SB。那么，上的AMQP似乎还没有完全发挥作用？
如果我漏掉了什么就纠正我？
更新以在本地机器上测试AMQP，这就是我所做的
在我的本地机器上安装了服务总线1.1
浏览 1提问于2013-12-01得票数 2
回答已采纳
我一直试图为Node.js找到一个Apache客户端。
我发现了这个包，但是它太老了，甚至没有安装QPD-质子-C0.3，就像自述的那样。
我只是想要一个Node.js的AMQP客户端，它可以成功地与QPID C++代理对话。
我为Node.js找到的大多数AMQP客户端(如)(AMQP0-9-1)都不能与QPID C++ Broker (AMQP1-0和0-10)进行互操作。
任何帮助都将不胜感激。
浏览 1提问于2014-06-14得票数 1
回答已采纳
我们现在使用QPID作为AMQP解决方案，而不是Rabbitmq，但我无法找到像Rabbitmq那样简单的检查队列和主题的方法。
QPID中有什么工具可以做到这一点吗？我看到一些qpid-stat，qpid-工具，qpidd，但这没有帮助。有可用的样品或文件吗？在qpid.apache.org上找不到多少。
谢谢。
浏览 1提问于2013-11-08得票数 0
回答已采纳
1回答
嗨，我正在使用嵌入式代理Qpid测试spring集成项目。但问题是我如何在qpid中排队和交换。我认为兔子-config.xml会在qpid代理中建立队列和交换，但没有效果。我的流程是在qpid代理中创建队列和交换，将消息传递给它们，而限制在这些队列上的入站amqp适配器将得到消息，我可以继续进行测试。
错误: Queue：'push.customer.arkona.controller.search‘在VirtualHost 'default’上找不到。
qpid-config.json:
{ "name": "EmbeddedB
浏览 0提问于2018-05-16得票数 0
回答已采纳
1回答
我无法让OpenNMS向AMQP端点发送消息。我从来没有做过这样的工作，这是我第一次使用OpenNMS和AMQP，这样可以减少我的经验不足。
我已经配置了RabbitMQ 3.5.7并按照这个对其进行了测试。它在使用外部QPID 0.32客户端时工作得很好，在使用python或perl时也很好。works的定义是:建立通信，将消息有效负载传输到交换中，然后将其传递到后端队列。然后，可以在RabbitMQ管理GUI中查看消息。
在OpenNMS中，我一直遵循从EventForwarder开始的指令，然后尝试了AlarmNorthbounder，两者都产生了NullPointerException
浏览 2提问于2016-06-12得票数 1
回答已采纳
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
