Ballerina java.js:如何设置请求-回复通信

Question

我能够与Ballerina版本0.983.0建立请求/回复通信，但在版本1.2.7中失败。有人能给我建议吗。

这是我尝试过的代码：

jms:Connection connection = check jms:createConnection(jmsConfig);
jms:Session session = check connection->createSession({acknowledgementMode: "AUTO_ACKNOWLEDGE"});
jms:Destination queue = check session->createQueue("MyQueue");
jms:Destination tempQueue = check session->createTemporaryQueue();
jms:MessageProducer producer = check session.createProducer(queue);
jms:TextMessage msg = check session.createTextMessage("Hello Ballerina!");
check producer->send(msg);
jms:MessageConsumer consumer = check session->createConsumer(tempQueue);
jms:Message? response = check consumer->receive(3000);
if (response is jms:TextMessage) {
var val = response.getText();
if (val is string) {
log:printInfo("Message received: " + val); 
} else {
log:printInfo("Message received without text");
}
} else {
log:printInfo("Message received.");
}

这会导致以下错误：

error: java.lang.ClassCastException message=java.lang.String incompatible with javax.jms.Destination
at ballerina.java_jms.C:.src.java$$$jms.session:createJmsConsumer(/C:/src/java.jms/session.bal:343)
ballerina.java_jms.Session:createConsumer(/C:/src/java.jms/session.bal:223)
acme.jmsTest:main(main.bal:30)

当我将消费者使用的目的地更改为与生产商使用的相同时(即"队列"(，就像在样本中一样，一切都很好。所以，要么我以错误的方式使用了临时队列，要么临时队列出现了错误。

Answer 1

我可以用Ballerina 1.2.7和使用ActiveMQ服务器的Ballerina/java.jms 0.8.1重现同样的错误。

error: java.lang.ClassCastException message=java.lang.String cannot be cast to javax.jms.Destination
at ballerina.java_jms.src.java$$$jms.session:createJmsConsumer(/src/java.jms/session.bal:343)
ballerina.java_jms.Session:createConsumer(/src/java.jms/session.bal:223)
user.jms_request_reply:main(main.bal:17)

我创建了一个问题来跟踪这一点。希望这将在未来的版本中得到修复。

你能告诉你使用的消息代理吗？如果用例不是特定于broker的，那么您可以查看ballerina中的其他几个消息连接器选项。

• RabbitMQ
• NATS
• 卡夫卡