From c3fe13f3248c87ddc4b7b70e69d4b5cb8fa07c0c Mon Sep 17 00:00:00 2001 From: trochas Date: Tue, 25 Mar 2025 13:41:19 +0100 Subject: [PATCH] lb ENvoyerDate --- src/main/java/fr/istic/date/lb/EnvoyerDate.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/main/java/fr/istic/date/lb/EnvoyerDate.java b/src/main/java/fr/istic/date/lb/EnvoyerDate.java index 5b6c3e3..9c7292b 100644 --- a/src/main/java/fr/istic/date/lb/EnvoyerDate.java +++ b/src/main/java/fr/istic/date/lb/EnvoyerDate.java @@ -5,10 +5,11 @@ import java.util.Date; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; +import com.rabbitmq.client.MessageProperties; public class EnvoyerDate { - private static final String EXCHANGE_NAME = "logs"; + private static final String EXCHANGE_NAME = "file_date"; public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); @@ -20,12 +21,10 @@ public class EnvoyerDate { 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")); + channel.basicPublish("",EXCHANGE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes("UTF-8")); System.out.println(" [x] Sent '" + message + "'"); try {