Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

2016-07-26 #1

Open
wants to merge 1,075 commits into
base: master
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
1075 commits
Select commit Hold shift + click to select a range
2974dbe
fixed #215 producer 中添加 topic 有效性检查。
YangJodie Aug 28, 2013
cc6f849
#228 topic 路由信息已经找到之后,不需要再通过默认 topic 再获取一次。
YangJodie Aug 29, 2013
80913a1
#227 获取默认 topic 路由信息时需要做特殊处理,不添加与虚拟环境运行相关的前缀。
YangJodie Aug 29, 2013
acce4b1
#230 修复从ProcessQueue取顺序消息,设置消费状态错误的问题
vintagewang Aug 29, 2013
7283225
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Aug 29, 2013
f56c3ab
#227 修改 namespace
YangJodie Aug 30, 2013
5928e52
#227 #231 添加 project group 配置工具。
YangJodie Aug 30, 2013
8d59545
#227 #231 添加通过 value 反向查询 key 的工具。
YangJodie Aug 30, 2013
ce2c696
增加遗漏日志
Sep 2, 2013
1d077ca
修改log4j 输出路径
Sep 2, 2013
a1017f4
#4 修改brokerstats打印顺序
vintagewang Sep 3, 2013
3b45529
增加 参数去除空格
Sep 4, 2013
541bc69
Merge branch 'develop' of http://gitlab.alibaba-inc.com/middleware/ro…
Sep 4, 2013
3e70db1
fixed #242 修复线上环境关闭自动创建topic后,客户端仍然打印多余日志的问题。
vintagewang Sep 5, 2013
45aa2bb
增加producer 初始设置topic 和启动时按初始topic 寻址。
Sep 6, 2013
b9be77a
Merge branch 'develop' of http://gitlab.alibaba-inc.com/middleware/ro…
Sep 6, 2013
6574547
fixed #245 修复打印消费进度时,不能全部打印的问题。
vintagewang Sep 7, 2013
efac82c
增加 reblance 日志
Sep 9, 2013
c3b98c5
#4 删除AddTopic接口,转移到支付宝客户端。
vintagewang Sep 9, 2013
20b32ed
#4 客户端部分内部对象方法公开,供支付宝客户端进行扩展。
vintagewang Sep 9, 2013
6fcaf3f
客户端日志配置允许第三方jar包覆盖
vintagewang Sep 10, 2013
f3e920c
修改日志
vintagewang Sep 10, 2013
af3f5aa
#245 优化rebalance算法,全部队列平均分配。
YangJodie Sep 10, 2013
b20b061
#244 去掉未获取到虚拟运行环境的 project group 时的异常信息,记录一下获取到project group即可。
YangJodie Sep 10, 2013
bf25a08
#4 测试
YangJodie Sep 10, 2013
a794b0c
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Sep 10, 2013
f6c2b02
#4 删除tools工程测试代码 & 格式化
vintagewang Sep 10, 2013
e7f3f5f
#4 修改版本号为3.0.0-beta7
vintagewang Sep 10, 2013
21ca536
#4 注释掉taobao.parent
vintagewang Sep 10, 2013
5b6bd00
#236 创建 topic 时做系统保留字验证。
YangJodie Sep 10, 2013
53274d8
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
YangJodie Sep 10, 2013
757e332
#247 消息重试时 %RETRY% 作为前缀标识,与同是虚拟项目分组前缀的 %PROJECT_% 冲突。将 %PROJECT_% 改成后…
YangJodie Sep 11, 2013
9aa14a0
#233 添加按时间回溯消费进度bean
YangJodie Sep 12, 2013
d5ea57d
#233 新增按 consumerGroup,topic,timestamp 回溯消费进度逻辑
YangJodie Sep 12, 2013
c88a2f1
#233 新增 command tools
YangJodie Sep 12, 2013
e2fed12
#233 1.执行结果输出 2.允许按照日期格式输入,精确到毫秒
YangJodie Sep 12, 2013
5c2112d
#233 删除测试代码
YangJodie Sep 12, 2013
acd5c3d
#233 打印 force 状态
YangJodie Sep 12, 2013
59f14c4
#233 去掉日期与时间之间的空格,用#分隔。
YangJodie Sep 12, 2013
6fdf7d7
修改配置文件加载类,能自动创建目录
Sep 13, 2013
b94f01b
#4 整理tools命令,将消息查询命令拆分成3个子命令
vintagewang Sep 16, 2013
4e78e25
#4 修改版本号为3.0.0-SNAPSHOT
vintagewang Sep 16, 2013
c00e17f
#4 修改版本号为3.0.0-SNAPSHOT
vintagewang Sep 16, 2013
fbbb23d
#4 “修改配置文件加载类,能自动创建目录”此功能已转移到支付宝自定义客户端
vintagewang Sep 17, 2013
e388624
#253 格式化pom,升级netty依赖到4.0.9
vintagewang Sep 17, 2013
895ef24
#234 按照消息ID查询命令行工具增加消息Body输出
YangJodie Sep 17, 2013
e8caa6d
#253 修改命令行顺序
vintagewang Sep 17, 2013
60b946b
#255 增加发送消息Hook,消费消息Hook
vintagewang Sep 18, 2013
7b965e3
#255 增加tostring方法
vintagewang Sep 18, 2013
3a37c32
#255 去除无用参数
vintagewang Sep 18, 2013
99d3089
#255 将consumer对象的实现对象修改为protected
vintagewang Sep 18, 2013
4eff3a2
#255 为hook调用增加参数
vintagewang Sep 22, 2013
49d6769
#255 为hook增加group参数
vintagewang Sep 22, 2013
7172c5c
#253 调整rebalance日志
vintagewang Sep 22, 2013
32ee740
#253 调整消息id查询body路径
vintagewang Sep 23, 2013
35f3c30
更新MQVersion,3.0.0-SNAPSHOT
vintagewang Sep 24, 2013
7f1c9db
#258 Consumer连接管理没有定时检查不可能的连接。
YangJodie Sep 24, 2013
d418831
#258 update log.
YangJodie Sep 24, 2013
aec27f5
#258 consumer注册时,要更新最后变更时间
vintagewang Sep 25, 2013
3d5a303
发布beta8版本
vintagewang Sep 25, 2013
8192198
发布beta8版本,注释parentpom
vintagewang Sep 25, 2013
00ef17f
更改命令名字。
vintagewang Sep 27, 2013
2276f4a
为工具类程序,增加默认订阅组
vintagewang Sep 27, 2013
48df8ef
为工具类程序,增加默认订阅组
vintagewang Sep 27, 2013
b6e4f4d
#260 修复tags过滤产生堆积消息假象的问题
vintagewang Sep 28, 2013
05182fd
#261 为安装包增加调试程序
vintagewang Sep 28, 2013
0165e40
#262 为Broker统计信息中增加延时进度
vintagewang Sep 28, 2013
8572385
#261 测试程序,设置instanceName
vintagewang Sep 28, 2013
9a25efe
#261 打印增加换行
vintagewang Sep 28, 2013
f4692c7
#261 测试程序允许订阅表达式为null
vintagewang Sep 28, 2013
3b94ff7
修改日志打印
vintagewang Sep 30, 2013
3a95be5
#253 对于发送消息失败,增加URL说明
vintagewang Oct 7, 2013
72c160d
fixed #226 消费进度查询api,增加最后一条消息的时间戳
vintagewang Oct 7, 2013
66d29b6
#253 更新README
vintagewang Oct 7, 2013
6745dbc
#253 删除多余的example
vintagewang Oct 7, 2013
36499ff
#253 修改错误异常信息
vintagewang Oct 7, 2013
d664fd1
输出最后消息提交时间
Oct 9, 2013
83c4efe
#253 修改README,增加代码行数说明
vintagewang Oct 11, 2013
a7bfa49
#253 Name Server增加过期连接扫描
vintagewang Oct 12, 2013
eb34778
#253 Name Server增加过期连接扫描
vintagewang Oct 12, 2013
c4d7c19
#253 为Remoting增加SO_REUSEADDR选项。
vintagewang Oct 12, 2013
049d769
#253 当broker意外下线时,要清除对应的集群信息
vintagewang Oct 13, 2013
4f58915
#253 Name Server,修改变量名
vintagewang Oct 13, 2013
ec26216
#253 修改消息压缩默认Level,由9改为5
vintagewang Oct 13, 2013
545b6a9
#253 修改消息offset重置的 包名
vintagewang Oct 13, 2013
4fd0a4b
#253 去除消费进度打印时间戳,由于已有打印项已经占满正行,无法再增加新列
vintagewang Oct 13, 2013
1c0dc01
#253 将Connection命令拆分成两个独立的子命令,分别处理producer、consumer
vintagewang Oct 13, 2013
eb29ad5
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Oct 13, 2013
2d4d66b
#253 发送消息超时时间由之前默认10s改为3s
vintagewang Oct 13, 2013
158594d
#253 zipLevel参数设置代码笔误
vintagewang Oct 13, 2013
69cd863
#253 超时情况下,取消之前关闭连接的动作,防止产生连锁反映
vintagewang Oct 14, 2013
fdd2f18
#253 zip 压缩level增加get set方法,允许应用设置
vintagewang Oct 14, 2013
6b4df7f
#253 修改readme
vintagewang Oct 14, 2013
463d01d
#253 修改beta8版本为3.0.0-SNAPSHOT,准备发正式版本
vintagewang Oct 15, 2013
77fcc13
#253 排除一些无法通过的测试用例
vintagewang Oct 17, 2013
b597f90
#265 Name Server增加获取Namspace下所有配置的功能
vintagewang Oct 17, 2013
9747890
#253 格式化代码
vintagewang Oct 17, 2013
21563c5
fixed #269 修复客户端连接地址显示错误的问题(针对支付宝环境修改)
vintagewang Oct 17, 2013
2f3a7b1
#253 修改develop.sh
vintagewang Oct 17, 2013
0fd2f9a
#253 mqadmin在命令不存在情况下,给出错误提示
vintagewang Oct 17, 2013
24c6b03
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Oct 17, 2013
180d35a
#271 优化checkpoint机制
vintagewang Oct 18, 2013
6da9536
#253 consumer流控时,修复打印日志过多的问题。
vintagewang Oct 18, 2013
c36ec60
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Oct 18, 2013
b0f0e97
#253 修复PullConsumer例子少收消息的问题。
vintagewang Oct 18, 2013
4d7c7bf
#253 文件保留时间由默认12小时改为24小时
vintagewang Oct 18, 2013
94c8446
#253 数据恢复时,增加日志
vintagewang Oct 18, 2013
02b1e3c
#253 消息保存时间默认改成48小时
vintagewang Oct 18, 2013
bb78732
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Oct 18, 2013
3ebddb2
#253 对factory对象的生命周期管理进行优化。
vintagewang Oct 19, 2013
abfc9da
#253 对各个客户端服务对象的状态位进行优化
vintagewang Oct 19, 2013
5a5595a
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
vintagewang Oct 19, 2013
657ec1c
#253 修改PullConsumer例子
vintagewang Oct 19, 2013
2f3e7d6
#253 为集群命令增加tps输出
vintagewang Oct 20, 2013
42901b4
#253 为集群命令增加tps输出
vintagewang Oct 20, 2013
7e659ef
#253 为集群命令增加tps输出
vintagewang Oct 20, 2013
4002b1f
#253 集群命令按照BrokerName来排序
vintagewang Oct 20, 2013
01ea893
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
617c82a
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
65c39db
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
816c068
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
9e58a00
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
13276f6
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
66420fa
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
62300d0
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
da0d76f
#253 优化消费进度查询命令
vintagewang Oct 20, 2013
c698e95
#253 Netty Channel地址解析容错。
vintagewang Oct 20, 2013
6e7c3a2
#253 修改集群tps 打印格式
vintagewang Oct 20, 2013
46431c5
#253 修改集群tps 打印格式
vintagewang Oct 20, 2013
119f213
#253 修改集群tps 打印格式
vintagewang Oct 20, 2013
b879d34
#253 增加更新broker配置文件命令
vintagewang Oct 20, 2013
03caa9d
#253 发布3.0.0-final版
vintagewang Oct 20, 2013
7772f54
#253 发布3.0.0-final版,去除parrent注释,depoly到mvn库
vintagewang Oct 20, 2013
4f8edf6
#253 发布3.0.0-final版,增加parrent注释,准备合并到master
vintagewang Oct 20, 2013
bb4f664
#272 load之前启动IndexService
vintagewang Oct 20, 2013
e4eadab
#272 优化IndexService关闭流程
vintagewang Oct 20, 2013
d4e3172
#253 格式化代码
vintagewang Oct 21, 2013
85f49bb
#253 发布一个优化版本,对宕机重启速度进行优化 3.0.1
vintagewang Oct 21, 2013
c526720
#253 发布一个优化版本,对宕机重启速度进行优化 3.0.1,修改parrent pom
vintagewang Oct 21, 2013
e91b82e
#253 开始开发3.0.2-SNAPSHOT版本
vintagewang Oct 21, 2013
5a80b12
#276 为每日消息增加统计。
vintagewang Oct 23, 2013
5ca4dfc
#276 为每日消息增加统计。
vintagewang Oct 23, 2013
00e5de4
#276 为每日消息增加统计。调整命令行打印格式
vintagewang Oct 23, 2013
c8fc99c
#276 为每日消息增加统计。调整scadule参数
vintagewang Oct 24, 2013
d7aa33d
修改一处日志打印错误的问题
vintagewang Oct 24, 2013
8fc216d
release配置修改
agapple Oct 25, 2013
d768922
修改回3.0.1-SNAPSHOT
agapple Oct 25, 2013
e3e8df5
Merge pull request #278 from agapple/develop
vintagewang Oct 25, 2013
df80e31
发布3.0.2版本
vintagewang Oct 28, 2013
88f0b26
发布3.0.2版本
vintagewang Oct 28, 2013
97c921f
发布3.0.2版本
vintagewang Oct 28, 2013
8a1e20b
修改pom,开始开发3.0.3-SNAPSHOT版本
vintagewang Oct 28, 2013
358ed5a
注释掉parrent sontype
vintagewang Oct 28, 2013
fbe1c67
fixed #280 修复pulcosumer导致broker打印日志过多的问题
vintagewang Oct 29, 2013
98cad11
#280 Broker针对PullConsumer的订阅关系变更不打印日志
vintagewang Oct 29, 2013
5af510c
发布3.0.3版本,解决服务器因为pullconsumer导致打印日志过多的问题
vintagewang Oct 29, 2013
5435809
#285 Broker发送消息线程池增加流控机制,在线程池繁忙情况下,快速向应用报错,防止发生雪崩效应。
vintagewang Nov 5, 2013
7be8fe6
修改pom版本号,3.0.4-SNAPSHOT
vintagewang Nov 5, 2013
4d29c6b
#285 Broker统计信息里增加写入队列的实时排队请求数
vintagewang Nov 6, 2013
4ae7ad8
#285 Broker订阅线程池队列size也增加限制
vintagewang Nov 6, 2013
b1cbe2e
#286 unlock操作使用finaly操作保证能一定调用到
vintagewang Nov 6, 2013
c037315
message中的常量定义转移到MessageConst类。
vintagewang Nov 8, 2013
22ae73a
修改下报错文案,线程池繁忙。
vintagewang Nov 8, 2013
6659b40
增加打印property
vintagewang Nov 10, 2013
3e935be
#292 优化重置消费进度逻辑,即使consumer没有启动也能重置
vintagewang Nov 13, 2013
66ab19d
针对Fastjson版本过低导致的异常提供issue url来帮助定位问题。
vintagewang Nov 15, 2013
a2ab1dd
更新流控文案
vintagewang Nov 15, 2013
0c3a857
增加一个按照时间重置offset的方法
vintagewang Nov 16, 2013
d3af2eb
修改消息属性注释
vintagewang Nov 16, 2013
fb85677
修改流控间隔时间。
vintagewang Nov 17, 2013
be13428
修复索引文件没有正常删除的问题
vintagewang Nov 18, 2013
3ab8506
fixed #294 修复因为个别版本jvm无法识别gc相关参数导致启动失败的问题
vintagewang Nov 20, 2013
257a16c
发布3.0.4-open版本
vintagewang Nov 21, 2013
a26ec3f
发布3.0.4版本
vintagewang Nov 21, 2013
09e487b
开始开发3.0.5版本
vintagewang Nov 21, 2013
6007836
netty升级到4.0.12,fastjson升级到1.1.37
vintagewang Nov 22, 2013
383f279
解决 properties 中文乱码的问题。
YangJodie Nov 22, 2013
9da97c0
修改windows启动配置文件,java内存参数
vintagewang Nov 24, 2013
e7325df
修复Math.abs(Integer.min_value)依然为负数的问题
allenzhu Nov 26, 2013
29ef20d
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
allenzhu Nov 26, 2013
5fcf5e9
修复Math.abs(Integer.min_value)依然为负数的问题 #295
allenzhu Nov 26, 2013
618cbe4
#295 putKey抛异常时,增加内部变量打印
vintagewang Nov 27, 2013
fb21203
fix无法回溯消息
allenzhu Nov 27, 2013
b72d2fe
Merge branch 'develop' of gitlab.alibaba-inc.com:middleware/rocketmq …
allenzhu Nov 27, 2013
c47f28b
fix无法回溯消息
allenzhu Nov 28, 2013
8e78b7e
修改pom,导致在mvn2下编译不过的问题。
vintagewang Nov 28, 2013
93313db
fixed #298 修复多网卡下获取主机ip可能有误的问题
vintagewang Nov 30, 2013
883f277
netty升级到4.0.13
vintagewang Dec 2, 2013
bfad470
发布3.0.5版本
vintagewang Dec 2, 2013
ef8a592
广播消息重置消费进度时,需要设置instacneName
vintagewang Dec 2, 2013
87eaddc
增加注释
vintagewang Dec 2, 2013
9fd80a8
增加主备部署,配置文件模版
vintagewang Dec 3, 2013
d6d4c5c
将pom.xml的淘宝parent依赖去掉,并合并到主干
vintagewang Dec 4, 2013
d72a0c3
发布开源3.0.5-open版本
vintagewang Dec 5, 2013
40f5841
发布开源3.0.5-open版本,增加doc,source插件
vintagewang Dec 5, 2013
084f90c
fixed #302 对ProcessQueue中写入消息逻辑进行优化,避免消息总数计数不准影响到流控功能。
vintagewang Dec 6, 2013
53e6deb
删除log4j不支持的配置项,MaxBackupIndex
vintagewang Dec 9, 2013
1836992
默认不生成java doc
vintagewang Dec 10, 2013
9d172d6
消息发送失败,重试次数可配置。
vintagewang Dec 11, 2013
45e6fca
#310 fixed 清楚 brokerAddr 时与 topicTable 之间存在并发问题,加锁解决。
YangJodie Dec 16, 2013
f5e162b
修复UtilAll.isBlank逻辑
vintagewang Dec 16, 2013
5a0934d
修复根据Offset查询消息的代码错误,订阅者没有正确设置
vintagewang Dec 17, 2013
bdfb5d4
启动过程增加异常打印
vintagewang Dec 17, 2013
894d13f
开始开发3.0.6版本
vintagewang Dec 17, 2013
43ba367
过滤掉生成文档
vintagewang Dec 17, 2013
7f53cef
fixed #311 修复打印日志错误
vintagewang Dec 17, 2013
56fdd64
fixed #302 从ProcessQueue中删除消息,也要判断是否有消息存在。
vintagewang Dec 17, 2013
08466ba
#316 优化consumer第一次启动时的消费逻辑。
vintagewang Dec 23, 2013
c96e2fa
增加多个版本号,修改代码demo
vintagewang Dec 24, 2013
84472e8
修改注释,consumer第一次启动时,默认回溯时间改为半小时
vintagewang Dec 24, 2013
cf96b85
#316 修改注释。
vintagewang Dec 24, 2013
36ea6a7
#317 分支完成后 continue 进入下一次循环,同时修复错误的日志。
YangJodie Dec 25, 2013
34ed7ed
#317 添加解锁时的日志。
YangJodie Dec 25, 2013
8236733
#317 修改日志。
YangJodie Dec 25, 2013
b391442
#317 本地定时重试消费时,如果当前 mq 已经被 rebalance 删除,则跳出重试。
YangJodie Dec 25, 2013
871004a
更新Example,增加注释。
vintagewang Dec 25, 2013
c9156f2
#317 新生成lockEntry时继续往下执行,去掉continue.
YangJodie Dec 25, 2013
9c4c9c5
发布3.0.6版本
vintagewang Dec 26, 2013
e36da55
合并develop到master,3.0.6,去除taobao parent依赖
vintagewang Dec 26, 2013
b4b8ead
修改pom为3.0.7-SNAPSHOT
vintagewang Dec 30, 2013
bc8f8db
fixed #325 优化注册订阅关系流程,优化消费进度查询流程, topic取消订阅后,过滤掉。
vintagewang Jan 6, 2014
6ecfc64
#326 去除写入消息索引的流控机制
vintagewang Jan 7, 2014
068f4f1
fixed #322 and fixed #326 修复消息索引保存的时间差单位,由毫秒改为秒,防止索引文件创建时间过长,但是消息过少情况…
vintagewang Jan 7, 2014
b57679e
#325 修复注销订阅关系的逻辑错误。
vintagewang Jan 7, 2014
94526bf
名称错误,应该是RocketMQ,不是Metaq
hengyunabc Jan 8, 2014
a53b38e
Merge pull request #327 from hengyunabc/patch-1
vintagewang Jan 8, 2014
4641329
#329 根据时间进行 offset 重置,客户端无需再重启。
YangJodie Jan 9, 2014
864d382
#330 通过 topic、group 查询到订阅的客户端,查询客户端当前的消费进度。
YangJodie Jan 9, 2014
0b6e8cb
#331 如果是广播消费,则不需要进行锁判断,也无需定时去 broker 更新锁状态。
YangJodie Jan 9, 2014
d467173
#329 resetOffsetByTime、resetOffsetByTimeOld两个 command 放一块儿。
YangJodie Jan 9, 2014
426bd74
#329 如果ProcessQueue是dropped状态,不需要直接更新 offset
YangJodie Jan 9, 2014
db5d3ad
#329 #330 每个 broker 上有所有的 consumer 连接,故只需要在一个 broker 执行即可
YangJodie Jan 9, 2014
d6eee2c
#330 将 ip:port 的方式改为 clientId
YangJodie Jan 9, 2014
56bf460
#329 #330 注册客户端支持的RPC CODE
YangJodie Jan 9, 2014
4bd8707
#329 #330 记录关键日志、源ip
YangJodie Jan 9, 2014
2c73a65
#329 等待时间 60s 改为 10s
YangJodie Jan 9, 2014
948cbe8
#330 调整显示
YangJodie Jan 9, 2014
80a3d61
#330 修正 CFNullable 包
YangJodie Jan 10, 2014
839993e
发布3.0.7版本
vintagewang Jan 10, 2014
5986cf6
发布3.0.7版本
vintagewang Jan 10, 2014
bfb2273
增加异常Issue链接,同一个Group内不同的订阅关系的问题。
vintagewang Jan 10, 2014
afedde8
fixed #333 修复updateProcessQueueTableInRebalance方法中遍历HashMap删除元素的错误逻辑
vintagewang Jan 14, 2014
d20f391
fixed #334 修复remoting模块异步调用没有回调的问题。
vintagewang Jan 15, 2014
838fa8c
对于队列不存在的异常增加URL,并格式化代码
vintagewang Jan 15, 2014
5ef7ef1
开始开发3.0.8-SNAPSHOT版本
vintagewang Jan 15, 2014
bc3d897
#337 增加对JDK7的兼容,主要修改了释放PAGECACHE的逻辑
vintagewang Jan 15, 2014
35e3d5e
#340 为PushConsumer每次pull消息时,增加开关来控制是否上传订阅关系
vintagewang Jan 17, 2014
7340169
fixed #341 为磁盘这种情况增加更详细的信息
vintagewang Jan 17, 2014
1173883
格式化代码
vintagewang Jan 17, 2014
9f1d849
根据Findbugs修复所有发现的问题。
vintagewang Jan 23, 2014
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
广播消息重置消费进度时,需要设置instacneName
vintagewang committed Dec 2, 2013
commit ef8a592a7a0c4ffaa4b832cd4e4aca715fbabbf2
Original file line number Diff line number Diff line change
@@ -46,12 +46,14 @@ public class MQHelper {
*/
public static void resetOffsetByTimestamp(//
final MessageModel messageModel,//
final String instanceName,//
final String consumerGroup, //
final String topic, //
final long timestamp) throws Exception {
final Logger log = ClientLogger.getLog();

DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(consumerGroup);
consumer.setInstanceName(instanceName);
consumer.setMessageModel(messageModel);
consumer.start();

@@ -81,4 +83,13 @@ public static void resetOffsetByTimestamp(//
consumer.shutdown();
}
}


public static void resetOffsetByTimestamp(//
final MessageModel messageModel,//
final String consumerGroup, //
final String topic, //
final long timestamp) throws Exception {
resetOffsetByTimestamp(messageModel, "DEFAULT", consumerGroup, topic, timestamp);
}
}