Skip to content

Commit

Permalink
Adapt to vertx-core changes
Browse files Browse the repository at this point in the history
  • Loading branch information
vietj committed Feb 3, 2025
1 parent 5052205 commit 2fe3a35
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
import io.vertx.core.buffer.Buffer;
import io.vertx.core.http.HttpServerRequest;
import io.vertx.core.internal.ContextInternal;
import io.vertx.core.internal.concurrent.InboundMessageQueue;
import io.vertx.core.internal.concurrent.InboundMessageChannel;
import io.vertx.core.internal.logging.Logger;
import io.vertx.core.internal.logging.LoggerFactory;
import io.vertx.core.internal.net.NetSocketInternal;
Expand Down Expand Up @@ -79,7 +79,7 @@ class SockJSSession extends SockJSSocketBase implements Shareable {
private long timeoutTimerID = -1;
private int maxQueueSize = 64 * 1024; // Message queue size is measured in *characters* (not bytes)
private int messagesSize;
private InboundMessageQueue<Buffer> pendingReads;
private InboundMessageChannel<Buffer> pendingReads;
private Handler<Buffer> handler;
private Handler<Void> drainHandler;
private Handler<Void> endHandler;
Expand Down Expand Up @@ -116,7 +116,7 @@ class SockJSSession extends SockJSSocketBase implements Shareable {
}

private void initPendingReads() {
pendingReads = new InboundMessageQueue<>(context.executor(), context.executor()) {
pendingReads = new InboundMessageChannel<>(context.executor(), context.executor()) {
@Override
protected void handleMessage(Buffer msg) {
Handler<Buffer> h = handler;
Expand Down

0 comments on commit 2fe3a35

Please sign in to comment.