silentbalanceyh/vertx-zero

File ServerStompHandler.java has 438 lines of code (exceeds 250 allowed). Consider refactoring.

Open

package io.vertx.up.plugin.stomp.socket;

import io.horizon.uca.log.Annal;
import io.vertx.core.*;
import io.vertx.core.impl.ContextInternal;

ServerStompHandler has 42 methods (exceeds 20 allowed). Consider refactoring.

Open

public class ServerStompHandler implements ServerWsHandler {

    private static final Annal LOGGER = Annal.get(ServerStompHandler.class);
    private final Vertx vertx;
    private final Context context;

Method handle has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void handle(final ServerFrame serverFrame) {
        final Frame frame = serverFrame.frame();
        final StompServerConnection connection = serverFrame.connection();
        connection.onServerActivity();

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    @Override
    public StompServerHandler onAck(final StompServerConnection connection, final Frame subscription, final List<Frame> messages) {
        final Handler<Acknowledgement> handler;
        synchronized (this) {
            handler = this.onAckHandler;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    @Override
    public StompServerHandler onNack(final StompServerConnection connection, final Frame subscribe, final List<Frame> messages) {
        final Handler<Acknowledgement> handler;
        synchronized (this) {
            handler = this.onNackHandler;

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleAck(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.ackHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleDisconnect(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.disconnectHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleSubscribe(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.subscribeHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleNack(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.nackHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleCommit(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.commitHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleSend(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.sendHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleBegin(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.beginHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleAbort(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.abortHandler;
        }

• Read up
  Read up

Similar blocks of code found in 9 locations. Consider refactoring.

Open

    private void handleUnsubscribe(final Frame frame, final StompServerConnection connection) {
        final Handler<ServerFrame> handler;
        synchronized (this) {
            handler = this.unsubscribeHandler;
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        final long pong = Frame.Heartbeat.computePongPeriod(
            Frame.Heartbeat.create(connection.server().options().getHeartbeat()),
            Frame.Heartbeat.parse(frame.getHeader(Frame.HEARTBEAT)));

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        final long ping = Frame.Heartbeat.computePingPeriod(
            Frame.Heartbeat.create(connection.server().options().getHeartbeat()),
            Frame.Heartbeat.parse(frame.getHeader(Frame.HEARTBEAT)));

• Read up
  Read up