Skip to content

Commit 8718894

Browse files
mostroverkhovStephane Maldini
authored and
Stephane Maldini
committed
fix #665 add ConnectionSetupPayload.isResumeEnabled and resumeToken
1 parent cf1b5d6 commit 8718894

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

rsocket-core/src/main/java/io/rsocket/ConnectionSetupPayload.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import io.netty.util.AbstractReferenceCounted;
2121
import io.rsocket.frame.FrameHeaderFlyweight;
2222
import io.rsocket.frame.SetupFrameFlyweight;
23+
import javax.annotation.Nullable;
2324

2425
/**
2526
* Exposed to server for determination of ResponderRSocket based on mime types and SETUP
@@ -43,6 +44,11 @@ public static ConnectionSetupPayload create(final ByteBuf setupFrame) {
4344

4445
public abstract boolean willClientHonorLease();
4546

47+
public abstract boolean isResumeEnabled();
48+
49+
@Nullable
50+
public abstract ByteBuf resumeToken();
51+
4652
@Override
4753
public ConnectionSetupPayload retain() {
4854
super.retain();
@@ -101,6 +107,16 @@ public boolean willClientHonorLease() {
101107
return SetupFrameFlyweight.honorLease(setupFrame);
102108
}
103109

110+
@Override
111+
public boolean isResumeEnabled() {
112+
return SetupFrameFlyweight.resumeEnabled(setupFrame);
113+
}
114+
115+
@Override
116+
public ByteBuf resumeToken() {
117+
return SetupFrameFlyweight.resumeToken(setupFrame);
118+
}
119+
104120
@Override
105121
public ConnectionSetupPayload touch() {
106122
setupFrame.touch();

0 commit comments

Comments
 (0)