This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git.
from b081013 [ISSUE #10] remove duplicated caffeine dependency in pom.xml
(#11)
add d5ab14c for check style for RocketMQ
add 8ec77fd add .travis.yaml
add b53fd4d for fix unit test
new c359b33 [ISSUE #8] fix rocketmq-mqtt check style error and
.travis.yaml file is not exist
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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(-)
create mode 100644 .travis.yaml
create mode 100644 style/copyright/Apache.xml
create mode 100644 style/copyright/profiles_settings.xml
create mode 100644 style/rmq_checkstyle.xml
create mode 100644 style/rmq_codeStyle.xml
