vuminh224/ipd-tp-4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lb ENvoyerDate

Browse Source
This commit is contained in:
trochas
2025-03-25 13:41:19 +01:00
parent 46570f5652
commit c3fe13f324
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/fr/istic/date/lb/EnvoyerDate.java
View File

@@ -5,10 +5,11 @@ import java.util.Date;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection; import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;
public class EnvoyerDate { 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 { public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory(); ConnectionFactory factory = new ConnectionFactory();
@@ -20,12 +21,10 @@ public class EnvoyerDate {
while(true){ while(true){
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String message = argv.length < 1 ? getDate() String message = argv.length < 1 ? getDate()
: String.join(" ", argv); : 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 + "'"); System.out.println(" [x] Sent '" + message + "'");
try { try {