You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/12/01 21:51:03 UTC
[streampipes] branch SP-820 updated (99a6b8b68 -> c7bfc4b1a)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch SP-820
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 99a6b8b68 Merge branch 'SP-820' of github.com:apache/streampipes into SP-820
add 1fe4ac5f0 Enable checkstyle for streampipes-messaging-kafka (#820)
add c7bfc4b1a Enable checkstyle for streampipes-messaging-mqtt (#820)
No new revisions were added by this update.
Summary of changes:
streampipes-messaging-kafka/pom.xml | 24 ++++++++++++++-
.../messaging/kafka/SpKafkaConsumer.java | 27 +++++++++--------
.../messaging/kafka/SpKafkaProducer.java | 31 +++++++++++++-------
.../messaging/kafka/SpKafkaProtocol.java | 4 +--
.../kafka/config/ConsumerConfigFactory.java | 7 +++--
.../kafka/config/KafkaConfigAppender.java | 2 +-
.../kafka/config/ProducerConfigFactory.java | 14 ++++-----
.../security/KafkaSecuritySaslPlainConfig.java | 31 +++++++++++---------
.../kafka/security/KafkaSecuritySaslSSLConfig.java | 31 +++++++++++---------
.../KafkaSecurityUnauthenticatedPlainConfig.java | 7 ++---
.../KafkaSecurityUnauthenticatedSSLConfig.java | 8 ++---
streampipes-messaging-mqtt/pom.xml | 23 ++++++++++++++-
.../messaging/mqtt/AbstractMqttConnector.java | 26 +++++++++--------
.../streampipes/messaging/mqtt/MqttConsumer.java | 34 ++++++++++++----------
.../streampipes/messaging/mqtt/MqttPublisher.java | 26 +++++++++--------
.../streampipes/messaging/mqtt/SpMqttProtocol.java | 29 +++++++++---------
.../messaging/mqtt/SpMqttProtocolFactory.java | 27 ++++++++---------
streampipes-messaging-nats/pom.xml | 1 -
18 files changed, 213 insertions(+), 139 deletions(-)