File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -59,7 +59,16 @@ class ServiceSubRabbit extends ServiceSub {
59
59
this . _subscriptions [ i ] = { } ;
60
60
61
61
let info = yield this . getServiceInfo ( i ) ;
62
- let rabbitAvailable = info ? Object . keys ( info . modules ) . some ( key => key == "pub-rabbit" ) : false ;
62
+ let rabbitAvailable = false ;
63
+ try {
64
+ rabbitAvailable = info ? Object . keys ( info . modules ) . some ( key => key == "pub-rabbit" ) : false ;
65
+ } catch ( err ) {
66
+ this . logger . warn ( "Cannot load info.modules:" , error ) ;
67
+ }
68
+ // We don't want to use fallback, throw error instead
69
+ if ( ! rabbitAvailable ) {
70
+ throw new Error ( "Rabbitmq is not available, error subscribing" ) ;
71
+ }
63
72
64
73
for ( let event in desc [ i ] ) {
65
74
let channel = yield this . _connection . createChannel ( ) ;
You can’t perform that action at this time.
0 commit comments