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

Complétion structure MessageQueue

parent 140ee84f
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 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
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment