Skip to content

Commit

Permalink
#49 Fixed bug in QueueBrowser by deleting it. Is deprecated since 2021
Browse files Browse the repository at this point in the history
  • Loading branch information
mcweba committed May 29, 2024
1 parent f826cd8 commit feef995
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 402 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
package org.swisspush.gateleen.playground;

import io.vertx.core.*;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
import io.vertx.core.Handler;
import io.vertx.core.Vertx;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpServer;
Expand Down Expand Up @@ -55,7 +58,6 @@
import org.swisspush.gateleen.monitoring.MonitoringHandler;
import org.swisspush.gateleen.monitoring.ResetMetricsController;
import org.swisspush.gateleen.qos.QoSHandler;
import org.swisspush.gateleen.queue.queuing.QueueBrowser;
import org.swisspush.gateleen.queue.queuing.QueueClient;
import org.swisspush.gateleen.queue.queuing.QueueProcessor;
import org.swisspush.gateleen.queue.queuing.circuitbreaker.QueueCircuitBreaker;
Expand Down Expand Up @@ -332,8 +334,6 @@ public void start() {
queueCircuitBreakerConfigurationResourceManager, requestHandler, circuitBreakerPort);

new QueueProcessor(vertx, selfClient, monitoringHandler, queueCircuitBreaker);
final QueueBrowser queueBrowser = new QueueBrowser(vertx, SERVER_ROOT + "/queuing", Address.redisquesAddress(),
monitoringHandler);

LogController logController = new LogController();
logController.registerLogConfiguratorMBean(JMX_DOMAIN);
Expand Down Expand Up @@ -365,7 +365,7 @@ public void start() {
.delegateHandler(delegateHandler)
.customHttpResponseHandler(customHttpResponseHandler)
.contentTypeConstraintHandler(contentTypeConstraintHandler)
.build(vertx, redisProvider, Server.class, router, monitoringHandler, queueBrowser);
.build(vertx, redisProvider, Server.class, router, monitoringHandler);
Handler<RoutingContext> routingContextHandlerrNew = runConfig.buildRoutingContextHandler();
selfClient.setRoutingContexttHandler(routingContextHandlerrNew);

Expand Down
Loading

0 comments on commit feef995

Please sign in to comment.