我正在使用 RabbitMQ Java API 连接到 RabbitMQ 服务器。我想使用 ConnectionFactory.setUri(...)
来配置要使用的服务器。它似乎对虚拟主机进行了修改。
有一个名为 /
的默认虚拟主机。
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.net.URI;
public class Worker {
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
final URI uri = URI.create("amqp://guest:guest@localhost:5672/");
factory.setUri(uri);
final Connection connection = factory.newConnection();
final Channel channel = connection.createChannel();
}
}
使用上面的代码,配置的虚拟主机是空的。似乎没有办法使用 URI 将虚拟主机配置为
/
。有没有办法做到这一点?
最佳答案
我最终通过不使用 setUri
而是设置单个 URI 组件来解决这个问题。
关于java - 如何使用 Java RabbitMQ 并设置 URI 服务器?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17221874/