This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from db5605277 Merge pull request #3289 from mxsm/eventmesh-3288
new 9a0fafe57 Refactor SubscribeTask
new 3fbc7d677 Changes from checkstyle
new 1741bc003 Merge branch 'master' of
github.com:apache/incubator-eventmesh into eventmesh-3445
new 885812fc4 Merge pull request #3447 from HattoriHenzo/eventmesh-3445
The 3827 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:
.../standalone/broker/task/SubScribeTask.java | 118 ---------------------
.../storage/standalone/broker/task/Subscribe.java | 105 ++++++++++++++++++
...oryMessageClearTask.java => SubscribeTask.java} | 18 ++--
.../standalone/consumer/StandaloneConsumer.java | 30 +++---
4 files changed, 132 insertions(+), 139 deletions(-)
delete mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/SubScribeTask.java
create mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/Subscribe.java
copy
eventmesh-storage/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/{HistoryMessageClearTask.java
=> SubscribeTask.java} (70%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
