diff --git a/pom.xml b/pom.xml index c2098e53e0..17e75f0c1d 100644 --- a/pom.xml +++ b/pom.xml @@ -17,7 +17,8 @@ ~ --> - + 4.0.0 @@ -31,1067 +32,186 @@ 0.95.0-SNAPSHOT pom - - UTF-8 - false - 3.8.7 - false - - - 5.18.0 - 1.9.12 - 1.9.4 - 1.15 - 3.2.2 - 2.11.0 - 3.12.0 - 1.2 - 1.5.2 - 6.8.17 - 3.1.0 - 1.13.5 - 1.0 - 2.57 - 1.14 - 32.1.2-jre - 2.10 - 8.0.0.Final - 4.5.13 - 4.4.9 - 4.4.9 - 2.23 - 1.6.0 - 2.15.0 - 2.15.0 - 2.1.1 - 2.0.1 - 2.1.1 - 2.0.1 - 2.0.1 - 6.0.0 - 3.0.2 - 4.0.0 - 2.4.0-b180725.0427 - 1.1 - 2.0.1 - 3.0.1 - 3.1.0 - 3.29.2-GA - 3.5.2.Final - 2.2.1.Final - 2.2.1.Final - 3.1.0 - 24.0.1 - 10.0.16 - 1.5.1 - 0.11.2 - 5.13.0 - 5.3.0 - 2.5.0 - 3.0.2 - 3.4.0 - 1.9.0 - 0.2.0 - 2.20.0 - 1.8.0 - 1.4.5 - 2.2 - 3.7.1 - 1.12 - 2.17.0 - 3.3 - 6.0.0 - 2.1.1 - 1.1 - 3.5.0 - 3.7.7 - 1.9.0 - 2.29.0.Final - 5.1.27 - 8.3.1 - 2.0.6 - 2.2 - 1.1.10.4 - 6.0.10 - 3.1.0 - 6.1.1 - 2.2.7 - 0.8.1 - 1.11 - 2.0.52.Final - - 1.19.0 - 1.2 - - - 4.13.2 - 5.7.0 - 2.0.9 - 2.9.0 - 2.27.2 - - - 17 - 17 - - 5.20.0 - 1.23 - 1.1.0 - 1.70 - 1.69 - 3.9 - 3.39.0 - 3.6.1 - 1.23.0 - 1.10.0 - 2.11.1 - 1.0.0 - 1.4.1 - 2.2.0 - 23.0.0 - 1.5.0 - 2.1.0 - 2.3.2 - 0.2.0 - 4.4.3 - 2.24.0 - 0.6 - 2.8.2 - 1.18.22 - 1.4.3 - 4.2.15 - 1.9.13 - 4.1.72.Final - 3.13.1 - 2.1.0 - 42.6.0 - 2.10.1 - 5.0.2 - 2.3.2 - 2.13.10 - 2.2.0 - 1.4.0 - 2.12.2 - 1.9.0 - - 3.2.4 - - - 1.17 - 4.13.0 - 4.4 - 0.6.9 - 4.1.72.Final - 5.8 - 0.10.0 - 3.25.0 - 0.34.0 - - 0.13 - 1.11 - 10.12.1 - 1.7.0 - 2.23.0 - 3.2.1 - 8.4.0 - 3.4.1 - 1.11.0 - 1.11.0 - - Apache StreamPipes A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams. https://streampipes.apache.org - - - - ch.qos.logback - logback-classic - ${logback.version} - - - ch.qos.logback - logback-core - ${logback.version} - - - com.esotericsoftware.kryo - kryo - ${kryo.version} - - - com.fasterxml.jackson.core - jackson-annotations - ${jackson.version} - - - com.fasterxml.jackson.core - jackson-core - ${jackson.version} - - - com.fasterxml.jackson.core - jackson-databind - ${jackson.databind.version} - - - com.fasterxml.jackson.dataformat - jackson-dataformat-cbor - ${jackson.version} - - - com.fasterxml.jackson.dataformat - jackson-dataformat-smile - ${jackson.version} - - - com.fasterxml.jackson.dataformat - jackson-dataformat-xml - ${jackson.version} - - - com.fasterxml.jackson.dataformat - jackson-dataformat-yaml - ${jackson.version} - - - com.fasterxml.jackson.datatype - jackson-datatype-jdk8 - ${jackson.version} - - - com.fasterxml.jackson.datatype - jackson-datatype-jsr310 - ${jackson.version} - - - com.fasterxml.jackson.module - jackson-module-jaxb-annotations - ${jackson.version} - - - com.fasterxml.jackson.module - jackson-module-jakarta-xmlbind-annotations - ${jackson.version} - + + 5.18.0 + 5.20.0 + 1.2 + 1.1.0 + 3.9 + 3.39.0 + 1.15 + 3.2.2 + 1.23.0 + 2.11.0 + 3.12.0 + 2.11.1 + 1.10.0 + 1.0.0 + 0.6.9 + 3.1.0 + 1.13.5 + 1.0 + 2.57 + 1.14 + 2.2.0 + 23.0.0 + 2.10 + 32.1.2-jre + 4.5.13 + 4.4.9 + 2.23 + 1.9.0 + 2.15.0 + 2.15.0 + 2.1.1 + 2.0.1 + 2.0.1 + 6.0.0 + 3.0.2 + 4.0.0 + 2.4.0-b180725.0427 + 1.5.0 + 2.3.2 + 1.1 + 3.0.1 + 3.1.0 + 3.29.2-GA + 3.5.2.Final + 4.4.3 + 3.1.3 + 10.0.16 + 1.5.1 + 0.2.0 + 0.11.2 + 1.19.0 + 3.4.0 + 0.2.0 + 3.7.1 + 1.4.3 + 1.11.5 + 1.11.5 + 1.12 + 2.17.0 + 4.1.72.Final + 3.13.1 + 5.8 + 2.1.0 + 0.10.0 + 2.1.1 + 1.1 + 3.5.0 + 42.6.0 + 3.25.0 + 2.10.1 + 2.3.2 + + 3.7.7 + 1.9.0 + 5.0.2 + 5.1.27 + 8.3.1 + 1.4.0 + 2.0.6 + 2.2 + 3.1.5 + 6.1.5 + 2.2.7 + 0.8.1 + 1.11 - - com.j2html - j2html - ${j2html.version} - - - com.github.drapostolos - type-parser - ${type-parser.version} - - - com.google.code.findbugs - jsr305 - ${jsr305.version} - - - com.google.code.gson - gson - ${gson.version} - - - com.google.guava - guava - ${guava.version} - - - com.orbitz.consul - consul-client - ${consul-client.version} - - - com.squareup.okhttp3 - okhttp - ${okhttp.version} - - - com.sun.mail - jakarta.mail - ${jakarta-mail.version} - - - commons-beanutils - commons-beanutils - ${commons-beanutils.version} - - - commons-codec - commons-codec - ${commons-codec.version} - - - commons-collections - commons-collections - ${commons-collections.version} - - - commons-io - commons-io - ${commons-io.version} - - - commons-logging - commons-logging - ${commons-logging.version} - - - de.grundid.opendatalab - geojson-jackson - ${geojson-jackson.version} - - - de.ruedigermoeller - fst - ${fst.version} - - - io.rest-assured - json-path - ${json-path.version} - - - io.jsonwebtoken - jjwt-api - ${jjwt.version} - - - io.jsonwebtoken - jjwt-impl - ${jjwt.version} - - - io.jsonwebtoken - jjwt-jackson - ${jjwt.version} - - - io.nats - jnats - ${nats.version} - - - io.swagger.core.v3 - swagger-annotations-jakarta - ${swagger.version} - - - io.swagger.core.v3 - swagger-jaxrs2-jakarta - ${swagger.version} - - - jakarta.activation - jakarta.activation-api - ${jakarta-activation-api.version} - - - jakarta.annotation - jakarta.annotation-api - ${jakarta-annotation.version} - - - jakarta.inject - jakarta.inject-api - ${jakarta-inject-api.version} - - - jakarta.validation - jakarta.validation-api - ${jakarta-validation.version} - - - jakarta.servlet - jakarta.servlet-api - ${jakarta-servlet-api.version} - - - jakarta.xml.bind - jakarta.xml.bind-api - ${jakarta-xml-bind-api.version} - - - jakarta.persistence - persistence-api - ${jakarta-persistence-api.version} - - - jakarta.validation - validation-api - ${jakarta-validation.version} - - - jakarta.ws.rs - jakarta.ws.rs-api - ${jakarta.ws.rs.version} - - - javax.websocket - javax.websocket-api - ${javax-websocket-api.version} - - - javax.xml.bind - jaxb-api - ${javax.xml.bind.version} - - - net.minidev - json-smart - ${json-smart.version} - - - org.apache.httpcomponents - fluent-hc - ${httpclient.version} - - - org.apache.httpcomponents - httpmime - ${httpclient.version} - - - org.apache.httpcomponents - httpclient - ${httpclient.version} - - - org.apache.httpcomponents - httpclient-osgi - ${httpclient.version} - - - org.apache.httpcomponents - httpcore-osgi - ${httpcore-osgi.version} - - - org.apache.httpcomponents - httpcore - ${httpcore.version} - - - org.apache.httpcomponents - httpcore-nio - ${httpcore.version} - - - org.apache.logging.log4j - log4j-api - ${log4j.version} - - - org.apache.logging.log4j - log4j-core - ${log4j.version} - - - org.apache.logging.log4j - log4j-to-slf4j - ${log4j.version} - - - org.apache.maven.shared - maven-invoker - ${maven-invoker.version} - - - org.apache.kafka - kafka_2.12 - ${kafka.version} - - - org.apache.kafka - kafka-clients - ${kafka.version} - - - org.apache.kafka - kafka-streams - ${kafka.version} - - - org.apache.maven - maven-plugin-api - ${maven.version} - - - org.apache.maven - maven-core - ${maven.version} - - - org.apache.maven - maven-artifact - ${maven.version} - - - org.apache.maven - maven-compat - ${maven.version} - - - org.apache.activemq - activemq-client - ${activemq-client.version} - - - org.apache.commons - commons-lang3 - ${commons-lang3.version} - - - org.apache.flink - flink-connector-kafka_2.11 - ${flink.version} - - - org.apache.flink - flink-java - ${flink.version} - - - org.apache.flink - flink-streaming-java_2.11 - ${flink.version} - - - org.codehaus.plexus - plexus-component-annotations - ${plexus-component-annotations.version} - - - org.codehaus.plexus - plexus-utils - ${plexus-utils.version} - - - org.eclipse.jetty - jetty-http - ${jetty.version} - - - org.eclipse.jetty - jetty-io - ${jetty.version} - - - org.eclipse.jetty - jetty-server - ${jetty.version} - - - org.eclipse.jetty - jetty-servlet - ${jetty.version} - - - org.eclipse.jetty - jetty-servlets - ${jetty.version} - - - org.eclipse.jetty - jetty-webapp - ${jetty.version} - - - org.eclipse.jetty - jetty-util - ${jetty.version} - - - org.eclipse.jetty - jetty-continuation - ${jetty.version} - - - org.eclipse.rdf4j - rdf4j-rio-turtle - ${rdf4j.version} - - - org.eclipse.rdf4j - rdf4j-rio-rdfxml - ${rdf4j.version} - - - org.elasticsearch.client - elasticsearch-rest-high-level-client - ${elasticsearch.version} - - - org.fusesource.mqtt-client - mqtt-client - ${mqtt-client.version} - - - org.fusesource.hawtbuf - hawtbuf - ${hawtbuf.version} - - - org.jboss.logging - jboss-logging - ${jboss-logging.version} - - - org.jboss.logging - jboss-logging-annotations - ${jboss-logging-annotations.version} - - - org.jboss.logging - jboss-logging-processor - ${jboss-logging-processor.version} - runtime - - - org.jetbrains - annotations - ${jetbrains-annotations.version} - - - org.jgrapht - jgrapht-core - ${jgrapht.version} - - - org.glassfish - jakarta.json - ${jakarta-json.version} - - - org.glassfish.jersey.core - jersey-client - ${jersey.version} - - - org.glassfish.jersey.core - jersey-common - ${jersey.version} - - - org.glassfish.jersey.core - jersey-server - ${jersey.version} - - - org.glassfish.jersey.containers - jersey-container-jetty-http - ${jersey.version} - - - org.glassfish.jersey.containers - jersey-container-servlet - ${jersey.version} - - - org.glassfish.jersey.containers - jersey-container-servlet-core - ${jersey.version} - - - org.glassfish.jersey.inject - jersey-hk2 - ${jersey.version} - - - org.glassfish.jersey.media - jersey-media-json-jackson - ${jersey.version} - - - org.glassfish.jersey.media - jersey-media-multipart - ${jersey.version} - - - org.glassfish.jersey.media - jersey-media-sse - ${jersey.version} - - - org.hibernate.validator - hibernate-validator - ${hibernate-validator.version} - - - org.influxdb - influxdb-java - ${influxdb.version} - - - org.javassist - javassist - ${javassist.version} - - - org.lightcouch - lightcouch - ${lightcouch.version} - - - org.lz4 - lz4-java - ${lz4.version} - - - org.objenesis - objenesis - ${objenesis.version} - - - org.osgi - org.osgi.core - ${osgi.version} - - - org.rendersnake - rendersnake - ${rendersnake.version} - - - org.simplejavamail - simple-java-mail - ${simple-java-mail.version} - - - org.slf4j - slf4j-api - ${slf4j.version} - - - org.springframework - spring-aop - ${spring.version} - - - org.springframework - spring-beans - ${spring.version} - - - org.springframework - spring-context - ${spring.version} - - - org.springframework - spring-context-support - ${spring.version} - - - org.springframework - spring-core - ${spring.version} - - - org.springframework - spring-expression - ${spring.version} - - - org.springframework - spring-webmvc - ${spring.version} - - - org.springframework.security - spring-security-core - ${spring-security.version} - - - org.springframework - spring-web - ${spring.version} - - - org.springframework.boot - spring-boot-properties-migrator - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-jersey - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-jetty - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-security - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-undertow - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-web - ${spring-boot.version} - - - org.springframework.boot - spring-boot-starter-actuator - ${spring-boot.version} - - - org.yaml - snakeyaml - ${snakeyaml.version} - - - io.fogsy - qudt - ${fogsy-qudt.version} - - - org.xerial.snappy - snappy-java - ${snappy-java.version} - - - uk.com.robust-it - cloning - ${cloning.version} - - - io.siddhi - siddhi-annotations - ${siddhi.version} - - - io.siddhi - siddhi-core - ${siddhi.version} - - - io.siddhi - siddhi-query-api - ${siddhi.version} - - - io.siddhi - siddhi-query-compiler - ${siddhi.version} - - - io.netty - netty-tcnative-classes - ${netty-tc-native.version} - + + 4.13.2 + 5.7.0 + 2.0.9 + 2.9.0 + 2.27.2 - - - com.github.tomakehurst - wiremock - ${wiremock.version} - test - - - javax.servlet - servlet-api - - - - - junit - junit - ${junit.version} - test - - - org.mockito - mockito-core - ${mockito.version} - test - - - org.powermock - powermock-module-junit4 - ${powermock.version} - test - - - org.powermock - powermock-api-mockito2 - ${powermock.version} - test - - - com.jayway.restassured - rest-assured - ${rest-assured.version} - test - + + 0.13 + 1.11 + 10.12.1 + 1.7.0 + 2.23.0 + 17 + 17 + 3.2.1 + 8.4.0 + 3.4.1 + 3.8.7 - - org.apache.flink - flink-runtime_2.11 - ${flink.version} - test-jar - - - org.apache.maven - maven-aether-provider - ${maven.version} - - - org.apache.maven - maven-model - ${maven.version} - - - org.apache.maven.plugin-tools - maven-plugin-annotations - ${maven-plugin-annotations.version} - - - org.apache.maven.shared - file-management - ${file-management.version} - - - org.codehaus.plexus - plexus-interactivity-api - ${plexus-interactivity-api.version} - - - org.jboss.forge.roaster - roaster-api - ${roaster.version} - - - org.jboss.forge.roaster - roaster-jdt - ${roaster.version} - - - - org.antlr - antlr4-runtime - ${antlr4-runtime.version} - - - io.netty - netty-handler - ${netty.version} - - - org.apache.qpid - proton-j - ${proton-j.version} - - - - edu.wpi.rail - jrosbridge - ${jsrosbridge.version} - - - io.netty - netty-resolver - ${netty-resolver.version} - - - jakarta.websocket - jakarta.websocket-api - ${jakarta-websocket-client-api.version} - - - org.apache.commons - commons-collections4 - ${commons-collections4.version} - - - org.apache.commons - commons-compress - ${commons-compress.version} - - - org.apache.commons - commons-text - ${commons-text.version} - - - org.bouncycastle - bcprov-jdk15on - ${bcprov.version} - - - org.bouncycastle - bcpkix-jdk15on - ${bcpkix.version} - - - org.checkerframework - checker-qual - ${checker-qual.version} - - - org.codehaus.mojo - animal-sniffer-annotations - ${animal-sniffer-annotations.version} - - - org.eclipse.milo - sdk-client - ${eclipse.milo.version} - - - org.graalvm.js - js - ${graalvm.js.version} - - - org.graalvm.js - js-scriptengine - ${graalvm.js.version} - + UTF-8 + false + false + + + + - org.java-websocket - Java-WebSocket - ${java-websocket.version} + commons-codec + commons-codec + ${commons-codec.version} - org.projectlombok - lombok - ${lombok.version} + commons-collections + commons-collections + ${commons-collections.version} - io.netty - netty-buffer - ${netty.version} + commons-io + commons-io + ${commons-io.version} - io.netty - netty-codec - ${netty.version} + com.fasterxml.jackson.core + jackson-annotations + ${jackson.version} - io.netty - netty-common - ${netty.version} + com.fasterxml.jackson.core + jackson-core + ${jackson.version} - io.netty - netty-transport - ${netty.version} + com.fasterxml.jackson.core + jackson-databind + ${jackson.databind.version} + + + com.fasterxml.jackson.dataformat + jackson-dataformat-cbor + ${jackson.version} + + + com.fasterxml.jackson.dataformat + jackson-dataformat-smile + ${jackson.version} + + + com.fasterxml.jackson.dataformat + jackson-dataformat-xml + ${jackson.version} + + + com.github.drapostolos + type-parser + ${type-parser.version} + + + com.google.code.gson + gson + ${gson.version} + + + com.google.guava + guava + ${guava.version} com.opencsv @@ -1099,103 +219,184 @@ ${opencsv.version} - org.apache.plc4x - plc4j-api - ${plc4x.version} + com.fasterxml.jackson.dataformat + jackson-dataformat-yaml + ${jackson.version} - org.apache.plc4x - plc4j-connection-pool - ${plc4x.version} + com.squareup.okhttp3 + okhttp + ${okhttp.version} - org.apache.plc4x - plc4j-driver-s7 - ${plc4x.version} - runtime + de.grundid.opendatalab + geojson-jackson + ${geojson-jackson.version} - org.apache.plc4x - plc4j-driver-modbus - ${plc4x.version} - runtime + de.ruedigermoeller + fst + ${fst.version} - com.google.protobuf - protobuf-java - ${protobuf.version} + io.fogsy + qudt + ${fogsy-qudt.version} - - - com.google.maps - google-maps-services - ${google-maps-services.version} + io.jsonwebtoken + jjwt-api + ${jjwt.version} - com.optimaize.languagedetector - language-detector - ${language-detector.version} + io.jsonwebtoken + jjwt-impl + ${jjwt.version} - com.rabbitmq - amqp-client - ${amqp-client.version} + io.jsonwebtoken + jjwt-jackson + ${jjwt.version} - com.ullink.slack - simpleslackapi - ${slack-api.version} + io.micrometer + micrometer-registry-prometheus + ${micrometer-prometheus.version} - io.dropwizard.metrics - metrics-core - ${metrics-core.version} + io.micrometer + micrometer-observation + ${micrometer-observation.version} - jakarta.json - jakarta.json-api - ${jakarta-json-api.version} - - - javax.mail - mailapi - ${mailapi.version} + io.nats + jnats + ${nats.version} - net.acesinc.data - json-data-generator - ${data-generator.version} + io.siddhi + siddhi-annotations + ${siddhi.version} - net.sourceforge.nekohtml - nekohtml - ${nekohtml.version} + io.siddhi + siddhi-core + ${siddhi.version} + + + io.siddhi + siddhi-query-api + ${siddhi.version} + + + io.siddhi + siddhi-query-compiler + ${siddhi.version} + + + io.swagger.core.v3 + swagger-annotations-jakarta + ${swagger.version} + + + io.swagger.core.v3 + swagger-jaxrs2-jakarta + ${swagger.version} + + + jakarta.activation + jakarta.activation-api + ${jakarta-activation-api.version} + + + jakarta.annotation + jakarta.annotation-api + ${jakarta-annotation.version} + + + jakarta.inject + jakarta.inject-api + ${jakarta-inject-api.version} + + + jakarta.validation + jakarta.validation-api + ${jakarta-validation.version} + + + jakarta.servlet + jakarta.servlet-api + ${jakarta-servlet-api.version} + + + jakarta.xml.bind + jakarta.xml.bind-api + ${jakarta-xml-bind-api.version} + + + jakarta.persistence + persistence-api + ${jakarta-persistence-api.version} + + + jakarta.ws.rs + jakarta.ws.rs-api + ${jakarta.ws.rs.version} + + + org.apache.activemq + activemq-client + ${activemq-client.version} org.apache.commons - commons-math3 - ${commons-math3.version} + commons-lang3 + ${commons-lang3.version} org.apache.commons - commons-pool2 - ${commons-pool2.version} + commons-text + ${commons-text.version} org.apache.flink - flink-cep_2.11 + flink-connector-kafka_2.11 ${flink.version} org.apache.flink - flink-runtime_2.11 + flink-java ${flink.version} - org.apache.opennlp - opennlp-tools - ${opennlp.version} + org.apache.flink + flink-streaming-java_2.11 + ${flink.version} + + + org.apache.httpcomponents + fluent-hc + ${httpclient.version} + + + org.apache.httpcomponents + httpclient + ${httpclient.version} + + + org.apache.httpcomponents + httpcore + ${httpcore.version} + + + org.apache.kafka + kafka-clients + ${kafka.version} + + + org.apache.kafka + kafka-streams + ${kafka.version} org.apache.pulsar @@ -1208,15 +409,294 @@ + + org.eclipse.rdf4j + rdf4j-rio-turtle + ${rdf4j.version} + + + org.eclipse.rdf4j + rdf4j-rio-rdfxml + ${rdf4j.version} + + + org.fusesource.mqtt-client + mqtt-client + ${mqtt-client.version} + + + org.fusesource.hawtbuf + hawtbuf + ${hawtbuf.version} + + + org.glassfish.jersey.containers + jersey-container-jetty-http + ${jersey.version} + + + org.glassfish.jersey.media + jersey-media-json-jackson + ${jersey.version} + + + org.glassfish.jersey.media + jersey-media-multipart + ${jersey.version} + + + org.influxdb + influxdb-java + ${influxdb.version} + + + org.jgrapht + jgrapht-core + ${jgrapht.version} + + + org.lightcouch + lightcouch + ${lightcouch.version} + + + org.rendersnake + rendersnake + ${rendersnake.version} + + + org.simplejavamail + simple-java-mail + ${simple-java-mail.version} + + + org.slf4j + slf4j-api + ${slf4j.version} + + + org.springframework.boot + spring-boot-properties-migrator + ${spring-boot.version} + + + org.springframework.boot + spring-boot-starter-actuator + ${spring-boot.version} + + + org.springframework.boot + spring-boot-starter-jersey + ${spring-boot.version} + + + org.springframework.boot + spring-boot-starter-security + ${spring-boot.version} + + + org.springframework.boot + spring-boot-starter-undertow + ${spring-boot.version} + + + org.springframework.boot + spring-boot-starter-web + ${spring-boot.version} + + + org.springframework.security + spring-security-core + ${spring-security.version} + + + org.yaml + snakeyaml + ${snakeyaml.version} + + + + + + com.github.tomakehurst + wiremock + ${wiremock.version} + test + + + javax.servlet + servlet-api + + + + + junit + junit + ${junit.version} + test + + + org.eclipse.jetty + jetty-server + ${jetty.version} + test + + + org.mockito + mockito-core + ${mockito.version} + test + + + org.powermock + powermock-module-junit4 + ${powermock.version} + test + + + org.powermock + powermock-api-mockito2 + ${powermock.version} + test + + + com.jayway.restassured + rest-assured + ${rest-assured.version} + test + + + + + + org.apache.maven + maven-plugin-api + ${maven.version} + + + org.apache.maven + maven-core + ${maven.version} + + + org.apache.maven + maven-artifact + ${maven.version} + + + org.apache.maven + maven-compat + ${maven.version} + + + org.codehaus.plexus + plexus-component-annotations + ${plexus-component-annotations.version} + + + org.codehaus.plexus + plexus-utils + ${plexus-utils.version} + + + org.apache.maven + maven-aether-provider + ${maven.version} + + + org.apache.maven + maven-model + ${maven.version} + + + org.apache.maven.plugin-tools + maven-plugin-annotations + ${maven-plugin-annotations.version} + + + org.apache.maven.shared + file-management + ${file-management.version} + + + org.codehaus.plexus + plexus-interactivity-api + ${plexus-interactivity-api.version} + + + + + + com.google.maps + google-maps-services + ${google-maps-services.version} + + + com.rabbitmq + amqp-client + ${amqp-client.version} + + + com.ullink.slack + simpleslackapi + ${slack-api.version} + + + edu.wpi.rail + jrosbridge + ${jsrosbridge.version} + + + org.apache.commons + commons-compress + ${commons-compress.version} + + + org.apache.commons + commons-pool2 + ${commons-pool2.version} + + + org.apache.inlong + tubemq-client + ${inlong.version} + + + org.apache.opennlp + opennlp-tools + ${opennlp.version} + + + org.apache.plc4x + plc4j-api + ${plc4x.version} + + + org.apache.plc4x + plc4j-connection-pool + ${plc4x.version} + + + org.apache.plc4x + plc4j-driver-s7 + ${plc4x.version} + runtime + + + org.apache.plc4x + plc4j-driver-modbus + ${plc4x.version} + runtime + org.apache.rocketmq rocketmq-client-java ${rocketmq.version} - org.atteo.classindex - classindex - ${classindex.version} + org.apache.sis.core + sis-referencing + ${apache-sis-referencing.version} org.boofcv @@ -1229,34 +709,39 @@ ${ditto-client.version} - org.elasticsearch - elasticsearch - ${elasticsearch.version} + org.eclipse.milo + sdk-client + ${eclipse.milo.version} - org.postgresql - postgresql - ${postgresql.version} + org.glassfish.jersey.media + jersey-media-sse + ${jersey.version} + + + org.graalvm.js + js + ${graalvm.js.version} - org.scala-lang - scala-library - ${scala-lang.version} + org.graalvm.js + js-scriptengine + ${graalvm.js.version} - org.scala-lang.modules - scala-parser-combinators_2.11 - ${scala-parser-combinators.version} + org.java-websocket + Java-WebSocket + ${java-websocket.version} - xerces - xercesImpl - ${xerces.version} + org.locationtech.jts + jts-core + ${jts-core.version} - redis.clients - jedis - ${jedis.version} + org.postgresql + postgresql + ${postgresql.version} org.quartz-scheduler @@ -1264,50 +749,83 @@ ${quartz.version} - org.apache.inlong - tubemq-client - ${inlong.version} + redis.clients + jedis + ${jedis.version} - - - - org.locationtech.jts - jts-core - ${jts-core.version} - - - - org.apache.sis.core - sis-referencing - ${apache-sis-referencing.version} - + + + org.jboss.logging + jboss-logging + ${jboss-logging.version} + + + org.glassfish.jersey.core + jersey-common + ${jersey.version} + + + org.javassist + javassist + ${javassist.version} + + + javax.xml.bind + jaxb-api + ${javax.xml.bind.version} + org.glassfish.jaxb jaxb-runtime ${jaxb-runtime.version} - net.java.dev.jna - jna - ${jna.version} + org.checkerframework + checker-qual + ${checker-qual.version} + + + javax.websocket + javax.websocket-api + ${javax-websocket-api.version} + + + io.netty + netty-handler + ${netty.version} + + + io.netty + netty-buffer + ${netty.version} + + + io.netty + netty-codec + ${netty.version} + + + io.netty + netty-common + ${netty.version} - org.jetbrains.kotlin - kotlin-stdlib - ${kotlin-stdlib.version} + io.netty + netty-transport + ${netty.version} + + + org.atteo.classindex + classindex + ${classindex.version} + + + com.google.protobuf + protobuf-java + ${protobuf.version} - - io.micrometer - micrometer-registry-prometheus - ${micrometer-prometheus.version} - - - io.micrometer - micrometer-observation - ${micrometer-observation.version} - @@ -1316,53 +834,53 @@ archetypes/streampipes-archetype-pe-sinks-flink archetypes/streampipes-archetype-pe-processors-flink streampipes-client - streampipes-client-api + streampipes-client-api streampipes-commons streampipes-config streampipes-connect-management - streampipes-connect-shared - streampipes-extensions-api + streampipes-connect-shared + streampipes-extensions-api streampipes-extensions-management streampipes-data-explorer - streampipes-data-explorer-commons - streampipes-data-export + streampipes-data-explorer-commons + streampipes-data-export streampipes-dataformat streampipes-dataformat-cbor streampipes-dataformat-fst streampipes-dataformat-json streampipes-dataformat-smile streampipes-extensions - streampipes-integration-tests - streampipes-mail + streampipes-integration-tests + streampipes-mail streampipes-maven-plugin streampipes-measurement-units streampipes-messaging-kafka streampipes-messaging streampipes-messaging-jms streampipes-messaging-mqtt - streampipes-messaging-nats + streampipes-messaging-nats streampipes-messaging-pulsar streampipes-model streampipes-model-client streampipes-model-shared streampipes-platform-services streampipes-pipeline-management - streampipes-resource-management - streampipes-rest-extensions + streampipes-resource-management + streampipes-rest-extensions streampipes-rest streampipes-rest-core-base streampipes-rest-shared streampipes-sdk - streampipes-sdk-bundle + streampipes-sdk-bundle streampipes-security-jwt streampipes-serializers-json streampipes-service-base - streampipes-service-core - streampipes-service-core-minimal + streampipes-service-core + streampipes-service-core-minimal streampipes-service-discovery streampipes-service-discovery-consul streampipes-service-discovery-api - streampipes-service-extensions + streampipes-service-extensions streampipes-storage-api streampipes-storage-management streampipes-storage-couchdb @@ -1375,7 +893,7 @@ streampipes-wrapper-kafka-streams streampipes-wrapper-siddhi streampipes-wrapper-standalone - + @@ -1478,22 +996,22 @@ org.apache.maven.plugins maven-assembly-plugin - - - source-release-assembly - - apache-streampipes-${project.version} - - tools/maven/assembly.xml - - - - + + + source-release-assembly + + apache-streampipes-${project.version} + + tools/maven/assembly.xml + + + + org.apache.maven.plugins maven-checkstyle-plugin - ${maven-checkstyle-plugin.version} + ${maven-checkstyle-plugin.version} com.puppycrawl.tools @@ -1537,27 +1055,27 @@ - - org.apache.maven.plugins - maven-assembly-plugin - - - false - installer-files - package - - single - - - true - apache-streampipes-${project.version}-installer - - ${project.basedir}/tools/maven/installer.xml - - - - - + + org.apache.maven.plugins + maven-assembly-plugin + + + false + installer-files + package + + single + + + true + apache-streampipes-${project.version}-installer + + ${project.basedir}/tools/maven/installer.xml + + + + + org.apache.maven.plugins maven-enforcer-plugin @@ -1585,7 +1103,7 @@ - + @@ -1674,8 +1192,8 @@ **/*.ipynb - - **/*.svg + + **/*.svg **/system @@ -1694,7 +1212,7 @@ - streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/** + streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/** streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/processor/revgeocoder/geocode/** @@ -1730,7 +1248,7 @@ .mypy_cache/** **/site/** **/.mypy_cache/** - **/poetry.lock + **/poetry.lock ui/.husky/** @@ -1812,7 +1330,6 @@ scm:git:ssh://git@github.com/apache/streampipes.git scm:git:ssh://git@github.com/apache/streampipes.git https://github.com/apache/streampipes - rel/0.91.0 diff --git a/streampipes-client-api/pom.xml b/streampipes-client-api/pom.xml index 947df759e4..de47e02af7 100644 --- a/streampipes-client-api/pom.xml +++ b/streampipes-client-api/pom.xml @@ -45,14 +45,10 @@ streampipes-model 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-service-discovery-api - 0.95.0-SNAPSHOT - + org.apache.httpcomponents - fluent-hc + httpcore diff --git a/streampipes-client/pom.xml b/streampipes-client/pom.xml index 1cd53c2c7f..f16fa82d4b 100644 --- a/streampipes-client/pom.xml +++ b/streampipes-client/pom.xml @@ -59,11 +59,6 @@ streampipes-model 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-model-client - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-security-jwt @@ -83,10 +78,6 @@ - - commons-io - commons-io - org.apache.httpcomponents fluent-hc diff --git a/streampipes-commons/pom.xml b/streampipes-commons/pom.xml index 46a5e5bf73..10e30ec144 100644 --- a/streampipes-commons/pom.xml +++ b/streampipes-commons/pom.xml @@ -31,10 +31,6 @@ - - commons-codec - commons-codec - org.apache.commons commons-lang3 @@ -43,14 +39,14 @@ commons-io commons-io - - ch.qos.logback - logback-classic - io.micrometer micrometer-registry-prometheus + + org.slf4j + slf4j-api + junit diff --git a/streampipes-config/pom.xml b/streampipes-config/pom.xml index de47e28c72..a445066de5 100644 --- a/streampipes-config/pom.xml +++ b/streampipes-config/pom.xml @@ -34,21 +34,6 @@ streampipes-model 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-model-client - 0.95.0-SNAPSHOT - - - org.apache.streampipes - streampipes-serializers-json - 0.95.0-SNAPSHOT - - - org.apache.streampipes - streampipes-vocabulary - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-service-discovery diff --git a/streampipes-connect-management/pom.xml b/streampipes-connect-management/pom.xml index c9c1dd2836..661ac1e620 100644 --- a/streampipes-connect-management/pom.xml +++ b/streampipes-connect-management/pom.xml @@ -54,28 +54,6 @@ streampipes-storage-couchdb 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-user-management - 0.95.0-SNAPSHOT - - - org.apache.streampipes - streampipes-data-explorer - 0.95.0-SNAPSHOT - - - - - org.apache.httpcomponents - httpmime - - - - - org.jetbrains - annotations - diff --git a/streampipes-data-explorer-commons/pom.xml b/streampipes-data-explorer-commons/pom.xml index 08226bb01b..cfcbea0c2b 100644 --- a/streampipes-data-explorer-commons/pom.xml +++ b/streampipes-data-explorer-commons/pom.xml @@ -29,7 +29,7 @@ org.apache.streampipes - streampipes-service-discovery-api + streampipes-client-api 0.95.0-SNAPSHOT @@ -37,11 +37,6 @@ streampipes-model 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-client - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-commons diff --git a/streampipes-data-explorer/pom.xml b/streampipes-data-explorer/pom.xml index 688cbeca3b..c68a436d7d 100644 --- a/streampipes-data-explorer/pom.xml +++ b/streampipes-data-explorer/pom.xml @@ -59,10 +59,6 @@ org.influxdb influxdb-java - - commons-io - commons-io - diff --git a/streampipes-dataformat-json/pom.xml b/streampipes-dataformat-json/pom.xml index 3ed946cfc3..714feebf92 100644 --- a/streampipes-dataformat-json/pom.xml +++ b/streampipes-dataformat-json/pom.xml @@ -45,10 +45,6 @@ com.fasterxml.jackson.core jackson-databind - - com.fasterxml.jackson.core - jackson-annotations - com.fasterxml.jackson.core jackson-core diff --git a/streampipes-extensions-api/pom.xml b/streampipes-extensions-api/pom.xml index 377a62d51e..5ba43b3754 100644 --- a/streampipes-extensions-api/pom.xml +++ b/streampipes-extensions-api/pom.xml @@ -43,11 +43,6 @@ streampipes-model 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-service-discovery-api - 0.95.0-SNAPSHOT - 8 diff --git a/streampipes-extensions-management/pom.xml b/streampipes-extensions-management/pom.xml index 682d764cbc..39c4b44f08 100644 --- a/streampipes-extensions-management/pom.xml +++ b/streampipes-extensions-management/pom.xml @@ -73,11 +73,6 @@ streampipes-serializers-json 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-service-discovery - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-test-utils @@ -92,18 +87,10 @@ - - ch.qos.logback - logback-classic - de.grundid.opendatalab geojson-jackson - - jakarta.json - jakarta.json-api - com.fasterxml.jackson.dataformat jackson-dataformat-xml @@ -112,16 +99,6 @@ com.opencsv opencsv - - org.eclipse.parsson - jakarta.json - 1.1.1 - - - - org.apache.httpcomponents - fluent-hc - @@ -134,10 +111,6 @@ jetty-server test - - jakarta.servlet - jakarta.servlet-api - com.jayway.restassured rest-assured diff --git a/streampipes-extensions/pom.xml b/streampipes-extensions/pom.xml index 0d03fce705..ec1ec140e3 100644 --- a/streampipes-extensions/pom.xml +++ b/streampipes-extensions/pom.xml @@ -46,7 +46,6 @@ streampipes-extensions-all-iiot streampipes-extensions-all-jvm - streampipes-pipeline-elements-data-simulator streampipes-pipeline-elements-shared streampipes-processors-change-detection-jvm @@ -100,7 +99,6 @@ org.springframework.boot spring-boot-maven-plugin - ${spring-boot.version} diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/pom.xml b/streampipes-extensions/streampipes-connect-adapters-iiot/pom.xml index 53df31c415..f2917f08b7 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/pom.xml +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/pom.xml @@ -56,46 +56,10 @@ - - com.fasterxml.jackson.module - jackson-module-jaxb-annotations - - - com.google.protobuf - protobuf-java - - - com.opencsv - opencsv - edu.wpi.rail jrosbridge - - io.netty - netty-buffer - - - io.netty - netty-codec - - - io.netty - netty-common - - - io.netty - netty-transport - - - org.fusesource.mqtt-client - mqtt-client - - - jakarta.websocket - jakarta.websocket-api - org.apache.httpcomponents fluent-hc @@ -105,34 +69,8 @@ commons-compress - org.apache.commons - commons-text - - - org.bouncycastle - bcprov-jdk15on - - - org.checkerframework - checker-qual - - - org.codehaus.mojo - animal-sniffer-annotations - - - org.glassfish.jersey.media - jersey-media-sse - - - org.glassfish.jersey.core - jersey-server - - - - - org.java-websocket - Java-WebSocket + org.javassist + javassist @@ -168,20 +106,6 @@ junit test - - - - org.glassfish.jaxb - jaxb-runtime - - - org.apache.commons - commons-collections4 - - - javax.websocket - javax.websocket-api - diff --git a/streampipes-extensions/streampipes-connect-adapters/pom.xml b/streampipes-extensions/streampipes-connect-adapters/pom.xml index 83dd5ba538..04c217e21f 100644 --- a/streampipes-extensions/streampipes-connect-adapters/pom.xml +++ b/streampipes-extensions/streampipes-connect-adapters/pom.xml @@ -56,79 +56,21 @@ - - com.google.protobuf - protobuf-java - - - com.opencsv - opencsv - com.ullink.slack simpleslackapi - - io.netty - netty-buffer - - - io.netty - netty-codec - - - io.netty - netty-common - - - io.netty - netty-transport - - - org.fusesource.mqtt-client - mqtt-client - - - jakarta.websocket - jakarta.websocket-api - org.apache.httpcomponents fluent-hc - - org.apache.commons - commons-compress - - - org.apache.commons - commons-text - - - org.bouncycastle - bcprov-jdk15on - - - org.checkerframework - checker-qual - - - org.codehaus.mojo - animal-sniffer-annotations - org.glassfish.jersey.media jersey-media-sse - - - org.glassfish.jersey.core - jersey-server - - - org.java-websocket - Java-WebSocket + org.javassist + javassist @@ -160,16 +102,6 @@ junit test - - - - org.glassfish.jaxb - jaxb-runtime - - - org.apache.commons - commons-collections4 - diff --git a/streampipes-extensions/streampipes-connectors-opcua/pom.xml b/streampipes-extensions/streampipes-connectors-opcua/pom.xml index 4bc6decc77..50317fa837 100644 --- a/streampipes-extensions/streampipes-connectors-opcua/pom.xml +++ b/streampipes-extensions/streampipes-connectors-opcua/pom.xml @@ -52,10 +52,6 @@ 0.95.0-SNAPSHOT - - jakarta.annotation - jakarta.annotation-api - org.eclipse.milo sdk-client diff --git a/streampipes-extensions/streampipes-extensions-all-iiot/pom.xml b/streampipes-extensions/streampipes-extensions-all-iiot/pom.xml index 70d91a582c..2c2788fdb5 100644 --- a/streampipes-extensions/streampipes-extensions-all-iiot/pom.xml +++ b/streampipes-extensions/streampipes-extensions-all-iiot/pom.xml @@ -115,6 +115,16 @@ org.apache.streampipes streampipes-processors-filters-siddhi 0.95.0-SNAPSHOT + + + org.apache.logging.log4j + log4j-api + + + org.apache.logging.log4j + log4j-core + + org.apache.streampipes @@ -151,25 +161,44 @@ streampipes-processors-change-detection-jvm 0.95.0-SNAPSHOT + + org.apache.streampipes + streampipes-connect-adapters-iiot + 0.95.0-SNAPSHOT + - + + + org.atteo.classindex + classindex + - io.dropwizard.metrics - metrics-core + org.checkerframework + checker-qual + + + javax.websocket + javax.websocket-api io.netty netty-handler - org.atteo.classindex - classindex + io.netty + netty-buffer - - org.apache.streampipes - streampipes-connect-adapters-iiot - 0.95.0-SNAPSHOT + io.netty + netty-codec + + + io.netty + netty-common + + + io.netty + netty-transport diff --git a/streampipes-extensions/streampipes-extensions-all-jvm/pom.xml b/streampipes-extensions/streampipes-extensions-all-jvm/pom.xml index 9b475be045..7df2518fd2 100644 --- a/streampipes-extensions/streampipes-extensions-all-jvm/pom.xml +++ b/streampipes-extensions/streampipes-extensions-all-jvm/pom.xml @@ -126,6 +126,16 @@ org.apache.streampipes streampipes-processors-filters-siddhi 0.95.0-SNAPSHOT + + + org.apache.logging.log4j + log4j-api + + + org.apache.logging.log4j + log4j-core + + org.apache.streampipes @@ -183,10 +193,43 @@ streampipes-messaging-nats 0.95.0-SNAPSHOT - + + + + com.google.protobuf + protobuf-java + + + org.atteo.classindex + classindex + + + org.checkerframework + checker-qual + + + javax.websocket + javax.websocket-api + + + io.netty + netty-handler + + + io.netty + netty-buffer + + + io.netty + netty-codec + + + io.netty + netty-common + - org.antlr - antlr4-runtime + io.netty + netty-transport diff --git a/streampipes-extensions/streampipes-extensions-iiot-minimal/pom.xml b/streampipes-extensions/streampipes-extensions-iiot-minimal/pom.xml index 839ff52ead..f0f413e60b 100644 --- a/streampipes-extensions/streampipes-extensions-iiot-minimal/pom.xml +++ b/streampipes-extensions/streampipes-extensions-iiot-minimal/pom.xml @@ -29,6 +29,10 @@ streampipes-extensions-iiot-minimal + + true + + org.apache.streampipes @@ -82,6 +86,16 @@ org.apache.streampipes streampipes-processors-filters-siddhi 0.95.0-SNAPSHOT + + + org.apache.logging.log4j + log4j-api + + + org.apache.logging.log4j + log4j-core + + org.apache.streampipes @@ -134,6 +148,40 @@ streampipes-wrapper-standalone 0.95.0-SNAPSHOT + + + + org.atteo.classindex + classindex + + + org.checkerframework + checker-qual + + + javax.websocket + javax.websocket-api + + + io.netty + netty-handler + + + io.netty + netty-buffer + + + io.netty + netty-codec + + + io.netty + netty-common + + + io.netty + netty-transport + diff --git a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/pom.xml b/streampipes-extensions/streampipes-pipeline-elements-data-simulator/pom.xml deleted file mode 100644 index 7333c4d11f..0000000000 --- a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/pom.xml +++ /dev/null @@ -1,88 +0,0 @@ - - - - - - streampipes-extensions - org.apache.streampipes - 0.95.0-SNAPSHOT - - 4.0.0 - - streampipes-pipeline-elements-data-simulator - - - true - - - - - net.acesinc.data - json-data-generator - - - org.eclipse.jetty - jetty-server - - - org.hibernate - hibernate-validator - - - javax.validation - validation-api - - - com.sun.jersey - jersey-core - - - com.sun.jersey - jersey-server - - - com.sun.jersey - jersey-servlet - - - com.sun.jersey.contribs - jersey-guice - - - org.eclipse.paho - org.eclipse.paho.client.mqttv3 - - - com.metamx - tranquility_2.10 - - - - - - - - - - org.apache.maven.plugins - maven-checkstyle-plugin - - - - diff --git a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/StreamPipesSimulationRunner.java b/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/StreamPipesSimulationRunner.java deleted file mode 100644 index 0871b7c884..0000000000 --- a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/StreamPipesSimulationRunner.java +++ /dev/null @@ -1,115 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ -package org.apache.streampipes.pe.simulator; - -import net.acesinc.data.json.generator.EventGenerator; -import net.acesinc.data.json.generator.SimulationRunner; -import net.acesinc.data.json.generator.config.SimulationConfig; -import net.acesinc.data.json.generator.config.WorkflowConfig; -import net.acesinc.data.json.generator.log.EventLogger; -import net.acesinc.data.json.generator.log.KafkaLogger; -import org.apache.logging.log4j.LogManager; -import org.apache.logging.log4j.Logger; - -import java.util.ArrayList; -import java.util.Collections; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -public class StreamPipesSimulationRunner { - - private static final Logger log = LogManager.getLogger(SimulationRunner.class); - private SimulationConfig config; - private List eventGenerators; - private List eventGenThreads; - private boolean running; - private List eventLoggers; - private Map simulationWorkflows; - private String kafkaHost; - private Integer kafkaPort; - - public StreamPipesSimulationRunner(SimulationConfig config, Map - simulationWorkflows, String kafkaHost, Integer kafkaPort) { - this.config = config; - this.kafkaHost = kafkaHost; - this.kafkaPort = kafkaPort; - eventGenerators = new ArrayList<>(); - eventLoggers = new ArrayList<>(); - eventGenThreads = new ArrayList<>(); - this.simulationWorkflows = simulationWorkflows; - - setupSimulation(); - } - - private Map makeProducerConfig(String topic) { - Map producerConfig = new HashMap<>(); - producerConfig.put("broker.server", this.kafkaHost); - producerConfig.put("broker.port", this.kafkaPort); - producerConfig.put("flatten", false); - producerConfig.put("sync", false); - producerConfig.put("topic", topic); - - return producerConfig; - } - - private void setupSimulation() { - running = false; - for (WorkflowConfig workflowConfig : config.getWorkflows()) { - if (simulationWorkflows.containsKey(workflowConfig.getWorkflowFilename())) { - TopicAwareWorkflow w = simulationWorkflows.get(workflowConfig.getWorkflowFilename()); - KafkaLogger kafkaLogger = new KafkaLogger(makeProducerConfig(w.getTargetTopic())); - eventLoggers.add(kafkaLogger); - final EventGenerator gen = new EventGenerator(w, workflowConfig, - Collections.singletonList(kafkaLogger)); - log.info("Adding EventGenerator for [ " + workflowConfig.getWorkflowName() + "," - + workflowConfig.getWorkflowFilename() + " ]"); - eventGenerators.add(gen); - eventGenThreads.add(new Thread(gen)); - } - } - } - - public void startSimulation() { - log.info("Starting Simulation"); - - if (eventGenThreads.size() > 0) { - for (Thread t : eventGenThreads) { - t.start(); - } - running = true; - } - } - - public void stopSimulation() { - log.info("Stopping Simulation"); - for (Thread t : eventGenThreads) { - t.interrupt(); - } - for (EventLogger l : eventLoggers) { - l.shutdown(); - } - running = false; - } - - public boolean isRunning() { - return running; - } - -} diff --git a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/TopicAwareWorkflow.java b/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/TopicAwareWorkflow.java deleted file mode 100644 index e7a0d58106..0000000000 --- a/streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/TopicAwareWorkflow.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - */ -package org.apache.streampipes.pe.simulator; - -import net.acesinc.data.json.generator.workflow.Workflow; - -public class TopicAwareWorkflow extends Workflow { - - private String targetTopic; - - public TopicAwareWorkflow() { - - } - - public String getTargetTopic() { - return targetTopic; - } - - public void setTargetTopic(String targetTopic) { - this.targetTopic = targetTopic; - } -} diff --git a/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/pom.xml b/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/pom.xml index 540579af0d..cd069e7c62 100644 --- a/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/pom.xml +++ b/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/pom.xml @@ -42,10 +42,6 @@ streampipes-wrapper-flink 0.95.0-SNAPSHOT - - org.atteo.classindex - classindex - org.apache.flink flink-cep_2.11 @@ -78,12 +74,6 @@ xerces xercesImpl - - - - io.dropwizard.metrics - metrics-core - diff --git a/streampipes-extensions/streampipes-processors-filters-siddhi/pom.xml b/streampipes-extensions/streampipes-processors-filters-siddhi/pom.xml index 1cc59d6d00..7fe41be2ea 100644 --- a/streampipes-extensions/streampipes-processors-filters-siddhi/pom.xml +++ b/streampipes-extensions/streampipes-processors-filters-siddhi/pom.xml @@ -46,17 +46,6 @@ - - - io.dropwizard.metrics - metrics-core - - - org.atteo.classindex - classindex - - - junit diff --git a/streampipes-extensions/streampipes-sinks-brokers-jvm/pom.xml b/streampipes-extensions/streampipes-sinks-brokers-jvm/pom.xml index 30e7a0513f..f81ba04dd9 100644 --- a/streampipes-extensions/streampipes-sinks-brokers-jvm/pom.xml +++ b/streampipes-extensions/streampipes-sinks-brokers-jvm/pom.xml @@ -77,22 +77,6 @@ Java-WebSocket - - - io.netty - netty-resolver - - - org.graalvm.nativeimage - svm - - - - - org.projectlombok - lombok - - org.mockito mockito-core diff --git a/streampipes-extensions/streampipes-sinks-databases-jvm/pom.xml b/streampipes-extensions/streampipes-sinks-databases-jvm/pom.xml index eb7596ecd6..396cb042ea 100644 --- a/streampipes-extensions/streampipes-sinks-databases-jvm/pom.xml +++ b/streampipes-extensions/streampipes-sinks-databases-jvm/pom.xml @@ -75,37 +75,15 @@ jedis - - io.dropwizard.metrics - metrics-core - - - org.atteo.classindex - classindex - - - - - jakarta.activation - jakarta.activation-api - - - jakarta.xml.bind - jakarta.xml.bind-api + javax.xml.bind + jaxb-api org.glassfish.jaxb jaxb-runtime - - org.bouncycastle - bcprov-jdk15on - - - org.bouncycastle - bcpkix-jdk15on - + @@ -118,12 +96,6 @@ mockito-core test - - - - javax.xml.bind - jaxb-api - diff --git a/streampipes-extensions/streampipes-sinks-notifications-jvm/pom.xml b/streampipes-extensions/streampipes-sinks-notifications-jvm/pom.xml index 5ab98e01ae..78c44edca0 100644 --- a/streampipes-extensions/streampipes-sinks-notifications-jvm/pom.xml +++ b/streampipes-extensions/streampipes-sinks-notifications-jvm/pom.xml @@ -50,10 +50,6 @@ com.ullink.slack simpleslackapi - - javax.mail - mailapi - com.squareup.okhttp3 okhttp diff --git a/streampipes-mail/pom.xml b/streampipes-mail/pom.xml index 1d35962182..cce1fe8951 100644 --- a/streampipes-mail/pom.xml +++ b/streampipes-mail/pom.xml @@ -27,11 +27,6 @@ streampipes-mail - - org.apache.streampipes - streampipes-config - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-user-management @@ -41,12 +36,6 @@ org.simplejavamail simple-java-mail - - - - com.j2html - j2html - diff --git a/streampipes-pipeline-management/pom.xml b/streampipes-pipeline-management/pom.xml index 10fcd48fc8..c011959769 100644 --- a/streampipes-pipeline-management/pom.xml +++ b/streampipes-pipeline-management/pom.xml @@ -101,10 +101,6 @@ org.jgrapht jgrapht-core - - org.objenesis - objenesis - diff --git a/streampipes-rest-extensions/pom.xml b/streampipes-rest-extensions/pom.xml index 874ac5133a..ec07d78fb6 100644 --- a/streampipes-rest-extensions/pom.xml +++ b/streampipes-rest-extensions/pom.xml @@ -42,6 +42,11 @@ streampipes-extensions-management 0.95.0-SNAPSHOT + + org.apache.streampipes + streampipes-service-discovery-api + 0.95.0-SNAPSHOT + @@ -67,10 +72,6 @@ - - org.springframework.security - spring-security-core - diff --git a/streampipes-rest/pom.xml b/streampipes-rest/pom.xml index 6541d59856..7725543934 100644 --- a/streampipes-rest/pom.xml +++ b/streampipes-rest/pom.xml @@ -40,11 +40,6 @@ - - org.apache.streampipes - streampipes-config - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-data-explorer @@ -80,16 +75,6 @@ streampipes-rest-shared 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-serializers-json - 0.95.0-SNAPSHOT - - - org.apache.streampipes - streampipes-service-discovery - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-user-management @@ -111,10 +96,6 @@ io.swagger.core.v3 swagger-annotations-jakarta - - org.influxdb - influxdb-java - diff --git a/streampipes-sdk/pom.xml b/streampipes-sdk/pom.xml index fd58258af3..84d2ef5200 100644 --- a/streampipes-sdk/pom.xml +++ b/streampipes-sdk/pom.xml @@ -29,11 +29,6 @@ - - org.apache.streampipes - streampipes-config - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-commons @@ -60,10 +55,6 @@ com.github.drapostolos type-parser - - org.apache.httpcomponents - fluent-hc - diff --git a/streampipes-security-jwt/pom.xml b/streampipes-security-jwt/pom.xml index c3d21823fd..bcd26f030f 100644 --- a/streampipes-security-jwt/pom.xml +++ b/streampipes-security-jwt/pom.xml @@ -32,6 +32,10 @@ streampipes-commons 0.95.0-SNAPSHOT + + commons-codec + commons-codec + io.jsonwebtoken jjwt-api diff --git a/streampipes-service-base/pom.xml b/streampipes-service-base/pom.xml index 57da98e922..8960a8e168 100644 --- a/streampipes-service-base/pom.xml +++ b/streampipes-service-base/pom.xml @@ -84,6 +84,15 @@ org.springframework.boot spring-boot-starter-actuator + + + org.jboss.logging + jboss-logging + + + org.glassfish.jersey.core + jersey-common + diff --git a/streampipes-service-core/pom.xml b/streampipes-service-core/pom.xml index 7a2d01c34a..72f1b30d60 100644 --- a/streampipes-service-core/pom.xml +++ b/streampipes-service-core/pom.xml @@ -98,17 +98,21 @@ io.swagger.core.v3 swagger-jaxrs2-jakarta + + + com.fasterxml.jackson.datatype + jackson-datatype-jsr310 + + + com.fasterxml.jackson.module + jackson-module-jakarta-xmlbind-annotations + + jakarta.annotation jakarta.annotation-api - - - - ch.qos.logback - logback-core - diff --git a/streampipes-service-discovery-consul/pom.xml b/streampipes-service-discovery-consul/pom.xml index 834c2329eb..4ce5796943 100644 --- a/streampipes-service-discovery-consul/pom.xml +++ b/streampipes-service-discovery-consul/pom.xml @@ -45,10 +45,6 @@ consul-api 1.4.5 - - org.apache.httpcomponents - fluent-hc - diff --git a/streampipes-service-extensions/pom.xml b/streampipes-service-extensions/pom.xml index 1acf490ee2..5782e9aa29 100644 --- a/streampipes-service-extensions/pom.xml +++ b/streampipes-service-extensions/pom.xml @@ -39,14 +39,13 @@ org.apache.streampipes streampipes-rest-extensions 0.95.0-SNAPSHOT + + + org.javassist + javassist + + - - - - com.fasterxml.jackson.datatype - jackson-datatype-jdk8 - - diff --git a/streampipes-storage-couchdb/pom.xml b/streampipes-storage-couchdb/pom.xml index 68a2259c5a..ff17524577 100644 --- a/streampipes-storage-couchdb/pom.xml +++ b/streampipes-storage-couchdb/pom.xml @@ -29,11 +29,6 @@ - - org.apache.streampipes - streampipes-service-discovery-api - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-model @@ -59,10 +54,6 @@ com.google.code.gson gson - - org.apache.commons - commons-text - org.apache.httpcomponents fluent-hc diff --git a/streampipes-user-management/pom.xml b/streampipes-user-management/pom.xml index df5d1b9ed5..fc29949bf4 100644 --- a/streampipes-user-management/pom.xml +++ b/streampipes-user-management/pom.xml @@ -51,6 +51,10 @@ + + org.apache.commons + commons-text + org.springframework.security spring-security-core diff --git a/streampipes-wrapper-distributed/pom.xml b/streampipes-wrapper-distributed/pom.xml index e90fa4bb95..2fc76cfa01 100644 --- a/streampipes-wrapper-distributed/pom.xml +++ b/streampipes-wrapper-distributed/pom.xml @@ -29,21 +29,11 @@ - - org.apache.streampipes - streampipes-messaging-jms - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-messaging-kafka 0.95.0-SNAPSHOT - - org.apache.streampipes - streampipes-messaging-mqtt - 0.95.0-SNAPSHOT - org.apache.streampipes streampipes-wrapper @@ -63,4 +53,4 @@ - \ No newline at end of file + diff --git a/streampipes-wrapper-flink/pom.xml b/streampipes-wrapper-flink/pom.xml index 179ac3e8ac..676c29e779 100644 --- a/streampipes-wrapper-flink/pom.xml +++ b/streampipes-wrapper-flink/pom.xml @@ -27,8 +27,37 @@ streampipes-wrapper-flink StreamPipes Wrapper for Apache Flink + + 1.13.5 + + + + + + org.objenesis + objenesis + 3.3 + + + org.xerial.snappy + snappy-java + 1.1.10.4 + + + + + + org.apache.streampipes + streampipes-messaging-jms + 0.95.0-SNAPSHOT + + + org.apache.streampipes + streampipes-messaging-mqtt + 0.95.0-SNAPSHOT + org.apache.streampipes streampipes-wrapper-distributed @@ -107,13 +136,12 @@ - org.xerial.snappy - snappy-java + org.objenesis + objenesis - - com.esotericsoftware.kryo - kryo + org.xerial.snappy + snappy-java