This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch
1717-support-other-protocols-besides-kafka-in-streampipes-client-for-gathering-live-data
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from d74046e44 Improve handling of messaging protocols, extend broker
support in client (#1717)
add 531d765ec Refactor messaging access of flink components
No new revisions were added by this update.
Summary of changes:
.../wrapper/flink/consumer/JmsFlinkConsumer.java | 12 +-----
.../wrapper/flink/consumer/MqttFlinkConsumer.java | 12 +-----
.../wrapper/flink/sink/JmsFlinkProducer.java | 4 +-
.../wrapper/flink/sink/MqttFlinkProducer.java | 4 +-
.../flink/status/PipelineElementStatusSender.java | 46 ----------------------
.../status/PipelineElementStatusSenderFactory.java | 42 --------------------
6 files changed, 8 insertions(+), 112 deletions(-)
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/status/PipelineElementStatusSender.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/status/PipelineElementStatusSenderFactory.java
