badman-data-rabbit-starter

Rabbit AMQP0.9 MiddleSoft

Demo API:

Declare Instances:

export default class DemoConsumer implements RabbitConsumer{

private rabbitAdminTemplate:RabbitAdminTemplate;

constructor () {
this.rabbitAdminTemplate = SingletonObjectFactory2.Instance(RabbitAdminTemplate.name);
}

async consume (channel: Channel, message: ConsumeMessage): Promise {

try {
doSometing();
} catch (e) {
this.logger.debug('Error->',e);
}
return ;
}


}



export default class DemoProducer implements RabbitConsumer{

private rabbitTemplate:RabbitTemplate

constructor () {
this.rabbitTemplate = SingletonObjectFactory2.Instance(RabbitTemplate.name);
}

send(){
this.rabbitTemplate.send(......);
}

}


async loadRabbit(){

this.logging = await SingletonObjectFactory2.initWithArgs(Logging,['log4js_properties.json']);

let rabbitProperties:RabbitProperties = {};

let rabbitConnectionFactory:RabbitConnectionFactory = await SingletonObjectFactory2.initWithArgs(AmqpConnectionFactory,
[rabbitProperties,this.logging.logger(AmqpConnectionFactory.name)]);

this.rabbitAdminTemplate = await SingletonObjectFactory2.initWithArgs(RabbitAdminTemplate,
[this.logging.logger(RabbitAdminTemplate.name),rabbitConnectionFactory]);

this.rabbitTemplate = await SingletonObjectFactory2.initWithArgs(RabbitTemplate,
[this.logging.logger(RabbitTemplate.name),rabbitConnectionFactory]);

this.rabbitAdminTemplate.declareAckConsumer('queueName',new DemoConsumer());
}