Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
S
seatunnel-web
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
宋勇
seatunnel-web
Commits
0868f1a9
提交
0868f1a9
authored
1月 29, 2024
作者:
王红亮
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
更新rabbitmq配置
上级
03d14457
隐藏空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
43 行增加
和
20 行删除
+43
-20
RabbitConfiguration.java
...unnel.datasource.plugin.rabbitmq/RabbitConfiguration.java
+43
-20
没有找到文件。
seatunnel-datasource/seatunnel-datasource-plugins/datasource-rabbitmq/src/main/java/org.apache.seatunnel.datasource.plugin.rabbitmq/RabbitConfiguration.java
浏览文件 @
0868f1a9
...
...
@@ -61,25 +61,49 @@ public class RabbitConfiguration {
@Override
public
String
toString
()
{
return
"RabbitConfiguration{"
+
"host='"
+
host
+
'\''
+
", port="
+
port
+
", virtualHost='"
+
virtualHost
+
'\''
+
", username='"
+
username
+
'\''
+
", password='"
+
password
+
'\''
+
", uri='"
+
uri
+
'\''
+
", networkRecoveryInterval="
+
networkRecoveryInterval
+
", automaticRecovery="
+
automaticRecovery
+
", topologyRecovery="
+
topologyRecovery
+
", connectionTimeout="
+
connectionTimeout
+
", requestedChannelMax="
+
requestedChannelMax
+
", requestedFrameMax="
+
requestedFrameMax
+
", requestedHeartbeat="
+
requestedHeartbeat
+
", prefetchCount="
+
prefetchCount
+
", deliveryTimeout="
+
deliveryTimeout
+
", queueName='"
+
queueName
+
'\''
+
", routingKey='"
+
routingKey
+
'\''
+
'}'
;
return
"RabbitConfiguration{"
+
"host='"
+
host
+
'\''
+
", port="
+
port
+
", virtualHost='"
+
virtualHost
+
'\''
+
", username='"
+
username
+
'\''
+
", password='"
+
password
+
'\''
+
", uri='"
+
uri
+
'\''
+
", networkRecoveryInterval="
+
networkRecoveryInterval
+
", automaticRecovery="
+
automaticRecovery
+
", topologyRecovery="
+
topologyRecovery
+
", connectionTimeout="
+
connectionTimeout
+
", requestedChannelMax="
+
requestedChannelMax
+
", requestedFrameMax="
+
requestedFrameMax
+
", requestedHeartbeat="
+
requestedHeartbeat
+
", prefetchCount="
+
prefetchCount
+
", deliveryTimeout="
+
deliveryTimeout
+
", queueName='"
+
queueName
+
'\''
+
", routingKey='"
+
routingKey
+
'\''
+
'}'
;
}
public
String
getHost
()
{
...
...
@@ -217,5 +241,4 @@ public class RabbitConfiguration {
public
void
setRoutingKey
(
String
routingKey
)
{
this
.
routingKey
=
routingKey
;
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论