public void start()

in docker_images/java/wrapper/src/main/java/io/swagger/server/api/verticle/ControlApiVerticle.java [39:154]
100 lines of code
14 McCabe index (conditional complexity)

    public void start() throws Exception {

        //Consumer for Control_Cleanup
        vertx.eventBus().<JsonObject> consumer(CONTROL_CLEANUP_SERVICE_ID).handler(message -> {
            try {
                // Workaround for #allParams section clearing the vendorExtensions map
                String serviceId = "Control_Cleanup";
                service.controlCleanup(result -> {
                    if (result.succeeded())
                        message.reply(null);
                    else {
                        Throwable cause = result.cause();
                        manageError(message, cause, "Control_Cleanup");
                    }
                });
            } catch (Exception e) {
                logUnexpectedError("Control_Cleanup", e);
                message.fail(MainApiException.INTERNAL_SERVER_ERROR.getStatusCode(), MainApiException.INTERNAL_SERVER_ERROR.getStatusMessage());
            }
        });

        //Consumer for Control_GetCapabilities
        vertx.eventBus().<JsonObject> consumer(CONTROL_GETCAPABILITIES_SERVICE_ID).handler(message -> {
            try {
                // Workaround for #allParams section clearing the vendorExtensions map
                String serviceId = "Control_GetCapabilities";
                service.controlGetCapabilities(result -> {
                    if (result.succeeded())
                        message.reply(new JsonObject(Json.encode(result.result())).encodePrettily());
                    else {
                        Throwable cause = result.cause();
                        manageError(message, cause, "Control_GetCapabilities");
                    }
                });
            } catch (Exception e) {
                logUnexpectedError("Control_GetCapabilities", e);
                message.fail(MainApiException.INTERNAL_SERVER_ERROR.getStatusCode(), MainApiException.INTERNAL_SERVER_ERROR.getStatusMessage());
            }
        });

        //Consumer for Control_LogMessage
        vertx.eventBus().<JsonObject> consumer(CONTROL_LOGMESSAGE_SERVICE_ID).handler(message -> {
            try {
                // Workaround for #allParams section clearing the vendorExtensions map
                String serviceId = "Control_LogMessage";
                JsonObject logMessageParam = message.body().getJsonObject("logMessage");
                if (logMessageParam == null) {
                    manageError(message, new MainApiException(400, "logMessage is required"), serviceId);
                    return;
                }
                LogMessage logMessage = Json.mapper.readValue(logMessageParam.encode(), LogMessage.class);
                service.controlLogMessage(logMessage, result -> {
                    if (result.succeeded())
                        message.reply(null);
                    else {
                        Throwable cause = result.cause();
                        manageError(message, cause, "Control_LogMessage");
                    }
                });
            } catch (Exception e) {
                logUnexpectedError("Control_LogMessage", e);
                message.fail(MainApiException.INTERNAL_SERVER_ERROR.getStatusCode(), MainApiException.INTERNAL_SERVER_ERROR.getStatusMessage());
            }
        });

        //Consumer for Control_SendCommand
        vertx.eventBus().<JsonObject> consumer(CONTROL_SENDCOMMAND_SERVICE_ID).handler(message -> {
            try {
                // Workaround for #allParams section clearing the vendorExtensions map
                String serviceId = "Control_SendCommand";
                String cmdParam = message.body().getString("cmd");
                if(cmdParam == null) {
                    manageError(message, new MainApiException(400, "cmd is required"), serviceId);
                    return;
                }
                String cmd = cmdParam;
                service.controlSendCommand(cmd, result -> {
                    if (result.succeeded())
                        message.reply(null);
                    else {
                        Throwable cause = result.cause();
                        manageError(message, cause, "Control_SendCommand");
                    }
                });
            } catch (Exception e) {
                logUnexpectedError("Control_SendCommand", e);
                message.fail(MainApiException.INTERNAL_SERVER_ERROR.getStatusCode(), MainApiException.INTERNAL_SERVER_ERROR.getStatusMessage());
            }
        });

        //Consumer for Control_SetFlags
        vertx.eventBus().<JsonObject> consumer(CONTROL_SETFLAGS_SERVICE_ID).handler(message -> {
            try {
                // Workaround for #allParams section clearing the vendorExtensions map
                String serviceId = "Control_SetFlags";
                String flagsParam = message.body().getString("flags");
                if(flagsParam == null) {
                    manageError(message, new MainApiException(400, "flags is required"), serviceId);
                    return;
                }
                Object flags = Json.mapper.readValue(flagsParam, Object.class);
                service.controlSetFlags(flags, result -> {
                    if (result.succeeded())
                        message.reply(null);
                    else {
                        Throwable cause = result.cause();
                        manageError(message, cause, "Control_SetFlags");
                    }
                });
            } catch (Exception e) {
                logUnexpectedError("Control_SetFlags", e);
                message.fail(MainApiException.INTERNAL_SERVER_ERROR.getStatusCode(), MainApiException.INTERNAL_SERVER_ERROR.getStatusMessage());
            }
        });

    }