in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java [576:606]
public RMQConnectionConfig build() {
if (this.uri != null) {
return new RMQConnectionConfig(
this.uri,
this.networkRecoveryInterval,
this.automaticRecovery,
this.topologyRecovery,
this.connectionTimeout,
this.requestedChannelMax,
this.requestedFrameMax,
this.requestedHeartbeat,
this.prefetchCount,
this.deliveryTimeout);
} else {
return new RMQConnectionConfig(
this.host,
this.port,
this.virtualHost,
this.username,
this.password,
this.networkRecoveryInterval,
this.automaticRecovery,
this.topologyRecovery,
this.connectionTimeout,
this.requestedChannelMax,
this.requestedFrameMax,
this.requestedHeartbeat,
this.prefetchCount,
this.deliveryTimeout);
}
}