var rabbitmq= {
        hostname:"192.1",
	port:"5672",
	username:"dep",
	password:"devl8",
	authMechanism: "AMQPLAIN" ,
	pathname:"/",
	ssl: { 
		enabled : false  
    }  
}


var open = require('amqplib').connect(rabbitmq).then(function(conn){
		  conn.createChannel().then((ch)=>{       //创建通道
			
			ch.assertExchange('api', 'topic',{durable:true}).then(function(ex) {    //连接交换机
					
					ch.assertQueue("topic").then(function(q) {     //连接队列
                                                             //队列     交换机     Rounting KEY   arguments
						 ch.bindQueue(q.queue,ex.exchange,"topic",{'x-match': 'any',
						 'foo': 'bar',
						 'baz': 'boo'})      //交换机bind队列
						                               //Routing key
						var a =ch.publish(ex.exchange, 'topic', new Buffer(JSON.stringify({name:"chendong"})), {headers: {baz: 'boo'}})
					     if(a){
							console.log("发送成功")
						//  conn.close()
						 }else{
							console.log("发送失败");
						//  conn.close()
						 }

						
					});
				});
		  })




},console.error)