VIPJAVA/rabbitmq-demo/src/main/java/com/sf/deadletter/length/Producer.java

package com.sf.deadletter.length;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.sf.util.MqUtils;

public class Producer {

    private final static String EXCHANGE_NAME = "normal_exchange1";

    public static void main(String[] args) throws Exception {
        Channel channel = MqUtils.getChannel();
        channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);

        int cnt = 10;
        while (cnt > 0) {
            String message = cnt + "";
            System.out.println(message);
            channel.basicPublish(EXCHANGE_NAME, "zhangsan", null, message.getBytes());
            cnt--;
        }
    }
}