if (message.equalsIgnoreCase("/addUser")) {
synchronized (lock) {
addUser();
}
} else if (message.equalsIgnoreCase("/addServeur")) {
synchronized (lock) {
addServeur();
}
} else if (message.equalsIgnoreCase("/ch")) {
synchronized (lock) {
canal = changeCannal();
}

synchronized (lock) {
}

public void run() {

try {

// System.out.println(liste.get(i));
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
synchronized (lock) {
System.out.println(message);
}
};

channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {
});

} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

``
main(){

}

" ".trim().isEmpty()