use long for java unsigned int to represent xid (#26)

disneystreaming · Jun 3, 2019 · 8b991d3 · 8b991d3
1 parent 5658ae4
commit 8b991d3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/com/disneystreaming/pg2k4j/models/SlotMessage.java b/src/main/java/com/disneystreaming/pg2k4j/models/SlotMessage.java
@@ -32,20 +32,20 @@
 
 public class SlotMessage {
 
-    private final int xid;
+    private final long xid;
     private final List<Change> change;
 
     @JsonCreator
     public SlotMessage(
-            @JsonProperty(value = "xid", required = true) final int xidInput,
+            @JsonProperty(value = "xid", required = true) final long xidInput,
             @JsonProperty(value = "change", required = true)
             final List<Change> changeInput
     ) {
         this.xid = xidInput;
         this.change = changeInput;
     }
 
-    public int getXid() {
+    public long getXid() {
         return xid;
     }
 

diff --git a/src/test/java/com/disneystreaming/pg2k4j/SlotReaderKinesisWriterTest.java b/src/test/java/com/disneystreaming/pg2k4j/SlotReaderKinesisWriterTest.java
@@ -120,7 +120,7 @@ public class SlotReaderKinesisWriterTest {
     private static final byte[] testByteArray = "testByteArray".getBytes();
     private static final String correctTableName = "correctTableName";
     private static final String incorrectTableName = "incorrectTableName";
-    private static final SlotMessage testSlotMessage = new SlotMessage(123,
+    private static final SlotMessage testSlotMessage = new SlotMessage(3147483647L,
             Arrays.asList(new DeleteChange("delete", "testTable", "mySchema",
                     new OldKeys(Arrays.asList("type"), Arrays.asList("value"), Arrays.asList("name")))));