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

DBZ-2543 Remove vert.x dependency

Browse Source
This commit is contained in:
Chris Cranford 2023-08-15 10:04:27 -04:00 committed by Chris Cranford
parent 2cae1b396d
commit c076d9526b
2 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-oracle/pom.xml
View File

@ -71,11 +71,6 @@
<scope>provided</scope>
</dependency>
<!-- Dependencies for OpenLogReplicator -->
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-core</artifactId>
<version>4.2.4</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>

12
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/client/OlrNetworkClient.java
View File

@ -24,7 +24,6 @@
import io.debezium.connector.oracle.proto.OpenLogReplicatorProtocol.RedoResponse;
import io.debezium.connector.oracle.proto.OpenLogReplicatorProtocol.RequestCode;
import io.debezium.connector.oracle.proto.OpenLogReplicatorProtocol.ResponseCode;
import io.vertx.core.buffer.Buffer;
/**
* An OpenLogReplicator network client that communicates using JSON streaming payloads.
@ -263,10 +262,13 @@ private ByteBuffer read() {
@SuppressWarnings("UnusedReturnValue")
private int send(RedoRequest request) {
try {
final Buffer buffer = Buffer.buffer();
buffer.appendIntLE(request.getSerializedSize());
buffer.appendBytes(request.toByteArray());
return channel.write(buffer.getByteBuf().nioBuffer());
// We need to write the size (4 bytes) plus the payload
final ByteBuffer buffer = ByteBuffer.allocate(4 + request.getSerializedSize());
buffer.order(ByteOrder.LITTLE_ENDIAN);
buffer.putInt(request.getSerializedSize());
buffer.put(request.toByteArray());
buffer.flip();
return channel.write(buffer);
}
catch (IOException e) {
throw new OlrNetworkClientException("Failed to send request to server", e);