From 8fe46ec8d6cf4f854260a29b8227fd3147d9d0fa Mon Sep 17 00:00:00 2001 From: Silvio Giebl Date: Fri, 17 Apr 2020 14:20:20 +0200 Subject: [PATCH] Uniform code style config --- .idea/codeStyles/Project.xml | 5 ++-- .../reactor/operators/FluxWithSingleMap.java | 12 +++++--- .../operators/FluxWithSinglePublishOn.java | 4 ++- .../client/rx/reactor/FluxWithSingle.java | 9 ++++-- .../client/rx/reactor/FluxWithSingleItem.java | 3 +- .../rx/reactor/FluxWithSingleSplit.java | 3 +- .../client/rx/reactor/FluxWithSingleTest.java | 15 ++++++---- .../client/internal/mqtt/MqttAsyncClient.java | 24 ++++++++++----- .../internal/mqtt/MqttClientConfig.java | 6 ++-- .../mqtt/MqttClientConnectionConfig.java | 2 -- .../mqtt/MqttClientExecutorConfigImpl.java | 3 +- .../mqtt/MqttClientSslConfigImpl.java | 6 ++-- .../mqtt/MqttClientTransportConfigImpl.java | 9 ++++-- .../internal/mqtt/MqttProxyConfigImpl.java | 7 +++-- .../mqtt/MqttRxClientBuilderBase.java | 3 +- .../mqtt/MqttWebSocketConfigImpl.java | 4 ++- .../advanced/MqttClientAdvancedConfig.java | 3 +- .../mqtt/codec/decoder/MqttDecoder.java | 3 +- .../codec/decoder/MqttDecoderContext.java | 10 +++++-- .../mqtt3/Mqtt3ClientMessageDecoders.java | 12 +++++--- .../mqtt5/Mqtt5ClientMessageDecoders.java | 15 ++++++---- .../mqtt5/Mqtt5MessageDecoderUtil.java | 10 +++++-- .../mqtt/codec/encoder/MqttEncoder.java | 3 +- .../mqtt3/Mqtt3ClientMessageEncoders.java | 12 +++++--- .../encoder/mqtt3/Mqtt3MessageEncoder.java | 4 ++- .../encoder/mqtt3/Mqtt3PublishEncoder.java | 6 ++-- .../codec/encoder/mqtt5/Mqtt5AuthEncoder.java | 15 +++++++--- .../mqtt5/Mqtt5ClientMessageEncoders.java | 15 ++++++---- .../encoder/mqtt5/Mqtt5ConnectEncoder.java | 24 +++++++++++---- .../mqtt5/Mqtt5MessageEncoderUtil.java | 3 +- ...Mqtt5MessageWithUserPropertiesEncoder.java | 24 +++++++++++---- .../encoder/mqtt5/Mqtt5PublishEncoder.java | 23 ++++++++++---- .../encoder/mqtt5/Mqtt5SubscribeEncoder.java | 15 +++++++--- .../mqtt5/Mqtt5UnsubscribeEncoder.java | 15 +++++++--- .../datatypes/MqttTopicFilterImplBuilder.java | 3 +- .../mqtt/handler/MqttChannelInitializer.java | 9 ++++-- .../internal/mqtt/handler/MqttSession.java | 9 ++++-- .../handler/auth/MqttConnectAuthHandler.java | 3 +- .../handler/connect/MqttConnAckSingle.java | 30 +++++++++++++------ .../handler/connect/MqttConnectHandler.java | 6 ++-- .../disconnect/MqttDisconnectHandler.java | 3 +- .../disconnect/MqttDisconnectUtil.java | 9 ++++-- .../proxy/MqttProxyAdapterHandler.java | 12 +++++--- .../handler/proxy/MqttProxyInitializer.java | 6 ++-- .../MqttGlobalIncomingPublishFlow.java | 6 ++-- .../MqttGlobalIncomingPublishFlowable.java | 3 +- .../incoming/MqttIncomingPublishFlow.java | 6 ++-- .../incoming/MqttIncomingPublishFlows.java | 6 ++-- .../incoming/MqttSubscribedPublishFlow.java | 6 ++-- .../MqttSubscribedPublishFlowTree.java | 12 +++++--- .../MqttSubscribedPublishFlowable.java | 3 +- .../incoming/MqttSubscribedPublishFlows.java | 3 +- .../publish/outgoing/MqttAckFlowableFlow.java | 3 +- .../outgoing/MqttOutgoingQosHandler.java | 3 +- .../publish/outgoing/MqttPubRelWithFlow.java | 4 ++- .../mqtt/handler/ssl/MqttSslInitializer.java | 6 ++-- .../subscribe/MqttSubscribeWithFlow.java | 3 +- .../handler/websocket/MqttWebSocketCodec.java | 3 +- .../websocket/MqttWebSocketInitializer.java | 6 ++-- .../MqttWebsocketHandshakeHandler.java | 6 ++-- .../internal/mqtt/ioc/ConnectionModule.java | 3 +- .../MqttClientConnectedContextImpl.java | 6 ++-- .../MqttClientDisconnectedContextImpl.java | 12 +++++--- .../mqtt/lifecycle/MqttClientReconnector.java | 4 ++- .../Mqtt3ClientConnectedContextView.java | 6 ++-- .../Mqtt3ClientDisconnectedContextView.java | 12 +++++--- .../MqttMessageWithUserProperties.java | 9 ++++-- .../internal/mqtt/message/auth/MqttAuth.java | 6 ++-- .../mqtt/message/connect/MqttConnect.java | 10 +++++-- .../connect/MqttConnectRestrictions.java | 11 +++++-- .../message/connect/MqttStatefulConnect.java | 3 +- .../message/connect/connack/MqttConnAck.java | 15 ++++++---- .../connack/MqttConnAckRestrictions.java | 10 +++++-- .../connect/mqtt3/Mqtt3ConnectView.java | 8 +++-- .../message/disconnect/MqttDisconnect.java | 6 ++-- .../mqtt/message/publish/MqttPublish.java | 17 +++++++---- .../message/publish/MqttPublishResult.java | 7 +++-- .../message/publish/MqttStatefulPublish.java | 5 +++- .../mqtt/message/publish/MqttWillPublish.java | 13 +++++--- .../publish/mqtt3/Mqtt3PublishView.java | 12 ++++++-- .../message/publish/puback/MqttPubAck.java | 6 ++-- .../message/publish/pubcomp/MqttPubComp.java | 6 ++-- .../message/publish/pubrec/MqttPubRec.java | 6 ++-- .../message/publish/pubrel/MqttPubRel.java | 6 ++-- .../message/subscribe/MqttSubscription.java | 7 +++-- .../message/subscribe/suback/MqttSubAck.java | 6 ++-- .../unsubscribe/unsuback/MqttUnsubAck.java | 6 ++-- .../mqtt/mqtt3/Mqtt3AsyncClientView.java | 24 ++++++++++----- .../netty/DefaultChannelOutboundHandler.java | 12 +++++--- .../client/internal/rx/RxFutureConverter.java | 6 ++-- .../rx/operators/FlowableWithSingleMap.java | 6 ++-- .../FlowableWithSingleObserveOn.java | 6 ++-- .../client/internal/util/ByteArrayUtil.java | 8 +++-- .../util/collections/ImmutableArray.java | 4 ++- .../internal/util/collections/Index.java | 3 +- .../internal/util/collections/IntIndex.java | 3 +- .../client/mqtt/mqtt3/Mqtt3AsyncClient.java | 24 ++++++++++----- .../client/mqtt/mqtt5/Mqtt5AsyncClient.java | 24 ++++++++++----- .../qos1/Mqtt5IncomingQos1Interceptor.java | 3 +- .../qos2/Mqtt5IncomingQos2Interceptor.java | 6 ++-- .../qos2/Mqtt5OutgoingQos2Interceptor.java | 4 ++- .../auth/Mqtt5EnhancedAuthMechanism.java | 6 ++-- .../hivemq/client/rx/FlowableWithSingle.java | 3 +- .../com/hivemq/client/util/KeyStoreUtil.java | 3 +- .../client/example/Mqtt3ClientExample.java | 7 +++-- .../decoder/AbstractMqttDecoderTest.java | 3 +- .../mqtt3/Mqtt3PublishDecoderTest.java | 6 +++- .../mqtt3/Mqtt3ConnectEncoderTest.java | 13 +++++--- .../encoder/mqtt5/Mqtt5AuthEncoderTest.java | 3 +- .../mqtt5/Mqtt5ConnectEncoderTest.java | 12 +++++--- .../mqtt5/Mqtt5PublishEncoderTest.java | 15 +++++++--- .../mqtt5/Mqtt5UnsubscribeEncoderTest.java | 3 +- .../MqttSharedTopicFilterImplTest.java | 18 +++++++---- .../datatypes/MqttTopicFilterImplTest.java | 6 ++-- .../MqttSubscribedPublishFlowTreeTest.java | 8 +++-- .../MqttSubscribedPublishFlowsTest.java | 24 ++++++++++----- .../client/rx/FlowableWithSingleItem.java | 3 +- .../client/rx/FlowableWithSingleSplit.java | 6 ++-- .../client/rx/FlowableWithSingleTest.java | 15 ++++++---- .../client/util/TestKeyStoreGenerator.java | 4 ++- 120 files changed, 692 insertions(+), 313 deletions(-) diff --git a/.idea/codeStyles/Project.xml b/.idea/codeStyles/Project.xml index 431a32b81..6055d9646 100644 --- a/.idea/codeStyles/Project.xml +++ b/.idea/codeStyles/Project.xml @@ -1,7 +1,7 @@ +