Increase EventBus timeout

[jp gouin]

Hi,

I would like to know how to setup a timeout on the eventbus  when it's clustered (Infinispan) into openshift (minishift).

I would like to increase the 30 second timeout.

I've tried to set the DeliveryOptions but it only seems to work when i start my micro services locally.

This is what i've tried : 

  DeliveryOptions options = new DeliveryOptions().setSendTimeout(200000);

        

    Single<String> obs1 = vertx.eventBus()

                .<String>rxSend("troubleshooting", metadata.toString(),options).subscribeOn(io.vertx.rxjava.core.RxHelper.scheduler(vertx)).retry(2).timeout(5, TimeUnit.MINUTES)

                .map(Message::body);

    obs1.subscribe(

    x -> rc.response().end(x),

                t -> rc.response().setStatusCode(500).end(t.getMessage())

    );

The troubleshooting handler perform a long task and then send a reply.

Thanks !

[Thomas SEGISMONT]

Hi,

The sendTimeout is not handled by the cluster manager but by the event bus implementation in Vert.x core.

Can you provide more details about your deployment?

Thanks

--
You received this message because you are subscribed to the Google Groups "vert.x" group.
To unsubscribe from this group and stop receiving emails from it, send an email to vertx+unsubscribe@googlegroups.com.
Visit this group at https://groups.google.com/group/vertx.
To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/1aaf76dc-95ec-426e-b89f-87f3e0d79d37%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[jp gouin]

Ok , so how can i increase the 30 second timeout ?

I have an application which is composed of 5 services deployed into minishift (for test puprose) using Kubernetes and Docker.

I use Infinispan as the cluster manager but i have no obligation about that (if the problem come from infinispan i can use another one).

Here is a snap of my code : 

public class ServerService extends AbstractVerticle {

Logger LOG = LoggerFactory.getLogger(ServerService.class);

@Override

    public void start() {

    Router router = Router.router(vertx);

        Set<String> allowedHeaders = new HashSet<>();

        allowedHeaders.add("x-requested-with");

        allowedHeaders.add("Access-Control-Allow-Origin");

        allowedHeaders.add("origin");

        allowedHeaders.add("Content-Type");

        allowedHeaders.add("accept");

        allowedHeaders.add("X-PINGARUNER");

        Set<HttpMethod> allowedMethods = new HashSet<>();

        allowedMethods.add(HttpMethod.GET);

        allowedMethods.add(HttpMethod.POST);

        allowedMethods.add(HttpMethod.OPTIONS);

        /*

         * these methods aren't necessary for this sample, 

         * but you may need them for your projects

         */

        allowedMethods.add(HttpMethod.DELETE);

        allowedMethods.add(HttpMethod.PATCH);

        allowedMethods.add(HttpMethod.PUT);

        

        router.route().handler(CorsHandler.create("*").allowedHeaders(allowedHeaders));

   

    router.route().handler(BodyHandler.create());

    router.get("/").handler(this::invokeMySecondMicroService);

    router.post("/investigation").handler(this::troubleshootingTreeHandler);

        vertx.createHttpServer()

        .requestHandler(router::accept)

        .listen(8080);

}

  private void troubleshootingTreeHandler(RoutingContext rc) {

   

      // The body has now been fully read, so retrieve the form attributes

        MultiMap formAttributes = rc.request().formAttributes();

        Gson gson = new Gson();

        JsonObject metadata = new JsonObject();

        

        for (Map.Entry<String, String> entry : formAttributes.getDelegate().entries()) {

        LOG.info(entry.getValue());

            metadata.add(entry.getKey(), gson.fromJson(entry.getValue(), JsonElement.class));

}

To unsubscribe from this group and stop receiving emails from it, send an email to vertx+un...@googlegroups.com.

[Thomas SEGISMONT]

2018-02-23 15:53 GMT+01:00 jp gouin <gouin.jea...@gmail.com>:

Ok , so how can i increase the 30 second timeout ?

With DeploymentOptions.setSendTimeout. I only meant that, as long as the cluster is well formed, the eventbus send timeout is not a cluster manager concern.

I just tried to reproduce and here are my findings:

- the HTTP request fails, with status 504

This is not Vert.x related, it's just the proxy timing out requests which takes longer than 30 seconds.

- when settings sendTimeout to a low value (500ms), the http request fails with a Vert.x timeout message.

So I suspect your issue is with the proxy timeout. Can you confirm?

Also, in the RxJava code I would

1/ simply create a scheduler for the verticle:

// Init a verticle field at the beginning of the start method

scheduler = RxHelper.scheduler(vertx.getOrCreateContext());

2/ provide this scheduler on the timeout operation

.timeout(5, TimeUnit.MINUTES, scheduler)

3/ remove the subscribeOn operation (useless)

[jp gouin]

Thanks for the answer.

You are rigth , i have a 504 error message and when i set the DeliveryOption timeout under 30 sec i have a vertx error message.

I will change my code with your suggestion.

How can i specify the DeploymentOptions , in the init method ?

[Thomas SEGISMONT]

2018-02-27 9:10 GMT+01:00 jp gouin <gouin.jea...@gmail.com>:

Thanks for the answer.

You are rigth , i have a 504 error message and when i set the DeliveryOption timeout under 30 sec i have a vertx error message.

I will change my code with your suggestion.

How can i specify the DeploymentOptions , in the init method ?

Sorry for the confusion, it's actually DeliveryOptions.setSendTimeout which drives the eventbus timeout.

 

--

You received this message because you are subscribed to the Google Groups "vert.x" group.

To unsubscribe from this group and stop receiving emails from it, send an email to vertx+unsubscribe@googlegroups.com.

Visit this group at https://groups.google.com/group/vertx.

To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/95e882c7-2c14-4ad4-9f86-6e0e08eb5cb1%40googlegroups.com.

[jp gouin]

Ok but i already got the DeliveryOption setup with a large timeout.

so how can i increase the timeout from the proxy ?

To unsubscribe from this group and stop receiving emails from it, send an email to vertx+un...@googlegroups.com.

Visit this group at https://groups.google.com/group/vertx.

[jp gouin]

I solved my problem , thanks for your help !

As you pointed out the problem came from the timeout of the route deployed by kubernetes. 

Using openshift command i increased the timeout and now it's working

[Thomas SEGISMONT]

Thanks for letting us know. Would you mind to share the command here ?

To unsubscribe from this group and stop receiving emails from it, send an email to vertx+unsubscribe@googlegroups.com.

Visit this group at https://groups.google.com/group/vertx.

To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/9e3d3101-1e2a-4517-b618-d54c9a6551fd%40googlegroups.com.

[Clement Escoffier]

Hi,

Yes, I would be very interested to know how you increase the timeout on a route. It is an attribute of the route (can’t find it)? or do you need to rebuild the router.

Clement

To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/CACiEr_SZFHBWEOmQy%3Dy-rr9Co%3DGNcorx69oM2MDay01JwCoiyQ%40mail.gmail.com.

[jp gouin]

You don't have to rebuilt the route , but juste annotate it.

Using the following command , it will change the timeout of the route "myroute" to 2 seconds

oc annotate route myroute --overwrite haproxy.router.openshift.io/timeout=2s

And into openshift , into the Applications->routes , select your route and click on "show annotations".

You will see the your new timeout.

https://docs.openshift.com/container-platform/3.5/install_config/configuring_routing.html

Clement

To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/9e3d3101-1e2a-4517-b618-d54c9a6551fd%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Thomas SEGISMONT]

Thanks for sharing

To unsubscribe from this group and stop receiving emails from it, send an email to vertx+unsubscribe@googlegroups.com.

Visit this group at https://groups.google.com/group/vertx.

To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/dc6921d2-14c9-4afc-87ef-25b3538e7ed0%40googlegroups.com.