You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2022/03/29 04:31:42 UTC
[rocketmq-mqtt] 14/43: [ISSUE #8] fix rocketmq-mqtt check style error and .travis.yaml file is not exist
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit c359b330b749701ba4e25ce305f59bbcc63f6271
Merge: b081013 b53fd4d
Author: dinglei <li...@163.com>
AuthorDate: Thu Mar 10 11:57:11 2022 +0800
[ISSUE #8] fix rocketmq-mqtt check style error and .travis.yaml file is not exist
[ISSUE #8] fix rocketmq-mqtt check style error and .travis.yaml file is not exist
.travis.yaml | 22 ++++
.../rocketmq/mqtt/common/facade/AuthManager.java | 26 ++--
.../mqtt/common/facade/LmqOffsetStore.java | 27 ++--
.../rocketmq/mqtt/common/facade/LmqQueueStore.java | 34 ++---
.../mqtt/common/facade/MetaPersistManager.java | 26 ++--
.../mqtt/common/hook/AbstractUpstreamHook.java | 26 ++--
.../org/apache/rocketmq/mqtt/common/hook/Hook.java | 30 ++---
.../rocketmq/mqtt/common/hook/HookResult.java | 26 ++--
.../rocketmq/mqtt/common/hook/UpstreamHook.java | 28 ++--
.../mqtt/common/hook/UpstreamHookEnum.java | 26 ++--
.../mqtt/common/hook/UpstreamHookManager.java | 26 ++--
.../rocketmq/mqtt/common/model/Constants.java | 28 ++--
.../apache/rocketmq/mqtt/common/model/Message.java | 26 ++--
.../rocketmq/mqtt/common/model/MessageEvent.java | 26 ++--
.../mqtt/common/model/MqttMessageUpContext.java | 26 ++--
.../rocketmq/mqtt/common/model/MqttTopic.java | 26 ++--
.../rocketmq/mqtt/common/model/PullResult.java | 26 ++--
.../apache/rocketmq/mqtt/common/model/Queue.java | 26 ++--
.../rocketmq/mqtt/common/model/QueueOffset.java | 26 ++--
.../apache/rocketmq/mqtt/common/model/Remark.java | 26 ++--
.../apache/rocketmq/mqtt/common/model/RpcCode.java | 26 ++--
.../rocketmq/mqtt/common/model/RpcHeader.java | 26 ++--
.../rocketmq/mqtt/common/model/StoreResult.java | 26 ++--
.../rocketmq/mqtt/common/model/Subscription.java | 26 ++--
.../apache/rocketmq/mqtt/common/model/Trie.java | 35 ++---
.../rocketmq/mqtt/common/model/TrieException.java | 31 ++---
.../rocketmq/mqtt/common/model/TrieMethod.java | 26 ++--
.../rocketmq/mqtt/common/util/HmacSHA1Util.java | 26 ++--
.../apache/rocketmq/mqtt/common/util/HostInfo.java | 38 +++---
.../rocketmq/mqtt/common/util/MessageUtil.java | 34 ++---
.../rocketmq/mqtt/common/util/NamespaceUtil.java | 28 ++--
.../apache/rocketmq/mqtt/common/util/StatUtil.java | 37 +++---
.../rocketmq/mqtt/common/util/TopicUtils.java | 28 ++--
.../rocketmq/mqtt/cs/channel/ChannelCloseFrom.java | 27 ++--
.../rocketmq/mqtt/cs/channel/ChannelException.java | 28 ++--
.../rocketmq/mqtt/cs/channel/ChannelInfo.java | 32 +++--
.../rocketmq/mqtt/cs/channel/ChannelManager.java | 26 ++--
.../rocketmq/mqtt/cs/channel/ConnectHandler.java | 26 ++--
.../mqtt/cs/channel/DefaultChannelManager.java | 32 +++--
.../rocketmq/mqtt/cs/config/ConnectConf.java | 26 ++--
.../mqtt/cs/config/ConnectConfListener.java | 26 ++--
.../mqtt/cs/hook/UpstreamHookManagerImpl.java | 26 ++--
.../cs/protocol/mqtt/MqttPacketDispatcher.java | 44 ++++---
.../mqtt/cs/protocol/mqtt/MqttPacketHandler.java | 26 ++--
.../protocol/mqtt/handler/MqttConnectHandler.java | 35 ++---
.../mqtt/handler/MqttDisconnectHandler.java | 26 ++--
.../cs/protocol/mqtt/handler/MqttPingHandler.java | 26 ++--
.../protocol/mqtt/handler/MqttPubAckHandler.java | 26 ++--
.../protocol/mqtt/handler/MqttPubCompHandler.java | 26 ++--
.../protocol/mqtt/handler/MqttPubRecHandler.java | 32 ++---
.../protocol/mqtt/handler/MqttPubRelHandler.java | 32 ++---
.../protocol/mqtt/handler/MqttPublishHandler.java | 35 ++---
.../mqtt/handler/MqttSubscribeHandler.java | 38 +++---
.../mqtt/handler/MqttUnSubscribeHandler.java | 32 ++---
.../mqtt/cs/protocol/rpc/RpcPacketDispatcher.java | 26 ++--
.../cs/protocol/ws/WebSocketServerHandler.java | 44 ++++---
.../mqtt/cs/protocol/ws/WebsocketEncoder.java | 44 +++----
.../rocketmq/mqtt/cs/session/QueueFresh.java | 28 ++--
.../apache/rocketmq/mqtt/cs/session/Session.java | 35 ++---
.../rocketmq/mqtt/cs/session/infly/InFlyCache.java | 26 ++--
.../rocketmq/mqtt/cs/session/infly/MqttMsgId.java | 26 ++--
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 26 ++--
.../mqtt/cs/session/infly/RetryDriver.java | 41 +++---
.../mqtt/cs/session/loop/PullResultStatus.java | 26 ++--
.../rocketmq/mqtt/cs/session/loop/QueueCache.java | 38 +++---
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 26 ++--
.../mqtt/cs/session/loop/SessionLoopImpl.java | 59 +++++----
.../mqtt/cs/session/match/MatchAction.java | 28 ++--
.../cs/session/notify/MessageNotifyAction.java | 26 ++--
.../rocketmq/mqtt/cs/starter/MqttServer.java | 26 ++--
.../apache/rocketmq/mqtt/cs/starter/RpcServer.java | 26 ++--
.../apache/rocketmq/mqtt/cs/starter/Startup.java | 26 ++--
.../mqtt/cs/test/TestDefaultChannelManager.java | 2 +-
.../rocketmq/mqtt/ds/auth/AuthManagerSample.java | 32 ++---
.../rocketmq/mqtt/ds/config/ServiceConf.java | 26 ++--
.../mqtt/ds/config/ServiceConfListener.java | 26 ++--
.../rocketmq/mqtt/ds/meta/FirstTopicManager.java | 26 ++--
.../mqtt/ds/meta/MetaPersistManagerSample.java | 26 ++--
.../mqtt/ds/meta/TopicNotExistException.java | 28 ++--
.../rocketmq/mqtt/ds/meta/WildcardManager.java | 26 ++--
.../org/apache/rocketmq/mqtt/ds/mq/MqAdmin.java | 30 ++---
.../org/apache/rocketmq/mqtt/ds/mq/MqConsumer.java | 26 ++--
.../org/apache/rocketmq/mqtt/ds/mq/MqFactory.java | 26 ++--
.../org/apache/rocketmq/mqtt/ds/mq/MqProducer.java | 26 ++--
.../apache/rocketmq/mqtt/ds/mq/MqPullConsumer.java | 26 ++--
.../rocketmq/mqtt/ds/notify/NotifyManager.java | 40 +++---
.../mqtt/ds/notify/NotifyRetryManager.java | 26 ++--
.../mqtt/ds/store/LmqOffsetStoreManager.java | 26 ++--
.../mqtt/ds/store/LmqQueueStoreManager.java | 33 ++---
.../mqtt/ds/upstream/UpstreamProcessor.java | 26 ++--
.../mqtt/ds/upstream/UpstreamProcessorManager.java | 41 +++---
.../mqtt/ds/upstream/processor/BaseProcessor.java | 31 ++---
.../ds/upstream/processor/ConnectProcessor.java | 26 ++--
.../ds/upstream/processor/DisconnectProcessor.java | 26 ++--
.../ds/upstream/processor/PublishProcessor.java | 26 ++--
.../ds/upstream/processor/SubscribeProcessor.java | 26 ++--
.../upstream/processor/UnSubscribeProcessor.java | 26 ++--
.../apache/rocketmq/mqtt/example/MqttConsumer.java | 33 ++---
.../apache/rocketmq/mqtt/example/MqttProducer.java | 33 ++---
.../rocketmq/mqtt/example/RocketMQConsumer.java | 26 ++--
.../rocketmq/mqtt/example/RocketMQProducer.java | 26 ++--
style/copyright/Apache.xml | 23 ++++
style/copyright/profiles_settings.xml | 64 +++++++++
style/rmq_checkstyle.xml | 140 ++++++++++++++++++++
style/rmq_codeStyle.xml | 143 +++++++++++++++++++++
105 files changed, 1813 insertions(+), 1478 deletions(-)