@@ -119,25 +119,19 @@ The following code connects to an AMQP broker:
119
119
120
120
@code java
121
121
ConnectionFactory factory = new ConnectionFactory();
122
- IProtocol protocol = Protocols.FromEnvironment();
123
- IConnection conn = factory.CreateConnection(protocol, hostName, portNumber);
122
+ factory.UserName = user;
123
+ factory.Password = pass;
124
+ factory.VirtualHost = vhost;
125
+ factory.Protocol = Protocols.FromEnvironment();
126
+ factory.HostName = hostName;
127
+ factory.Port = AmqpTcpEndpoint.UseDefaultPort;
128
+ IConnection conn = factory.CreateConnection();
124
129
125
130
The default parameters are:
126
131
- username: [code "guest"]
127
132
- password: [code "guest"]
128
133
- virtual-host: [code "/"]
129
134
130
- For control over the username, password and virtual-host supplied to
131
- the broker, modify the [code ConnectionFactory]'s [code
132
- ConnectionParameters] object before calling [code CreateConnection]:
133
-
134
- @code java
135
- ConnectionParameters params = factory.Parameters;
136
- params.UserName = userName;
137
- params.Password = password;
138
- params.VirtualHost = virtualHost;
139
- IConnection conn = factory.CreateConnection(protocol, hostName, portNumber);
140
-
141
135
The IConnection interface can then be used to open a channel:
142
136
143
137
@code java
0 commit comments