Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
小五666\n哈哈
Rocketmq
提交
199fc498
R
Rocketmq
项目概览
小五666\n哈哈
/
Rocketmq
与 Fork 源项目一致
Fork自
Apache RocketMQ / Rocketmq
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
R
Rocketmq
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
199fc498
编写于
12月 20, 2016
作者:
Y
yukon
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Revert SendMessageRequestHeaderV2. Reviewed by
@vintagewang
@vongosling
上级
7d1af821
变更
1
显示空白变更内容
内联
并排
Showing
1 changed file
with
86 addition
and
85 deletion
+86
-85
rocketmq-common/src/main/java/com/alibaba/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
...mq/common/protocol/header/SendMessageRequestHeaderV2.java
+86
-85
未找到文件。
rocketmq-common/src/main/java/com/alibaba/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
浏览文件 @
199fc498
...
...
@@ -24,65 +24,66 @@ import com.alibaba.rocketmq.remoting.exception.RemotingCommandException;
/**
* Use short variable name to speed up FastJson deserialization process.
* @author shijia.wxr
*/
public
class
SendMessageRequestHeaderV2
implements
CommandCustomHeader
{
@CFNotNull
private
String
producerGroup
;
private
String
a
;
//
producerGroup;
@CFNotNull
private
String
topic
;
private
String
b
;
//
topic;
@CFNotNull
private
String
defaultTopic
;
private
String
c
;
//
defaultTopic;
@CFNotNull
private
Integer
defaultTopicQueueNums
;
private
Integer
d
;
// d
efaultTopicQueueNums;
@CFNotNull
private
Integer
queueId
;
private
Integer
e
;
//
queueId;
@CFNotNull
private
Integer
sysFlag
;
private
Integer
f
;
//
sysFlag;
@CFNotNull
private
Long
bornTimestamp
;
private
Long
g
;
//
bornTimestamp;
@CFNotNull
private
Integer
flag
;
private
Integer
h
;
//
flag;
@CFNullable
private
String
properties
;
private
String
i
;
//
properties;
@CFNullable
private
Integer
reconsumeTimes
;
private
Integer
j
;
//
reconsumeTimes;
@CFNullable
private
boolean
unitMod
e
;
private
boolean
k
;
// unitMode = fals
e;
private
Integer
consumeRetryTimes
;
private
Integer
l
;
// consumeRetryTimes
public
static
SendMessageRequestHeader
createSendMessageRequestHeaderV1
(
final
SendMessageRequestHeaderV2
v2
)
{
SendMessageRequestHeader
v1
=
new
SendMessageRequestHeader
();
v1
.
setProducerGroup
(
v2
.
producerGroup
);
v1
.
setTopic
(
v2
.
topic
);
v1
.
setDefaultTopic
(
v2
.
defaultTopi
c
);
v1
.
setDefaultTopicQueueNums
(
v2
.
d
efaultTopicQueueNums
);
v1
.
setQueueId
(
v2
.
queueId
);
v1
.
setSysFlag
(
v2
.
sysFlag
);
v1
.
setBornTimestamp
(
v2
.
bornTimestamp
);
v1
.
setFlag
(
v2
.
flag
);
v1
.
setProperties
(
v2
.
properties
);
v1
.
setReconsumeTimes
(
v2
.
reconsumeTimes
);
v1
.
setUnitMode
(
v2
.
unitMode
);
v1
.
setMaxReconsumeTimes
(
v2
.
consumeRetryTimes
);
v1
.
setProducerGroup
(
v2
.
a
);
v1
.
setTopic
(
v2
.
b
);
v1
.
setDefaultTopic
(
v2
.
c
);
v1
.
setDefaultTopicQueueNums
(
v2
.
d
);
v1
.
setQueueId
(
v2
.
e
);
v1
.
setSysFlag
(
v2
.
f
);
v1
.
setBornTimestamp
(
v2
.
g
);
v1
.
setFlag
(
v2
.
h
);
v1
.
setProperties
(
v2
.
i
);
v1
.
setReconsumeTimes
(
v2
.
j
);
v1
.
setUnitMode
(
v2
.
k
);
v1
.
setMaxReconsumeTimes
(
v2
.
l
);
return
v1
;
}
public
static
SendMessageRequestHeaderV2
createSendMessageRequestHeaderV2
(
final
SendMessageRequestHeader
v1
)
{
SendMessageRequestHeaderV2
v2
=
new
SendMessageRequestHeaderV2
();
v2
.
producerGroup
=
v1
.
getProducerGroup
();
v2
.
topic
=
v1
.
getTopic
();
v2
.
defaultTopi
c
=
v1
.
getDefaultTopic
();
v2
.
d
efaultTopicQueueNums
=
v1
.
getDefaultTopicQueueNums
();
v2
.
queueId
=
v1
.
getQueueId
();
v2
.
sysFlag
=
v1
.
getSysFlag
();
v2
.
bornTimestamp
=
v1
.
getBornTimestamp
();
v2
.
flag
=
v1
.
getFlag
();
v2
.
properties
=
v1
.
getProperties
();
v2
.
reconsumeTimes
=
v1
.
getReconsumeTimes
();
v2
.
unitMode
=
v1
.
isUnitMode
();
v2
.
consumeRetryTimes
=
v1
.
getMaxReconsumeTimes
();
v2
.
a
=
v1
.
getProducerGroup
();
v2
.
b
=
v1
.
getTopic
();
v2
.
c
=
v1
.
getDefaultTopic
();
v2
.
d
=
v1
.
getDefaultTopicQueueNums
();
v2
.
e
=
v1
.
getQueueId
();
v2
.
f
=
v1
.
getSysFlag
();
v2
.
g
=
v1
.
getBornTimestamp
();
v2
.
h
=
v1
.
getFlag
();
v2
.
i
=
v1
.
getProperties
();
v2
.
j
=
v1
.
getReconsumeTimes
();
v2
.
k
=
v1
.
isUnitMode
();
v2
.
l
=
v1
.
getMaxReconsumeTimes
();
return
v2
;
}
...
...
@@ -90,122 +91,122 @@ public class SendMessageRequestHeaderV2 implements CommandCustomHeader {
public
void
checkFields
()
throws
RemotingCommandException
{
}
public
String
get
ProducerGroup
()
{
return
producerGroup
;
public
String
get
A
()
{
return
a
;
}
public
void
set
ProducerGroup
(
String
producerGroup
)
{
this
.
producerGroup
=
producerGroup
;
public
void
set
A
(
String
a
)
{
this
.
a
=
a
;
}
public
String
get
Topic
()
{
return
topic
;
public
String
get
B
()
{
return
b
;
}
public
void
set
Topic
(
String
topic
)
{
this
.
topic
=
topic
;
public
void
set
B
(
String
b
)
{
this
.
b
=
b
;
}
public
String
get
DefaultTopic
()
{
return
defaultTopi
c
;
public
String
get
C
()
{
return
c
;
}
public
void
set
DefaultTopic
(
String
defaultTopi
c
)
{
this
.
defaultTopic
=
defaultTopi
c
;
public
void
set
C
(
String
c
)
{
this
.
c
=
c
;
}
public
Integer
getD
efaultTopicQueueNums
()
{
return
d
efaultTopicQueueNums
;
public
Integer
getD
()
{
return
d
;
}
public
void
setD
efaultTopicQueueNums
(
Integer
defaultTopicQueueNums
)
{
this
.
d
efaultTopicQueueNums
=
defaultTopicQueueNums
;
public
void
setD
(
Integer
d
)
{
this
.
d
=
d
;
}
public
Integer
get
QueueId
()
{
return
queueId
;
public
Integer
get
E
()
{
return
e
;
}
public
void
set
QueueId
(
Integer
queueId
)
{
this
.
queueId
=
queueId
;
public
void
set
E
(
Integer
e
)
{
this
.
e
=
e
;
}
public
Integer
get
SysFlag
()
{
return
sysFlag
;
public
Integer
get
F
()
{
return
f
;
}
public
void
set
SysFlag
(
Integer
sysFlag
)
{
this
.
sysFlag
=
sysFlag
;
public
void
set
F
(
Integer
f
)
{
this
.
f
=
f
;
}
public
Long
get
BornTimestamp
()
{
return
bornTimestamp
;
public
Long
get
G
()
{
return
g
;
}
public
void
set
BornTimestamp
(
Long
bornTimestamp
)
{
this
.
bornTimestamp
=
bornTimestamp
;
public
void
set
G
(
Long
g
)
{
this
.
g
=
g
;
}
public
Integer
get
Flag
()
{
return
flag
;
public
Integer
get
H
()
{
return
h
;
}
public
void
set
Flag
(
Integer
flag
)
{
this
.
flag
=
flag
;
public
void
set
H
(
Integer
h
)
{
this
.
h
=
h
;
}
public
String
get
Properties
()
{
return
properties
;
public
String
get
I
()
{
return
i
;
}
public
void
set
Properties
(
String
properties
)
{
this
.
properties
=
properties
;
public
void
set
I
(
String
i
)
{
this
.
i
=
i
;
}
public
Integer
get
ReconsumeTimes
()
{
return
reconsumeTimes
;
public
Integer
get
J
()
{
return
j
;
}
public
void
set
ReconsumeTimes
(
Integer
reconsumeTimes
)
{
this
.
reconsumeTimes
=
reconsumeTimes
;
public
void
set
J
(
Integer
j
)
{
this
.
j
=
j
;
}
public
boolean
is
UnitMode
()
{
return
unitMode
;
public
boolean
is
K
()
{
return
k
;
}
public
void
set
UnitMode
(
boolean
unitMode
)
{
this
.
unitMode
=
unitMode
;
public
void
set
K
(
boolean
k
)
{
this
.
k
=
k
;
}
public
Integer
get
ConsumeRetryTimes
()
{
return
consumeRetryTimes
;
public
Integer
get
L
()
{
return
l
;
}
public
void
set
ConsumeRetryTimes
(
final
Integer
consumeRetryTimes
)
{
this
.
consumeRetryTimes
=
consumeRetryTimes
;
public
void
set
L
(
final
Integer
l
)
{
this
.
l
=
l
;
}
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录