alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3815 Use camel case for variables

Browse Source
This commit is contained in:
Thiago Avancini 2021-08-12 16:00:40 -03:00 committed by Gunnar Morling
parent a54174c70a
commit 388d1e6025
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-server/debezium-server-nats_streaming/src/main/java/io/debezium/server/nats_streaming/NatsStreamingChangeConsumer.java
View File

@ -50,8 +50,8 @@ public class NatsStreamingChangeConsumer extends BaseChangeConsumer
private static final String PROP_CLIENT_ID = PROP_PREFIX + "client.id";
private String url;
private String clusterID;
private String clientID;
private String clusterId;
private String clientId;
@ConfigProperty(name = PROP_PREFIX + "null.key", defaultValue = "default")
String nullKey;
@ -73,8 +73,8 @@ void connect() {
// Read config
final Config config = ConfigProvider.getConfig();
url = config.getValue(PROP_URL, String.class);
clusterID = config.getValue(PROP_CLUSTER_ID, String.class);
clientID = config.getValue(PROP_CLIENT_ID, String.class);
clusterId = config.getValue(PROP_CLUSTER_ID, String.class);
clientId = config.getValue(PROP_CLIENT_ID, String.class);
// Setup NATS Streaming connection
Options stanOptions = new Options.Builder()
@ -91,7 +91,7 @@ public void connectionEvent(Connection natsConnection, Events event) {
})
.build();
try {
sc = NatsStreaming.connect(clusterID, clientID, stanOptions);
sc = NatsStreaming.connect(clusterId, clientId, stanOptions);
}
catch (Exception e) {
throw new DebeziumException(e);