FilesExpand file tree

 master

/

Recv1.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

47 lines (33 loc) · 1.45 KB

 master

/

Recv1.java

Copy path

Top

File metadata and controls

• Code
• Blame

47 lines (33 loc) · 1.45 KB

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

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

package topic;

import com.rabbitmq.client.*;

import util.ConnectionUtils;

import java.io.IOException;

import java.util.concurrent.TimeoutException;

public class Recv1 {

private static final String EXCHANGE_NAME = "test_exchange_topic";

private static final String QUEUE_NAME = "test_queue_topic_1";

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

Connection connection = ConnectionUtils.getConnection();

final Channel channel = connection.createChannel();

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

channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "goods.add");

channel.basicQos(1);

Consumer consumer = new DefaultConsumer(channel){

@Override

public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

String msg = new String(body, "utf-8");

System.out.println("[1] Recv msg : " + msg);

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

System.out.println("[1] done");

channel.basicAck(envelope.getDeliveryTag(), false);

}

}

};

boolean autoAck = false;

channel.basicConsume(QUEUE_NAME, autoAck, consumer);

}

}