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/02 11:34:18 UTC
[streampipes] 01/01: Merge pull request #827 from apache/SP-820
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 35d55faf2091983866cb889c8ffff3ca2752fd7b
Merge: ae4a2ab23 152f9ea1e
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Dec 2 12:34:12 2022 +0100
Merge pull request #827 from apache/SP-820
Enable checkstyle for streampipes-messaging-* modules
.../backend/StreamPipesResourceConfig.java | 2 -
streampipes-messaging-jms/pom.xml | 24 +-
.../messaging/jms/ActiveMQConnectionProvider.java | 20 +-
.../messaging/jms/ActiveMQConsumer.java | 16 +-
.../messaging/jms/ActiveMQPublisher.java | 17 +-
.../streampipes/messaging/jms/ActiveMQUtils.java | 13 +-
.../streampipes/messaging/jms/SpJmsProtocol.java | 4 +-
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 | 21 ++
.../messaging/nats/AbstractNatsConnector.java | 30 +--
.../streampipes/messaging/nats/NatsConsumer.java | 37 +--
.../streampipes/messaging/nats/NatsPublisher.java | 28 ++-
.../streampipes/messaging/nats/NatsUtils.java | 29 +--
.../streampipes/messaging/nats/SpNatsProtocol.java | 30 +--
.../messaging/nats/SpNatsProtocolFactory.java | 25 +-
streampipes-messaging/pom.xml | 24 +-
.../streampipes/messaging/EventConsumer.java | 10 +-
.../streampipes/messaging/EventProducer.java | 10 +-
.../messaging/SpProtocolDefinition.java | 6 +-
.../streampipes/messaging/SpProtocolManager.java | 19 +-
streampipes-rest/pom.xml | 22 ++
.../apache/streampipes/rest/ResetManagement.java | 175 +++++++-------
.../streampipes/rest/api/IPipelineElement.java | 36 ---
.../streampipes/rest/api/IPipelineMonitoring.java | 29 ---
.../rest/filter/TokenAuthenticationFilter.java | 132 +++++-----
.../rest/impl/AccountActivationResource.java | 6 +-
.../rest/impl/AssetDashboardResource.java | 14 +-
.../rest/impl/AssetManagementResource.java | 13 +-
.../streampipes/rest/impl/Authentication.java | 19 +-
.../apache/streampipes/rest/impl/AutoComplete.java | 12 +-
.../streampipes/rest/impl/CategoryResource.java | 146 +++++------
.../streampipes/rest/impl/EmailResource.java | 3 +-
.../streampipes/rest/impl/FunctionsResource.java | 9 +-
.../rest/impl/GenericStorageResource.java | 159 ++++++------
.../streampipes/rest/impl/LabelResource.java | 198 +++++++--------
.../rest/impl/MeasurementUnitResource.java | 26 +-
.../apache/streampipes/rest/impl/Notification.java | 134 ++++++-----
.../rest/impl/OntologyMeasurementUnit.java | 52 ++--
.../streampipes/rest/impl/PipelineCache.java | 6 +-
.../rest/impl/PipelineCanvasMetadataCache.java | 8 +-
.../rest/impl/PipelineCanvasMetadataResource.java | 15 +-
.../streampipes/rest/impl/PipelineCategory.java | 78 +++---
.../rest/impl/PipelineElementAsset.java | 4 +-
.../rest/impl/PipelineElementCategory.java | 71 +++---
.../streampipes/rest/impl/PipelineElementFile.java | 14 +-
.../rest/impl/PipelineElementPreview.java | 8 +-
.../rest/impl/PipelineElementRuntimeInfo.java | 3 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 5 +-
.../streampipes/rest/impl/PipelineResource.java | 17 +-
.../streampipes/rest/impl/PipelineTemplate.java | 44 ++--
.../streampipes/rest/impl/ResetResource.java | 23 +-
.../rest/impl/RestorePasswordResource.java | 8 +-
.../org/apache/streampipes/rest/impl/Setup.java | 4 +-
.../apache/streampipes/rest/impl/UserResource.java | 51 ++--
.../streampipes/rest/impl/admin/ConsulConfig.java | 26 +-
.../rest/impl/admin/DataExportResource.java | 6 +-
.../rest/impl/admin/DataImportResource.java | 7 +-
.../impl/admin/EmailConfigurationResource.java | 9 +-
.../admin/ExtensionsServiceEndpointResource.java | 57 +++--
.../impl/admin/GeneralConfigurationResource.java | 12 +-
.../rest/impl/admin/PermissionResource.java | 2 +
.../rest/impl/admin/PipelineElementImport.java | 16 +-
.../rest/impl/admin/UserGroupResource.java | 8 +-
.../rest/impl/connect/AdapterResource.java | 1 +
.../rest/impl/connect/DescriptionResource.java | 267 +++++++++++----------
.../rest/impl/connect/GuessResource.java | 26 +-
.../impl/connect/RuntimeResolvableResource.java | 63 ++---
.../rest/impl/connect/SourcesResource.java | 67 +++---
.../rest/impl/connect/UnitResource.java | 35 +--
.../rest/impl/connect/WelcomePageMaster.java | 98 ++++----
.../impl/connect/WorkerAdministrationResource.java | 23 +-
.../impl/dashboard/AbstractDashboardResource.java | 10 +-
.../AbstractPipelineExtractionResource.java | 49 ++--
.../streampipes/rest/impl/dashboard/Dashboard.java | 41 ++--
.../rest/impl/dashboard/DashboardWidget.java | 9 +-
.../dashboard/VisualizablePipelineResource.java | 10 +-
.../impl/datalake/DataLakeDashboardResource.java | 40 +--
.../rest/impl/datalake/DataLakeWidgetResource.java | 9 +-
.../impl/datalake/PersistedDataStreamResource.java | 5 +-
.../impl/nouser/PipelineElementImportNoUser.java | 82 -------
.../rest/impl/pe/DataProcessorResource.java | 86 ++++---
.../streampipes/rest/impl/pe/DataSinkResource.java | 8 +-
.../streampipes/rest/security/AuthConstants.java | 93 ++++---
.../rest/security/SpPermissionEvaluator.java | 13 +-
.../v4/params/WhereStatementParamsTest.java | 68 +++---
tools/maven/checkstyle.xml | 5 -
102 files changed, 1930 insertions(+), 1581 deletions(-)