From f2d1a5ecba4bda3f1503da0b749cf9c92cdf550f Mon Sep 17 00:00:00 2001
From: ynn <ynn@mel.yt>
Date: Sun, 24 Feb 2019 18:17:54 +0100
Subject: [PATCH] update rmq

---
 run-docker.sh                          | 21 +++++++++++++++++++++
 src/main/java/rabbitmq/tuto1/Recv.java |  2 +-
 src/main/java/rabbitmq/tuto1/Send.java |  2 +-
 3 files changed, 23 insertions(+), 2 deletions(-)
 mode change 100644 => 100755 run-docker.sh

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);