From 3e934684c77f0401c11eb7f57bb23c6048ee74e8 Mon Sep 17 00:00:00 2001 From: trochas Date: Thu, 6 Mar 2025 16:31:48 +0100 Subject: [PATCH] =?UTF-8?q?lb=20=C3=A7a=20ne=20marche=20pas?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/fr/istic/date/lb/EnvoyerDate.java | 43 +++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 src/main/java/fr/istic/date/lb/EnvoyerDate.java diff --git a/src/main/java/fr/istic/date/lb/EnvoyerDate.java b/src/main/java/fr/istic/date/lb/EnvoyerDate.java new file mode 100644 index 0000000..5b6c3e3 --- /dev/null +++ b/src/main/java/fr/istic/date/lb/EnvoyerDate.java @@ -0,0 +1,43 @@ +package fr.istic.date.lb; + +import java.util.Date; + +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; + + +public class EnvoyerDate { + private static final String EXCHANGE_NAME = "logs"; + + public static void main(String[] argv) throws Exception { + ConnectionFactory factory = new ConnectionFactory(); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); + try (Connection connection = factory.newConnection(); + Channel channel = connection.createChannel()) { + channel.queueDeclare(EXCHANGE_NAME, false, false, false, null); + + + while(true){ + + channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); + + String message = argv.length < 1 ? getDate() + : String.join(" ", argv); + + channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes("UTF-8")); + System.out.println(" [x] Sent '" + message + "'"); + + try { + Thread.sleep(1000); // Attend 1 seconde (1000 millisecondes) + } catch (InterruptedException e) { + e.printStackTrace(); + } + } + } + } + + public static String getDate(){ + return (new Date()).toString(); + } +}