FilesExpand file tree

 master

/

RPCClient.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

77 lines (64 loc) · 2.15 KB

 master

/

RPCClient.java

Copy path

Top

File metadata and controls

• Code
• Blame

77 lines (64 loc) · 2.15 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

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.QueueingConsumer;

import com.rabbitmq.client.AMQP.BasicProperties;

import java.util.UUID;

public class RPCClient {

private Connection connection;

private Channel channel;

private String requestQueueName = "rpc_queue";

private String replyQueueName;

private QueueingConsumer consumer;

public RPCClient() throws Exception {

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

connection = factory.newConnection();

channel = connection.createChannel();

replyQueueName = channel.queueDeclare().getQueue();

consumer = new QueueingConsumer(channel);

channel.basicConsume(replyQueueName, true, consumer);

}

public String call(String message) throws Exception {

String response = null;

String corrId = UUID.randomUUID().toString();

BasicProperties props = new BasicProperties

.Builder()

.correlationId(corrId)

.replyTo(replyQueueName)

.build();

channel.basicPublish("", requestQueueName, props, message.getBytes());

while (true) {

QueueingConsumer.Delivery delivery = consumer.nextDelivery();

if (delivery.getProperties().getCorrelationId().equals(corrId)) {

response = new String(delivery.getBody(),"UTF-8");

break;

}

}

return response;

}

public void close() throws Exception {

connection.close();

}

public static void main(String[] argv) {

RPCClient fibonacciRpc = null;

String response = null;

try {

fibonacciRpc = new RPCClient();

System.out.println(" [x] Requesting fib(30)");

response = fibonacciRpc.call("30");

System.out.println(" [.] Got '" + response + "'");

}

catch (Exception e) {

e.printStackTrace();

}

finally {

if (fibonacciRpc!= null) {

try {

fibonacciRpc.close();

}

catch (Exception ignore) {}

}

}

}

}