diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..13566b8 --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# Default ignored files +/shelf/ +/workspace.xml +# Editor-based HTTP Client requests +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/compiler.xml b/.idea/compiler.xml new file mode 100644 index 0000000..dca6fef --- /dev/null +++ b/.idea/compiler.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml new file mode 100644 index 0000000..712ab9d --- /dev/null +++ b/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..6546f14 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,12 @@ + + + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..35eb1dd --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/src/main/java/fr/istic/date/RecevoirDate.java b/src/main/java/fr/istic/date/RecevoirDate.java index fe8e3b1..17712d9 100644 --- a/src/main/java/fr/istic/date/RecevoirDate.java +++ b/src/main/java/fr/istic/date/RecevoirDate.java @@ -1,5 +1,33 @@ package fr.istic.date; +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; +import com.rabbitmq.client.DeliverCallback; + +import java.util.Date; + public class RecevoirDate { + private static final Date date = null; + + public static void main(String[] argv) throws Exception { + ConnectionFactory factory = new ConnectionFactory(); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); + Connection connection = factory.newConnection(); + Channel channel = connection.createChannel(); + + channel.exchangeDeclare(date.toString(), "fanout"); + String queueName = channel.queueDeclare().getQueue(); + channel.queueBind(queueName, date.toString(), ""); + + System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); + + DeliverCallback deliverCallback = (consumerTag, delivery) -> { + String message = new String(delivery.getBody(), "UTF-8"); + System.out.println(" [x] Received '" + message + "'"); + }; + channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { + }); + } } diff --git a/src/main/java/rabbitmq/tuto1/Recv.java b/src/main/java/rabbitmq/tuto1/Recv.java index 99f9ff7..532696f 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.setUri("amqp://admin:admin@localhost:8088/ipr"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); 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 d1e8e9e..ddaa7db 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.setUri("amqp://admin:admin@localhost:8088/ipr"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(QUEUE_NAME, false, false, false, null); diff --git a/src/main/java/rabbitmq/tuto2/NewTask.java b/src/main/java/rabbitmq/tuto2/NewTask.java index c4f4dec..8d1b3a3 100644 --- a/src/main/java/rabbitmq/tuto2/NewTask.java +++ b/src/main/java/rabbitmq/tuto2/NewTask.java @@ -11,7 +11,7 @@ public class NewTask { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(TASK_QUEUE_NAME, true, false, false, null); diff --git a/src/main/java/rabbitmq/tuto2/Worker.java b/src/main/java/rabbitmq/tuto2/Worker.java index 797f8c9..3610e7f 100644 --- a/src/main/java/rabbitmq/tuto2/Worker.java +++ b/src/main/java/rabbitmq/tuto2/Worker.java @@ -11,7 +11,7 @@ public class Worker { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); final Connection connection = factory.newConnection(); final Channel channel = connection.createChannel(); diff --git a/src/main/java/rabbitmq/tuto3/EmitLog.java b/src/main/java/rabbitmq/tuto3/EmitLog.java index 35e615e..931481e 100644 --- a/src/main/java/rabbitmq/tuto3/EmitLog.java +++ b/src/main/java/rabbitmq/tuto3/EmitLog.java @@ -10,7 +10,7 @@ public class EmitLog { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); diff --git a/src/main/java/rabbitmq/tuto3/ReceiveLogs.java b/src/main/java/rabbitmq/tuto3/ReceiveLogs.java index d420f23..ef36d6b 100644 --- a/src/main/java/rabbitmq/tuto3/ReceiveLogs.java +++ b/src/main/java/rabbitmq/tuto3/ReceiveLogs.java @@ -10,7 +10,7 @@ public class ReceiveLogs { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); diff --git a/src/main/java/rabbitmq/tuto4/EmitLogDirect.java b/src/main/java/rabbitmq/tuto4/EmitLogDirect.java index dfe0f10..db77ef2 100644 --- a/src/main/java/rabbitmq/tuto4/EmitLogDirect.java +++ b/src/main/java/rabbitmq/tuto4/EmitLogDirect.java @@ -11,7 +11,7 @@ public class EmitLogDirect { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT); diff --git a/src/main/java/rabbitmq/tuto4/ReceiveLogsDirect.java b/src/main/java/rabbitmq/tuto4/ReceiveLogsDirect.java index 49c73eb..df3d487 100644 --- a/src/main/java/rabbitmq/tuto4/ReceiveLogsDirect.java +++ b/src/main/java/rabbitmq/tuto4/ReceiveLogsDirect.java @@ -8,7 +8,7 @@ public class ReceiveLogsDirect { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); diff --git a/src/main/java/rabbitmq/tuto5/EmitLogTopic.java b/src/main/java/rabbitmq/tuto5/EmitLogTopic.java index 123d03c..b433200 100644 --- a/src/main/java/rabbitmq/tuto5/EmitLogTopic.java +++ b/src/main/java/rabbitmq/tuto5/EmitLogTopic.java @@ -10,7 +10,7 @@ public class EmitLogTopic { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { diff --git a/src/main/java/rabbitmq/tuto5/ReceiveLogsTopic.java b/src/main/java/rabbitmq/tuto5/ReceiveLogsTopic.java index 58c67e6..bc3d871 100644 --- a/src/main/java/rabbitmq/tuto5/ReceiveLogsTopic.java +++ b/src/main/java/rabbitmq/tuto5/ReceiveLogsTopic.java @@ -11,7 +11,7 @@ public class ReceiveLogsTopic { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); diff --git a/src/main/java/rabbitmq/tuto6/RPCClient.java b/src/main/java/rabbitmq/tuto6/RPCClient.java index ade61ef..c70541a 100644 --- a/src/main/java/rabbitmq/tuto6/RPCClient.java +++ b/src/main/java/rabbitmq/tuto6/RPCClient.java @@ -17,9 +17,9 @@ public class RPCClient implements AutoCloseable { private Channel channel; private String requestQueueName = "rpc_queue"; - public RPCClient() throws IOException, TimeoutException { + public RPCClient() throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); connection = factory.newConnection(); channel = connection.createChannel(); @@ -33,7 +33,7 @@ public class RPCClient implements AutoCloseable { String response = fibonacciRpc.call(i_str); System.out.println(" [.] Got '" + response + "'"); } - } catch (IOException | TimeoutException | InterruptedException e) { + } catch (Exception e) { e.printStackTrace(); } } diff --git a/src/main/java/rabbitmq/tuto6/RPCServer.java b/src/main/java/rabbitmq/tuto6/RPCServer.java index 1cc8515..bdbdead 100644 --- a/src/main/java/rabbitmq/tuto6/RPCServer.java +++ b/src/main/java/rabbitmq/tuto6/RPCServer.java @@ -18,7 +18,7 @@ public class RPCServer { public static void main(String[] argv) throws Exception { ConnectionFactory factory = new ConnectionFactory(); - factory.setHost("localhost"); + factory.setUri("amqps://cyvthtfj:O8LmaXkX5mVB0oFZN9TobaK8rX9wEhol@whale.rmq.cloudamqp.com/cyvthtfj"); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {