Skip to content

Persistence parameters have been set, but not in effect #476

@c-y-q

Description

@c-y-q

var amqp = require('amqp')
var connection = amqp.createConnection({
host:'127.0.0.1',
post:5672,
login:'test',
password: '123',
vhost: '/test'
})
connection.on('error',function(err){
console.log('connection err : '+err);
})
var queName = 'test_q3',exname='test_ex';
connection.on('ready',function(){
var ex = connection.exchange(${exname},{type:'fanout',durable:true,autoDelete:false});
connection.queue(${queName},{durable:true,autoDelete:false},function(q){

 q.bind(ex,queName,function(){
 	ex.publish(queName,'test msg1',{deliveryMode:2})
 	ex.publish(queName,'test msg2 msg2',{deliveryMode:2})
 })
 setTimeout(function() {
    console.log("Single queue bind callback succeeded");
 //exchange.destroy();
 //queue.destroy();node
     connection.end();
     connection.destroy();
     },1000); 
q.subscribe({ack:true,prefetchCount:1},function(msg){
	q.shift()
	console.log('receive msg : '+msg.data);
})
})

})

fdfdfdfd

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions