qpid

0热度

1回答

我是Qpid的新手，我试图设置环境。在读了大量文档后，我设法下载了Apache Qpid并让它在本地主机上运行：8080 我还安装了maven，cmake。现在我正尝试在Eclipse中启动一个新的Maven项目来发送简单的消息。我不熟悉API接口和概念。我是否需要在我的项目解决方案中包含任何种类的jar或如何使用服务器？我已经找到https://github.com/apache/qpid-

0热度

2回答

用于加密消息的Qpid和JNDI

我目前正在开发JMS项目，并创建了2个密钥和2个证书以及我通过Qpid的UI创建的TrustStorage，mytruststore。在我jndi.properties文件我有以下代码： //Set the InitialContextFactory class to use java.naming.factory.initial = org.apache.qpid.jms.jndi.Jms

0热度

1回答

Azure Servicebus AMQP URL未被接受/或如何将Liberty连接到Azure服务总线

将Azure ServiceBus通过AMQP通过QPID连接到IBM WAS LibertyProfile时遇到问题。我跟着教程在Microsoft Docs Service Bus Messaging但我得到了以下异常（网址进行模糊处理）： Caused by: Not an AMQP URL amqps://POLICY:[email protected] at org.apache.q

0热度

1回答

在编译Docker Alpine中的qpid-cpp时如何解决`构建CXX对象src/CMakeFiles/qpidcommon.dir/qpid/sys/posix/Condition.cpp.o`？

Qpid-CPP已经被编译在Ubuntu的码头工人图像和当前尺寸是1.86GB： REPOSITORY TAG IMAGE ID CREATED SIZE ubuntu-qpid-cpp latest 7e60a5eabee1 44 hours ago 1.86 GB 目的要编译搬运工高山内qpid-CPP，以减少的磁盘大小图像问题一些软件包在Ubuntu可被省略或不

1热度

1回答

使用Python Qpid/Proton/Messenger（），如何从Azure事件中心过滤消息？

此要点说明如何使用Messenger（）从Azure事件中心接收消息。它效果很好。 https://gist.github.com/tomconte/e2a4667185a9bf674f59 然而，使用这种技术产生的事件集线器的所有消息。我想阅读消息，因为偏移量或时间戳（不关心哪个）。我可以在Qpid文档中看到如何设置这些要求，但在使用Messenger（）时不会。这里是在Qpid文档的相关章节

0热度

2回答

javax.jms.JMSException：现有连接被远程主机强制关闭

我是一个试图整合qpid与Apache Camel的新手。我需要编写java代码来使用qpid从队列读取和写入。所以首先我从qpid网站下载了JMS例子。我试图运行的代码是。 /* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements.

0热度

1回答

Azure中使用Spring JMS接收相同的消息被接收到多次和信息移动到DLQ

我使用qpid AMQP-1-0-客户端和相关罐连接到Azure的服务总线建立消费者。我能够连接到Azure的队列和接收消息，但问题是我从队列收到同一消息多次eventhough我处理消息之前承认它。此外，大部分时间我的信息都被转移到DLQ中。例如，如果我在队列中有500条消息，则覆盖MessageListener.onMessage（）的onMessage（）方法将执行超过500次。并将近20

-3热度

1回答

如何使用java提取对象

我正在将一个xml对象发送给JMS。当检索我收到一个对象。按照现在这一个XML我发送。但它可以是任何东西，一个XML或一个JSON。有没有办法在Java中，我可以提取这个对象并检索XML/JSON？这是我写的onMessage（）函数。 public void onMessage(Message message) { Message receivedMessage = message;

0热度

1回答

连接到耐用消费者 - Qpid质子Python

我试图让Qpid Proton Python客户端通过AMQP v1.0订阅ActiveMQ代理作为持久使用者。我可以创建持久订阅，但不太明白如何在下次运行脚本时获取相同订阅。每次运行后，ActiveMQ管理控制台都会显示已创建一个持久预订，并且根据我的脚本输入命名，但下一次运行只是创建另一个，而不是连接到之前创建的预定。我想我可能会错过创建“ClientID”（如ActiveMQ所称的），

0热度

2回答

SpringBootTest：当启动应用程序完成

春季启动集成测试看起来像这样 @RunWith(SpringRunner.class) @SpringBootTest(classes = Application) class IntegrationTest { static QpidRunner qpidRunner @BeforeClass static void init() { qpidRu