文章标题

测试文章

import java.io.IOException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

/**
* 消息持久化
* @author menghh
*
*/
public class Send04 {

public static void main(String[] args) throws IOException {
ConnectionFactory factory = new ConnectionFactory();
//RabbitMQ-Server安装在本机，所以直接用127.0.0.1
factory.setHost("127.0.0.1");
//创建一个连接
Connection conn = factory.newConnection();
//创建一个通信通道
Channel channel = conn.createChannel();