Skip to content

Commit f7721d7

Browse files
fix: OctopusImpl forgot register listener reference init + first message register
1 parent b72b1aa commit f7721d7

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

plugin/src/main/java/studio/o7/octopus/plugin/OctopusImpl.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,14 @@ public void onCompleted() {
7878
}
7979
});
8080

81+
requestRef.set(observer);
82+
83+
observer.onNext(ListenMessage.newBuilder()
84+
.setRegister(ListenRegister.newBuilder()
85+
.setKeyPattern(listener.getKeyPattern())
86+
.setPriority(listener.getPriority())
87+
.build()).build());
88+
8189
this.listeners.put(listener.getListenerUniqueId(), new Pair<>() {
8290
@Override
8391
public Listener left() {

0 commit comments

Comments
 (0)