Skip to content
Snippets Groups Projects
Verified Commit 252575a2 authored by Michaël El Kharroubi's avatar Michaël El Kharroubi :satellite:
Browse files

Commit for merging

parent 52885f73
No related branches found
No related tags found
1 merge request!21*poof* final version
package ch.hepia.mq;
import com.rabbitmq.client.ConnectionFactory;
import java.util.function.Consumer;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
......@@ -16,7 +19,12 @@ public class MessageQueue{
this.queueConnector.setPassword(password);
}
public void addConsumer(Consumer messageHandler){
}
public void sendBytes(byte[] bytes){
}
public void close(){
......
......@@ -30,6 +30,7 @@ public class Consumer {
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
Consumer.onReceive(consumerTag, delivery);
};
channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {
});
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment