FilesExpand file tree

 master

/

Send.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

26 lines (19 loc) · 788 Bytes

 master

/

Send.java

Copy path

Top

File metadata and controls

• Code
• Blame

26 lines (19 loc) · 788 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

package rabbitmq.simple;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import rabbitmq.util.ConnectionUtils;

import java.io.IOException;

import java.util.concurrent.TimeoutException;

public class Send {

private static final String QUEUE_NAME = "test_simple_queue";

public static void main(String[] args) throws IOException, TimeoutException {

Connection connection = ConnectionUtils.getConnect();

Channel channel = connection.createChannel();

channel.queueDeclare(QUEUE_NAME, false, false, false, null);

String msg = "Hello World";

channel.basicPublish("", QUEUE_NAME, null, msg.getBytes());

System.out.println("---send msg: " + msg);

channel.close();

connection.close();

}

}