Merge branch 'DEVELOP_BE' of ssh://git.eclipse.org:29418/openk-usermodules/org.eclipse.openk-usermodules.plannedGridMeasures.backend into DEVELOP_BE
diff --git a/src/main/java/org/eclipse/openk/core/RabbitMqTester.java b/src/main/java/org/eclipse/openk/core/RabbitMqTester.java
new file mode 100644
index 0000000..f0fee55
--- /dev/null
+++ b/src/main/java/org/eclipse/openk/core/RabbitMqTester.java
@@ -0,0 +1,208 @@
+/*
+ * *****************************************************************************
+ * Copyright © 2018 PTA GmbH.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ *
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * *****************************************************************************
+ */
+
+package org.eclipse.openk.core;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.AMQP.BasicProperties;
+import com.rabbitmq.client.AMQP.BasicProperties.Builder;
+import com.rabbitmq.client.AMQP.Queue.DeclareOk;
+import com.rabbitmq.client.BuiltinExchangeType;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Consumer;
+import com.rabbitmq.client.DefaultConsumer;
+import com.rabbitmq.client.Envelope;
+import com.rabbitmq.client.MessageProperties;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeoutException;
+import org.eclipse.openk.PlannedGridMeasuresConfiguration;
+import org.eclipse.openk.PlannedGridMeasuresConfiguration.RabbitmqConfiguration;
+import org.eclipse.openk.api.BackendSettings;
+import org.eclipse.openk.api.GridMeasure;
+import org.eclipse.openk.common.JsonGeneratorBase;
+import org.eclipse.openk.core.controller.BackendConfig;
+import org.eclipse.openk.core.messagebroker.Producer;
+
+public class RabbitMqTester {
+
+ private final static String QUEUE_NAME = "pgm-applied-queue";
+ private final static String ROUTING_KEY = "applied";
+ private final static String EXCHANGE_NAME = "openk-pgm-exchange-test";
+
+ public static void main(String[] args) throws Exception {
+ prepareBackendSettings();
+ //prepareRabbitMq();
+ send2();
+
+
+
+ // consumeExchange();
+ //consume();
+
+
+
+ }
+
+ private static void prepareBackendSettings() {
+ RabbitmqConfiguration rabbitmqConfiguration = new RabbitmqConfiguration();
+ rabbitmqConfiguration.setUser("admin");
+ rabbitmqConfiguration.setPassword("admin");
+ rabbitmqConfiguration.setExchangeName("openk-pgm-exchange-test");
+ // rabbitmqConfiguration.setHost("172.18.22.160");
+ rabbitmqConfiguration.setHost("localhost");
+ rabbitmqConfiguration.setPort("5672");
+ rabbitmqConfiguration.setUnroutedMessagesExchangeName("unrouted-messages-test-ex");
+ rabbitmqConfiguration.setUnroutedMessagesQueueName("unrouted-messages-test-q");
+
+ rabbitmqConfiguration.setQueueNames("pgm-applie-queue");
+
+ BackendSettings backendSettings = new BackendSettings();
+ PlannedGridMeasuresConfiguration measuresConfiguration = new PlannedGridMeasuresConfiguration();
+ measuresConfiguration.setPortalBaseURL("portalBaseUrlMock");
+ measuresConfiguration.setRabbitmqConfiguration(rabbitmqConfiguration);
+ BackendConfig.configure(measuresConfiguration, backendSettings);
+ }
+
+ private static void send2() throws Exception {
+ GridMeasure gm = new GridMeasure();
+ gm.setTitle("Tester33");
+ try (Producer prod = new Producer()) {
+ prod.sendMessageAsJson(gm, "applied");
+ }
+
+ }
+
+ private static void prepareRabbitMq(){
+ ConnectionFactory factory = new ConnectionFactory();
+ // factory.setHost("172.18.22.160");
+ factory.setHost("localhost");
+ factory.setPassword("admin");
+ factory.setUsername("admin");
+ try (Connection connection = factory.newConnection();
+ Channel channel = connection.createChannel()) {
+
+ // durable = true
+ channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT, true);
+
+ Map<String, Object> args = new HashMap<>();
+ args.put("x-queue-mode", "lazy");
+
+ List<String> queueNameList = Arrays.asList("pgm-canceled-queue", "pgm-applied-queue", "pgm-approved-queue");
+
+ for (String queueName : queueNameList) {
+ channel.queueDeclare(queueName, true, false, false, args);
+ String routingKey = queueName.split("-")[1];
+ channel.queueBind(queueName, EXCHANGE_NAME, routingKey);
+ }
+
+ } catch (TimeoutException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ private static void send() {
+ ConnectionFactory factory = new ConnectionFactory();
+ factory.setHost("172.18.22.160");
+ factory.setPassword("admin");
+ factory.setUsername("admin");
+ try (Connection connection = factory.newConnection();
+ Channel channel = connection.createChannel()) {
+
+ Map<String, Object> args = new HashMap<String, Object>();
+ args.put("x-queue-mode", "lazy");
+
+ channel.queueDeclare(QUEUE_NAME, true, false, false, args);
+ String message = "Hello World!333233";
+ // channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
+ BasicProperties basicProperties = new Builder().contentType("text/plain").deliveryMode(2).priority(0).userId("bob").build();
+ // channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
+ channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
+ System.out.println(" [x] Sent '" + message + "'");
+
+ } catch (TimeoutException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ }
+
+ private static void consumeExchange() {
+ ConnectionFactory factory = new ConnectionFactory();
+ factory.setHost("172.18.22.160");
+ factory.setPassword("admin");
+ factory.setUsername("admin");
+ try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {
+
+ // channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+ System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
+
+ Consumer consumer = new DefaultConsumer(channel) {
+ @Override
+ public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
+ String message = new String(body, "UTF-8");
+ System.out.println(" [x] Received '" + envelope.getRoutingKey() + "':'" + message + "'");
+ }
+ };
+ channel.basicConsume(QUEUE_NAME, true, consumer);
+
+ } catch (TimeoutException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ private static void consumeDirect() {
+ ConnectionFactory factory = new ConnectionFactory();
+ factory.setHost("172.18.22.160");
+ factory.setPassword("admin");
+ factory.setUsername("admin");
+ try (Connection connection = factory.newConnection();
+ Channel channel = connection.createChannel()) {
+
+ // channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+ System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
+
+ Consumer consumer = new DefaultConsumer(channel) {
+ @Override
+ public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
+ throws IOException {
+ String message = new String(body, "UTF-8");
+ System.out.println(" [x] Received '" + message + "'");
+ }
+ };
+ channel.basicConsume(QUEUE_NAME, true, consumer);
+
+ } catch (TimeoutException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+
+
+
+ }
+
+
+
+
+}
diff --git a/src/main/java/org/eclipse/openk/core/Tester.java b/src/main/java/org/eclipse/openk/core/Tester.java
new file mode 100644
index 0000000..730f733
--- /dev/null
+++ b/src/main/java/org/eclipse/openk/core/Tester.java
@@ -0,0 +1,96 @@
+/*
+ * *****************************************************************************
+ * Copyright © 2018 PTA GmbH.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ *
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * *****************************************************************************
+ */
+
+package org.eclipse.openk.core;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Locale;
+import java.util.Optional;
+import java.util.TimeZone;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+import org.eclipse.openk.common.util.DateUtils;
+
+public class Tester {
+
+ private static final String DATEFORMAT = "yyyy-MM-dd'T'HH:mm:ss";
+ private static final String DATEFORMAT2 = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";
+ private static final String DATEFORMAT3 = "yyMMdd";
+
+ public static void main(String[] args) throws Exception {
+ test3();
+ }
+
+ private static void test3() {
+ List<String> list = new ArrayList<>();
+ list.add("behold");
+ list.add("bend");
+ list.add("bet");
+ list.add("bear");
+ list.add("beat");
+ list.add("become");
+ list.add("begin");
+
+ String s = list.stream().filter(it -> it.contains("bea")).findFirst().orElse(null);
+ String s2 = list.stream().filter(it -> it.contains("bea")).findFirst().get();
+ //List<String> matches = list.stream().filter(it -> it.contains("bea")).collect(Collectors.toList());
+
+ System.out.println(s); // [bear, beat]
+
+ }
+
+ private static void test1() throws ParseException {
+ DateFormat dateFormat3 = new SimpleDateFormat("yyMMdd");
+ DateFormat dateFormat = new SimpleDateFormat(DATEFORMAT, Locale.GERMANY); //This is the format I need
+ // dateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
+ // dateFormat.setTimeZone(TimeZone.getTimeZone("ECT"));
+
+ Date date = new Date();
+ String format = dateFormat3.format(date);
+ System.out.println("format3: " + format);
+ // Date date2 = dateFormat.parse("");
+
+ Date date1 = DateUtils.parseStringToDate(null);
+ Date date2 = new Date();
+ Date date3 = org.apache.commons.lang3.time.DateUtils.addDays(date2, 3);
+ System.out.println(date3);
+
+ boolean sameDay = org.apache.commons.lang3.time.DateUtils.isSameDay(date, date3);
+ System.out.println(sameDay);
+
+ System.out.println(DateUtils.asLocalDate(date3));
+
+
+ }
+
+ private static void test2() {
+ int number = 123;
+ String numberAsString = String.format ("%05d", number);
+ System.out.println(numberAsString);
+
+ }
+
+ private static String createDescriptiveId(int counter, Date date){
+ DateFormat dateFormat = new SimpleDateFormat("yyMMdd");
+ String counterAsString = String.format ("%04d", counter);
+ return dateFormat.format(date)+ counterAsString;
+ }
+
+
+
+}
