forked from amqp/rhea
-
Notifications
You must be signed in to change notification settings - Fork 0
/
simple_sasl_client.js
40 lines (39 loc) · 1.53 KB
/
simple_sasl_client.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
/*
* Copyright 2015 Red Hat Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
var container = require('rhea');
var args = require('../options.js').options({
'username': { describe: 'username to connect with'},
'password': { describe: 'password to connect with (will use PLAIN)'},
'h': { alias: 'host', default: 'localhost', describe: 'dns or ip name of server where you want to connect'},
'p': { alias: 'port', default: 5671, describe: 'port to connect to'}
}).help('help').argv;
/**
* Default SASL behaviour is as follows. If the username and password
* are both specified, PLAIN will be used. If only a username is
* specified, ANONYMOUS will be used. If neither is specified, no SASl
* layer will be used.
*/
if (args.username) {
container.options.username = args.username;
}
if (args.password) {
container.options.password = args.password;
}
container.on('connection_open', function (context) {
console.log('Connected!');
context.connection.close();
});
container.connect({ port: args.port, host: args.host });