diff --git a/src/main/java/ch/hepia/mq/MessageQueue.java b/src/main/java/ch/hepia/mq/MessageQueue.java index f91a95c0eaf7ad87429d6acfe7ebf1ed900acd7f..e5cd0da32fc5706b9804a29ebc47b135cf6a9de0 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