diff --git a/src/main/java/cn/hezhaohui/mq/Send.java b/src/main/java/cn/hezhaohui/mq/Send.java new file mode 100644 index 0000000..0ae19e8 --- /dev/null +++ b/src/main/java/cn/hezhaohui/mq/Send.java @@ -0,0 +1,25 @@ +package cn.hezhaohui.mq; + +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; + +import java.io.IOException; +import java.util.concurrent.TimeoutException; + +public class Send { + private final static String QUEUE_NAME = "hello"; + + public static void main(String[] args) { + ConnectionFactory connectionFactory = new ConnectionFactory(); + try (Connection connection = connectionFactory.newConnection(); + Channel channel = connection.createChannel()){ + channel.queueDeclare(QUEUE_NAME, false, false, false, null); + String message = "Hello World!"; + channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); + System.out.println(" [x] Sent '" + message + "'"); + } catch (IOException | TimeoutException e) { + throw new RuntimeException(e); + } + } +}