Permalink
Browse files

update firehose for consistency

  • Loading branch information...
michaelplaing committed Jun 29, 2012
1 parent 75f49fc commit 5b36a08dabd6e24059f30c587d967d3c2bd67377
Showing with 22 additions and 5 deletions.
  1. +11 −3 test2/firehose.js
  2. +11 −2 test2src/firehose.coffee
View

Some generated files are not rendered by default. Learn more.

Oops, something went wrong.
View
@@ -8,7 +8,7 @@ argv = require('optimist')
.demand('port').describe('port', 'Port').default('port', 5672)
.demand('vhost').describe('vhost', 'Virtual Host').default('vhost', '/')
.demand('login').describe('login', 'Login').default('login', 'guest')
- .demand('password').describe('password', 'Password').default('password', 'starbuck')
+ .demand('password').describe('password', 'Password')
.argv
amqp = require '../amqp'
@@ -61,7 +61,16 @@ exec "rabbitmqctl trace_on -p #{argv.vhost}", (error, stdout, stderr) ->
console.log error
process.exit 1
- amqp_connection = amqp.createConnection()
+ {host, port, vhost, login, password} = argv
+
+ options =
+ host:host
+ port:port
+ vhost:vhost
+ login:login
+ password:password
+
+ amqp_connection = amqp.createConnection options
amqp_connection.on 'ready', () ->
default_exchange = amqp_connection.exchange()

0 comments on commit 5b36a08

Please sign in to comment.