package com.sf.deadletter.ttl;

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

import java.util.Scanner;

public class Producer {

    private final static String EXCHANGE_NAME = "normal_exchange";

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

        AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().expiration("10000").build();
        int cnt = 10;
        while (cnt > 0) {
            String message = cnt + "";
            System.out.println(message);
            channel.basicPublish(EXCHANGE_NAME, "zhangsan", properties, message.getBytes());
            cnt--;
        }
    }
}