File tree Expand file tree Collapse file tree 1 file changed +16
-0
lines changed
rsocket-core/src/main/java/io/rsocket Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Original file line number Diff line number Diff line change 2020import io .netty .util .AbstractReferenceCounted ;
2121import io .rsocket .frame .FrameHeaderFlyweight ;
2222import 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 ();
You can’t perform that action at this time.
0 commit comments