Vertx Java客户端在连接solace vmr服务器时引发“SMF AD绑定响应错误”

Question

public class Sender extends AbstractVerticle {

    private int count = 1;

    // Convenience method so you can run it in your IDE
    public static void main(String[] args) {
        Runner.runExample(Sender.class);
    }

    @Override
    public void start() throws Exception {
    AmqpBridge bridge = AmqpBridge.create(vertx);

    // Start the bridge, then use the event loop thread to process things thereafter.
    bridge.start("13.229.207.85", 21196,"UserName" ,"Password", res -> {
        if(!res.succeeded()) {
            System.out.println("Bridge startup failed: " + res.cause());
            return;
        }

        // Set up a producer using the bridge, send a message with it.
        MessageProducer<JsonObject> producer = 
            bridge.createProducer("T/GettingStarted/pubsub");

        // Schedule sending of a message every second
        System.out.println("Producer created, scheduling sends.");
        vertx.setPeriodic(1000, v -> {
            JsonObject amqpMsgPayload = new JsonObject();

            amqpMsgPayload.put(AmqpConstants.BODY, "myStringContent" + count);
            producer.send(amqpMsgPayload);

            System.out.println("Sent message: " + count++);
        });
    });
}

网桥启动失败:io.vertx.core.impl.nostackTraceThrowable:错误{condition=amqp:not-found,description='SMF AD bind response Error',info={solace.response_code=503,solace.response_text=unknown Queue}}2018年4月27日下午3:07:29 io.vertx.proton.impl.protonsessionimpl警告：接收器关闭，错误io.vertx.core.impl.nostackTraceThrowable:错误{

我已经创建队列和主题正确在solace VMR，但不能发送/接收消息。我是否缺少任何来自solace VMR服务器端的配置？上面的Vertx Sender Java代码中是否需要任何代码更改？我在传递消息时得到了上面的错误跟踪。有人能帮忙吗？

Vertx AMQP Bridge Java客户端：https://Vertx.io/docs/vertx-amqp-bridge/Java/

Answer 1

您可能会遇到此错误有几个不同的原因。

可能是客户端没有被授权发布有保证的消息。要解决这个问题，您需要在Solace路由器端的客户端配置文件中启用“保证endpoint创建”。

也可能是应用程序正在使用应答处理。Solace路由器目前不支持此功能。对此的支持将在Solace VMR的8.11版本中添加。解决办法是将ReplyHandlingSupport设置为false。

AmqpBridgeOptions().setReplyHandlingSupport(false);