Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
pulsar
提交
7e4ace21
pulsar
项目概览
apache
/
pulsar
通知
129
Star
40
Fork
3
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Wiki
1
Wiki
分析
仓库
DevOps
项目成员
Pages
pulsar
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Pages
分析
分析
仓库分析
DevOps
Wiki
1
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
提交
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
7e4ace21
编写于
9月 03, 2020
作者:
A
Aloys
提交者:
GitHub
9月 03, 2020
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Replace if..else with switch in TypeMessageBuilderImpl (#7947)
上级
452a5f24
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
30 addition
and
21 deletion
+30
-21
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java
...rg/apache/pulsar/client/impl/TypedMessageBuilderImpl.java
+30
-21
未找到文件。
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java
浏览文件 @
7e4ace21
...
...
@@ -236,27 +236,36 @@ public class TypedMessageBuilderImpl<T> implements TypedMessageBuilder<T> {
@Override
public
TypedMessageBuilder
<
T
>
loadConf
(
Map
<
String
,
Object
>
config
)
{
config
.
forEach
((
key
,
value
)
->
{
if
(
key
.
equals
(
CONF_KEY
))
{
this
.
key
(
checkType
(
value
,
String
.
class
));
}
else
if
(
key
.
equals
(
CONF_PROPERTIES
))
{
this
.
properties
(
checkType
(
value
,
Map
.
class
));
}
else
if
(
key
.
equals
(
CONF_EVENT_TIME
))
{
this
.
eventTime
(
checkType
(
value
,
Long
.
class
));
}
else
if
(
key
.
equals
(
CONF_SEQUENCE_ID
))
{
this
.
sequenceId
(
checkType
(
value
,
Long
.
class
));
}
else
if
(
key
.
equals
(
CONF_REPLICATION_CLUSTERS
))
{
this
.
replicationClusters
(
checkType
(
value
,
List
.
class
));
}
else
if
(
key
.
equals
(
CONF_DISABLE_REPLICATION
))
{
boolean
disableReplication
=
checkType
(
value
,
Boolean
.
class
);
if
(
disableReplication
)
{
this
.
disableReplication
();
}
}
else
if
(
key
.
equals
(
CONF_DELIVERY_AFTER_SECONDS
))
{
this
.
deliverAfter
(
checkType
(
value
,
Long
.
class
),
TimeUnit
.
SECONDS
);
}
else
if
(
key
.
equals
(
CONF_DELIVERY_AT
))
{
this
.
deliverAt
(
checkType
(
value
,
Long
.
class
));
}
else
{
throw
new
RuntimeException
(
"Invalid message config key '"
+
key
+
"'"
);
switch
(
key
)
{
case
CONF_KEY:
this
.
key
(
checkType
(
value
,
String
.
class
));
break
;
case
CONF_PROPERTIES:
this
.
properties
(
checkType
(
value
,
Map
.
class
));
break
;
case
CONF_EVENT_TIME:
this
.
eventTime
(
checkType
(
value
,
Long
.
class
));
break
;
case
CONF_SEQUENCE_ID:
this
.
sequenceId
(
checkType
(
value
,
Long
.
class
));
break
;
case
CONF_REPLICATION_CLUSTERS:
this
.
replicationClusters
(
checkType
(
value
,
List
.
class
));
break
;
case
CONF_DISABLE_REPLICATION:
boolean
disableReplication
=
checkType
(
value
,
Boolean
.
class
);
if
(
disableReplication
)
{
this
.
disableReplication
();
}
break
;
case
CONF_DELIVERY_AFTER_SECONDS:
this
.
deliverAfter
(
checkType
(
value
,
Long
.
class
),
TimeUnit
.
SECONDS
);
break
;
case
CONF_DELIVERY_AT:
this
.
deliverAt
(
checkType
(
value
,
Long
.
class
));
break
;
default
:
throw
new
RuntimeException
(
"Invalid message config key '"
+
key
+
"'"
);
}
});
return
this
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录