diff --git a/run-docker.sh b/run-docker.sh old mode 100644 new mode 100755 index e69de29..dda47a6 --- a/run-docker.sh +++ b/run-docker.sh @@ -0,0 +1,21 @@ +#!/bin/bash + +# LANCE UN SERVEUR RMQ + +# NOM D'UTILISATEUR : +export RMQ_USER="admin" + +# MOT DE PASSE : +export RMQ_PASSWORD="admin" + +# VHOST : +export RMQ_VHOST="ipr" + +export PORT_SERVER=8088 +export PORT_WEB=8089 + +echo "adresse serveur : amqp://${RMQ_USER}:${RMQ_PASSWORD}@localhost:${PORT_SERVER}/${RMQ_VHOST}" +echo "adresse admin : http://${RMQ_USER}:${RMQ_PASSWORD}@localhost:${PORT_WEB}/" + +sudo docker rm -vf rbmqtp +sudo docker run --rm -it --hostname my-rabbit --name rbmqtp -p ${PORT_WEB}:15672 -p ${PORT_SERVER}:5672 -e RABBITMQ_DEFAULT_VHOST=${RMQ_VHOST} -e RABBITMQ_DEFAULT_USER=${RMQ_USER} -e RABBITMQ_DEFAULT_PASS=${RMQ_PASSWORD} rabbitmq:3-management \ No newline at end of file diff --git a/src/main/java/rabbitmq/tuto1/Recv.java b/src/main/java/rabbitmq/tuto1/Recv.java index 74f7b0f..99f9ff7 100644 --- a/src/main/java/rabbitmq/tuto1/Recv.java +++ b/src/main/java/rabbitmq/tuto1/Recv.java @@ -11,7 +11,7 @@ public class Recv { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqp://admin:admin@localhost:8088/ipr"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); diff --git a/src/main/java/rabbitmq/tuto1/Send.java b/src/main/java/rabbitmq/tuto1/Send.java index e5ac3fa..d1e8e9e 100644 --- a/src/main/java/rabbitmq/tuto1/Send.java +++ b/src/main/java/rabbitmq/tuto1/Send.java @@ -10,7 +10,7 @@ public class Send { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqp://admin:admin@localhost:8088/ipr"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(QUEUE_NAME, false, false, false, null);