Skip to content

Commit 73b4a7c

Browse files
oskardudyczw1am
authored andcommitted
[DEVEX-250] Added default structure for message serializer and naming resolution
1 parent 3ba75be commit 73b4a7c

File tree

5 files changed

+0
-53
lines changed

5 files changed

+0
-53
lines changed

db-client-java/src/main/java/io/kurrent/dbclient/serialization/KurrentDBClientSerializationSettings.java

Lines changed: 0 additions & 34 deletions
This file was deleted.

db-client-java/src/main/java/io/kurrent/dbclient/serialization/MessageSerializer.java

Lines changed: 0 additions & 5 deletions
This file was deleted.

db-client-java/src/main/java/io/kurrent/dbclient/serialization/MessageSerializerBuilder.java

Lines changed: 0 additions & 7 deletions
This file was deleted.

db-client-java/src/main/java/io/kurrent/dbclient/serialization/MessageSerializerImpl.java

Lines changed: 0 additions & 4 deletions
This file was deleted.

src/main/java/io/kurrent/dbclient/KurrentDBClientBase.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
public class KurrentDBClientBase {
1717
final Logger logger = LoggerFactory.getLogger(KurrentDBClientBase.class);
1818
final private GrpcClient client;
19-
final private MessageSerializer serializer;
2019

2120
KurrentDBClientBase(KurrentDBClientSettings settings) {
2221
Discovery discovery;
@@ -33,8 +32,6 @@ public class KurrentDBClientBase {
3332
this.client = service.getHandle();
3433

3534
CompletableFuture.runAsync(service, createConnectionLoopExecutor());
36-
37-
serializer = MessageSerializerBuilder.get();
3835
}
3936
private Executor createConnectionLoopExecutor() {
4037
return Executors.newSingleThreadExecutor(r -> {

0 commit comments

Comments
 (0)