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

DBZ-1362 Comment

Browse Source
This commit is contained in:
Gunnar Morling 2019-07-01 09:34:01 +02:00
parent b546dc886e
commit a02daae3c1
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/RecordsSnapshotProducer.java
View File

@ -431,6 +431,7 @@ private void sendCurrentRecord(BlockingConsumer<ChangeEvent> consumer) throws In
consumer.accept(new ChangeEvent(record, sourceInfo.lsn()));
}
// test-only
boolean isStreamingRunning() {
return streamProducer.isPresent() && streamProducer.get().isStreamingRunning();
}

1
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/RecordsStreamProducer.java
View File

@ -683,6 +683,7 @@ private Table tableFromFromMessage(List<ReplicationMessage.Column> columns, Tabl
return combinedTable.create();
}
// test-only
boolean isStreamingRunning() {
return replicationStream.get() != null;
}