Apache Qpid JMS客户端消息生成器卡住，无法传递到队列

Question

我试图通过AMQP 1.0协议向Qpid代理发送消息。队列名为queue2，它已经在默认的虚拟主机下创建。但是，producer.send（消息）永远卡住了。相同的代码适用于连接到Azure服务总线。我使用的是qpid-jms-Client 0.58。生产者代码是：

Hashtable<String, String> hashtable = new Hashtable<>();
hashtable.put("connectionfactory.myFactoryLookup", protocol + "://" + url + "?amqp.idleTimeout=120000&amqp.traceFrames=true");
hashtable.put("queue.myQueueLookup", queueName);
hashtable.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");

Context context = new InitialContext(hashtable);

ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup");
queue = (Destination) context.lookup("myQueueLookup");

Connection connection = factory.createConnection(username, password);
connection.setExceptionListener(new AmqpConnectionFactory.MyExceptionListener());

connection.start();

Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// session.createQueue("queue3");
Queue queue = new JmsQueue("queue2");
MessageProducer messageProducer = session.createProducer(queue);
TextMessage textMessage = session.createTextMessage("new message");
messageProducer.send(textMessage) 

生产时应用程序的线程转储

java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0x000000078327c550> (a org.apache.qpid.jms.provider.ProgressiveProviderFuture)
    at java.lang.Object.wait(Object.java:502)
    at org.apache.qpid.jms.provider.ProgressiveProviderFuture.sync(ProgressiveProviderFuture.java:154)
    - locked <0x000000078327c550> (a org.apache.qpid.jms.provider.ProgressiveProviderFuture)
    at org.apache.qpid.jms.JmsConnection.send(JmsConnection.java:773)
    at org.apache.qpid.jms.JmsNoTxTransactionContext.send(JmsNoTxTransactionContext.java:37)
    at org.apache.qpid.jms.JmsSession.send(JmsSession.java:964)
    at org.apache.qpid.jms.JmsSession.send(JmsSession.java:843)
    at org.apache.qpid.jms.JmsMessageProducer.sendMessage(JmsMessageProducer.java:252)
    at org.apache.qpid.jms.JmsMessageProducer.send(JmsMessageProducer.java:182)

我尝试运行这个示例，得到了相同的结果。

Answer 1

好了，终于有问题了。文件系统已满90%以上，强制执行流控制。所以从我的机器上删除了文件，它开始工作了。https://qpid.apache.org/releases/qpid-broker-j-7.0.7/book/Java-Broker-Runtime-Disk-Space-Management.html

Answer 2

通常，如果客户端不发送，是因为远程服务器没有授予它这样做的权限。您可以使用协议跟踪功能调试客户端状态（只需设置PN\u trace\u FRM=true并运行客户端）。

可能您以某种方式错误配置了Broker-J，并且您创建的目的地不允许发送任何消息，或者您发送的消息太多，超出了写入限制。您应该参考配置指南并查看您已经设置的内容。