I am using RabbitMQ Java API to connect to the RabbitMQ server. I want to use the Using the above code, the configured virtual host is empty. There is no way to use URI to configure virtual hosts that have Is there any way to do this? I am not using it as ConnectionFactory.setUri (...) to configure which server to use. It appears that the virtual host is merged.
/ is a default Virtual Host named.
import com.rabbitmq.client.ConnectionFactory; Import com.rabbitmq.client.Connection; Import com.rabbitmq.client.Channel; Import java.net.URI; Public Work Worker {Public Fixed Zero Main (string [] argv throws exceptions {ConnectionFactory factory = New ConnectionFactory (); Final URI Uuri = URI.create ("amqp: // guest: localhost @ 5672 /"); Factory.setUri (URI); Last connection connection = factory.New connection (); Last channel channel = connection.createChannel (); }}
/ .
setUri but rather to individual URI components Setting up has ended.
No comments:
Post a Comment