diff --git a/src/main/java/ch/hepia/mq/MessageQueue.java b/src/main/java/ch/hepia/mq/MessageQueue.java index e5cd0da32fc5706b9804a29ebc47b135cf6a9de0..67ff7b5cf9289cc4eb8f3c4f50b6aa7abb23678b 100644 --- a/src/main/java/ch/hepia/mq/MessageQueue.java +++ b/src/main/java/ch/hepia/mq/MessageQueue.java @@ -3,6 +3,7 @@ package ch.hepia.mq; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; +import com.rabbitmq.client.Delivery; public class MessageQueue{ private final String exchange; @@ -16,7 +17,18 @@ public class MessageQueue{ this.queueConnector.setPassword(password); } - public void sendBytes(byte[] bytes){ + public void sendBytes(byte[] bytes) throws Exception { + try (Connection connection = this.queueConnector.newConnection(); Channel channel = connection.createChannel()) { + channel.basicPublish(this.exchange, "", null, bytes); + // System.out.println(" [x] Sent '" + bytes + "'"); + channel.close(); + connection.close(); + } + } + + public byte[] recvBytes(Delivery delivery) throws Exception { + byte[] data = delivery.getBody(); + return data; } public void close(){