Pass Publication.info on Java level

centrifugal · Oct 24, 2023 · 7ac66ba · 7ac66ba
1 parent 3971f02
commit 7ac66ba
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git a/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Client.java b/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Client.java
@@ -1205,6 +1205,7 @@ private void historySynchronized(String channel, HistoryOptions opts, ResultCall
                     Publication pub = new Publication();
                     pub.setData(protoPub.getData().toByteArray());
                     pub.setOffset(protoPub.getOffset());
+                    pub.setInfo(ClientInfo.fromProtocolClientInfo(protoPub.getInfo()));
                     pubs.add(pub);
                 }
                 result.setPublications(pubs);

diff --git a/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Publication.java b/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Publication.java
@@ -20,4 +20,14 @@ void setOffset(long offset) {
     }
 
     private long offset;
+
+    private ClientInfo info;
+
+    public ClientInfo getInfo() {
+        return info;
+    }
+
+    public void setInfo(ClientInfo info) {
+        this.info = info;
+    }
 }
diff --git a/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Subscription.java b/centrifuge/src/main/java/io/github/centrifugal/centrifuge/Subscription.java
@@ -185,6 +185,7 @@ void moveToSubscribed(Protocol.SubscribeResult result) {
                 PublicationEvent publicationEvent = new PublicationEvent();
                 publicationEvent.setData(publication.getData().toByteArray());
                 publicationEvent.setOffset(publication.getOffset());
+                publicationEvent.setInfo(ClientInfo.fromProtocolClientInfo(publication.getInfo()));
                 this.listener.onPublication(this, publicationEvent);
                 this.setOffset(publication.getOffset());
             }