You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/11/15 12:56:19 UTC
[incubator-streampipes] branch dev updated (b0b157a -> fbaeb08)
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from b0b157a [hotfix] use adoptopenjdk/openjdk8-openj9:alpine base image for all Dockerfiles
add b01ce7c [STREAMPIPES-252] add mqtt transport protocol
add 4d3cdcd [STREAMPIPES-252] add SP_PRIORITIZED_PROTOCOL env variable
add 8f1e08b Merge branch 'dev' into STREAMPIPES-252
add 2c4324f [STREAMPIPES-252] add SP_PRIORITIZED_PROTOCOL to .idea run config
add 007bd04 [STREAMPIPES-252] add mqtt transport protocol to flink wrapper
add e994228 [STREAMPIPES-252] remove prioritizedProtocol helper from sdk, fixed typo
add fbaeb08 [STREAMPIPES-252] add mqtt transport protocol to archetypes
No new revisions were added by this update.
Summary of changes:
.idea/runConfigurations/backend.xml | 1 +
.../archetype-resources/src/main/java/Init.java | 1 +
.../src/main/resources/archetype-resources/pom.xml | 5 +
.../archetype-resources/src/main/java/Init.java | 1 +
.../archetype-resources/src/main/java/Init.java | 1 +
.../src/main/resources/archetype-resources/pom.xml | 5 +
.../archetype-resources/src/main/java/Init.java | 1 +
pom.xml | 6 ++
.../streampipes/config/backend/BackendConfig.java | 16 +++-
.../config/backend/BackendConfigKeys.java | 4 +
.../config/backend/MessagingSettings.java | 45 +++++++--
.../backend/{SpDataFormat.java => SpProtocol.java} | 24 ++---
.../master/management/AdapterMasterManagement.java | 3 +-
streampipes-connect/pom.xml | 10 ++
.../streampipes/connect/adapter/Adapter.java | 52 +++++++++--
.../connect/adapter/GroundingService.java | 93 +++++++++++++++++--
.../model/pipeline/AdapterPipelineElement.java | 2 +-
.../elements/SendToBrokerAdapterSink.java | 103 +++++++++++++++++++++
...ink.java => SendToBrokerReplayAdapterSink.java} | 22 +++--
...elineElement.java => SendToJmsAdapterSink.java} | 21 ++---
.../elements/SendToKafkaAdapterSink.java | 57 ++----------
...lineElement.java => SendToMqttAdapterSink.java} | 21 ++---
.../connect/adapter/GroundingServiceTest.java | 8 +-
.../messaging/jms/ActiveMQConsumer.java | 3 +-
.../messaging/jms/ActiveMQPublisher.java | 18 +++-
.../streampipes/messaging/jms/ActiveMQUtils.java | 17 ++--
streampipes-messaging-mqtt/pom.xml | 4 +
.../streampipes/messaging/mqtt/MqttConsumer.java | 43 +++++++--
.../org/apache/streampipes/model/util/Cloner.java | 11 +--
streampipes-pipeline-management/pom.xml | 5 +
.../manager/matching/ProtocolSelector.java | 37 ++++++--
.../runtime/PipelineElementRuntimeInfoFetcher.java | 87 +++++++++++++----
.../AbstractNotificationSubscriber.java | 2 +-
.../apache/streampipes/sdk/helpers/Protocols.java | 21 +++--
.../sdk/helpers/SupportedProtocols.java | 10 ++
streampipes-wrapper-distributed/pom.xml | 5 +
.../distributed/runtime/DistributedRuntime.java | 21 +++--
.../wrapper/flink/FlinkDataProcessorRuntime.java | 10 +-
.../streampipes/wrapper/flink/FlinkRuntime.java | 22 +++--
.../{JmsConsumer.java => JmsFlinkConsumer.java} | 6 +-
.../{JmsConsumer.java => MqttFlinkConsumer.java} | 26 +++---
...FlinkJmsProducer.java => JmsFlinkProducer.java} | 4 +-
...linkJmsProducer.java => MqttFlinkProducer.java} | 14 +--
.../messaging-configuration.component.html | 20 ++++
.../messaging-configuration.component.ts | 4 +
.../shared/messaging-settings.model.ts | 1 +
46 files changed, 655 insertions(+), 238 deletions(-)
copy streampipes-config/src/main/java/org/apache/streampipes/config/backend/{SpDataFormat.java => SpProtocol.java} (65%)
create mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
rename streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/{SendToKafkaReplayAdapterSink.java => SendToBrokerReplayAdapterSink.java} (81%)
copy streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/{AddTimestampPipelineElement.java => SendToJmsAdapterSink.java} (62%)
copy streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/{AddTimestampPipelineElement.java => SendToMqttAdapterSink.java} (62%)
copy streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/exception/AdapterException.java => streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQUtils.java (66%)
copy streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/{JmsConsumer.java => JmsFlinkConsumer.java} (89%)
rename streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/{JmsConsumer.java => MqttFlinkConsumer.java} (74%)
copy streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/{FlinkJmsProducer.java => JmsFlinkProducer.java} (94%)
rename streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/{FlinkJmsProducer.java => MqttFlinkProducer.java} (78%)