Comparing version 0.2.5 to 0.2.6
@@ -415,2 +415,8 @@ /* | ||
} | ||
if (l.is_sender() && opts.source === undefined) { | ||
opts.source = l.set_source({}); | ||
} | ||
if (l.is_receiver() && opts.target === undefined) { | ||
opts.target = l.set_target({}); | ||
} | ||
l.attach(); | ||
@@ -417,0 +423,0 @@ return l; |
{ | ||
"name" : "rhea", | ||
"version": "0.2.5", | ||
"version": "0.2.6", | ||
"description": "reactive AMQP 1.0 library", | ||
@@ -16,5 +16,6 @@ "homepage": "http://github.com/grs/rhea", | ||
"eslint":"", | ||
"mocha":"", | ||
"mocha":"^3.0.0", | ||
"browserify":"", | ||
"istanbul": "" | ||
"istanbul": "", | ||
"minimist":"" | ||
}, | ||
@@ -21,0 +22,0 @@ "scripts": { |
@@ -25,3 +25,3 @@ /* | ||
beforeEach(function(done) { | ||
container = rhea.create_container(); | ||
container = rhea.create_container({non_fatal_errors:[]}); | ||
listener = container.listen({port:0}); | ||
@@ -149,2 +149,3 @@ listener.on('listening', function() { | ||
container = rhea.create_container(); | ||
container.options.non_fatal_errors = []; | ||
listener = container.listen({port:0}); | ||
@@ -194,3 +195,3 @@ listener.on('listening', function() { | ||
}); | ||
var c = rhea.create_container().connect(listener.address()); | ||
var c = rhea.create_container({non_fatal_errors:[]}).connect(listener.address()); | ||
c.on('connection_error', function(context) { | ||
@@ -211,3 +212,3 @@ error_handler_called = true; | ||
}); | ||
var container2 = rhea.create_container(); | ||
var container2 = rhea.create_container({non_fatal_errors:[]}); | ||
container2.on('error', function (error) { | ||
@@ -214,0 +215,0 @@ assert.equal(error.condition, 'amqp:connection:forced'); |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
333484
7253
5