evque:基于AMQP的事件总线 源码

evque 基于AMQP的事件总线。 安装 npm i evque --save 描述 每个event = exchange fanout类型,以事件命名。 每个subscriber =绑定到exchange queue ,以事件和订户命名。 动机 简单的项目引导 代理重新启动后会保留事件 事件将等待其侦听器(如果侦听器处于脱机状态,则事件不会消失) 例子 var bus = require ( 'evque' ) ( 'amqp://localhost' ) ; bus . on ( 'error' , function ( ev ) { console . log ( 'listener %s failed to handle event %s (%j) due to %s' , ev . listener , ev [ 'event' ] , ev . data , e