From 52885f73368e9ee6265e74fe1480034f4fd008b0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Micha=C3=ABl=20El=20Kharroubi=20=28HES=29?=
<michael.el-kharroubi@etu.hesge.ch>
Date: Fri, 18 Jan 2019 09:22:45 +0100
Subject: [PATCH] =?UTF-8?q?Compl=C3=A9tion=20structure=20MessageQueue?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
src/main/java/ch/hepia/mq/MessageQueue.java | 22 ++++++++++++++++++++-
1 file changed, 21 insertions(+), 1 deletion(-)
diff --git a/src/main/java/ch/hepia/mq/MessageQueue.java b/src/main/java/ch/hepia/mq/MessageQueue.java
index f91a95c..e5cd0da 100644
--- a/src/main/java/ch/hepia/mq/MessageQueue.java
+++ b/src/main/java/ch/hepia/mq/MessageQueue.java
@@ -1,5 +1,25 @@
package ch.hepia.mq;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+
public class MessageQueue{
- //public MessageQueue()
+ private final String exchange;
+ private final ConnectionFactory queueConnector;
+
+ public MessageQueue(String host, String username, String password, String exchange){
+ this.exchange = exchange;
+ this.queueConnector = new ConnectionFactory();
+ this.queueConnector.setHost(host);
+ this.queueConnector.setUsername(username);
+ this.queueConnector.setPassword(password);
+ }
+
+ public void sendBytes(byte[] bytes){
+ }
+
+ public void close(){
+ //TODO
+ }
}
\ No newline at end of file
--
GitLab