File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11var sockets = require ( './lib/sockets' ) ;
22
33module . exports = sockets ;
4- module . exports . createContext = function ( url ) {
5- return new sockets . Context ( url ) ;
4+ module . exports . createContext = function ( url , connOpts ) {
5+ return new sockets . Context ( url , connOpts ) ;
66}
Original file line number Diff line number Diff line change @@ -33,11 +33,11 @@ function errorLater(obj) {
3333function ignore ( ) { } // for stubbing out methods I don't care about;
3434 // i.e., _read
3535
36- function Context ( url ) {
36+ function Context ( url , connOpts ) {
3737 EventEmitter . call ( this ) ;
3838 var self = this ;
3939 var onError = errorLater ( this ) ;
40- var c = this . _connection = amqp . connect ( url ) ;
40+ var c = this . _connection = amqp . connect ( url , connOpts ) ;
4141 c . then ( function ( conn ) {
4242 conn . on ( 'error' , onError ) ;
4343 [ 'close' , 'blocked' , 'unblocked' ] . forEach ( function ( ev ) {
You can’t perform that action at this time.
0 commit comments