Update to latest core API
@@ -68,7 +68,7 @@ class SockJSSession extends SockJSSocketBase implements Shareable {
private final LocalMap<String, SockJSSession> sessions;
private final Deque<String> pendingWrites = new LinkedList<>();
- private final Context context;
+ private final ContextInternal context;
private final InboundBuffer<Buffer> pendingReads;
private final String id;
private final long timeout;
@@ -102,8 +102,8 @@ class SockJSSession extends SockJSSocketBase implements Shareable {
this.id = id;
this.timeout = id == null ? -1 : options.getSessionTimeout();
this.sockHandler = sockHandler;
- context = vertx.getOrCreateContext();
- pendingReads = new InboundBuffer<>(context);
+ context = (ContextInternal) vertx.getOrCreateContext();
+ pendingReads = new InboundBuffer<>(context.executor());
// Start a heartbeat
