From 0165bc4f7a021a7c9feb0145e7e884e96fbe4cb3 Mon Sep 17 00:00:00 2001
From: Alexis Durgnat <alexis.durgnat@etu.hesge.ch>
Date: Fri, 18 Jan 2019 10:02:00 +0100
Subject: [PATCH] sendBytes, recvBytes done
---
src/main/java/ch/hepia/mq/MessageQueue.java | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/src/main/java/ch/hepia/mq/MessageQueue.java b/src/main/java/ch/hepia/mq/MessageQueue.java
index e5cd0da..67ff7b5 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(){
--
GitLab