Questions tagged [vertx-eventbus]

98 questions
6
votes
1 answer

What's the difference between the send and publish methods of Vertx's EventBus?

I'm having my first contact with Vertx's EventBus and I realized there are two ways to submit a message. Used the send or publish method. I ask: What is the practical difference between using these two methods and in what scenario do they use each…
cazuzaneto
  • 175
  • 2
  • 9
5
votes
1 answer

Vertx clustered eventbus not removing old node on kubernetes rolling deployment

I have two vertx micro services running in cluster and communicate with each other using a headless service(link) in on premise cloud. Whenever I do a rolling deployment I am facing connectivity issue within services. When I analysed the log I can…
vel
  • 173
  • 9
4
votes
2 answers

Can you spy on the Vert.x event bus in Quarkus tests?

Does anyone know of a way to spy on the Vert.x event bus in Quarkus tests? Ideally I'd like to assert that during a method in the service layer we are sending an event to the correct address, but does anyone know if this is possible? If I just try…
bnjns
  • 41
  • 4
3
votes
0 answers

process is not defined in new svelte app using vertx eventbus

Created a new svelte app with: npx degit sveltejs/template svelte-typescript-app cd svelte-typescript-app node scripts/setupTypeScript.js Added this package @vertx/eventbus-bridge-client.js as dependency. { "name": "svelte-app", "version":…
kind_robot
  • 2,383
  • 4
  • 31
  • 45
3
votes
3 answers

Problems configuring clustered Vertx Eventbus in Quarkus

I'm using: Quarkus 1.6.1.Final Vertx 3.9.1 (provided by quarkus-vertx dependency, see pom.xml below) And I can't get the clusered Eventbus working. I've followed the instructions listed here: https://vertx.io/docs/vertx-hazelcast/java/ I've also…
Serkan
  • 639
  • 5
  • 14
3
votes
1 answer

Behaviour of Vert.x Event-bus when reaching the limit

I'm missing one piece of understanding of how Event Bus / Hazelcast works. Imagine a case with a consumer and a producer verticles communicating over the clustered EB. The consuming part is doing CPU / memory / IO-intensive calculations. When at…
injecteer
  • 20,038
  • 4
  • 45
  • 89
3
votes
0 answers

VertX eventbus.publish when running multiple instances

I'm beginning to realise VertX does its event bus publishing (eventbus.publish) fanning out to all instances of all verticle subscribed. But if I use eventbus.send for a specific address, that message gets delivered to a single instance of the…
2
votes
1 answer

What are Vert.x EventBus messages ordering guarantees?

Documention says: Vert.x will deliver messages to any particular handler in the same order they were sent from any particular sender. What is meant by a handler or sender: verticle, context, particular callback or something else? Will all messages…
Nolequen
  • 3,032
  • 6
  • 36
  • 55
2
votes
0 answers

Vertx - threads are stuck while sending response back to client

I'm using vertx-4.2.6 to build a proxy service which takes requests from clients (for ex: browser, standalone apps etc), invoke a single thirdparty server, gets the response and send the same response back to client who initiated the request. In…
2
votes
1 answer

Vertx - Database update query takes few minutes

I have a very simple update database operation in my Java Vertx application but for some reason it takes araround 3 minutes. I have attached the console output showing the time. Can somebody please help me to debug why is it so. 2022-07-19…
ZAJ
  • 793
  • 3
  • 23
  • 50
2
votes
1 answer

How to skip retry in vertx circuit breaker based on condition

I am currently using Vertx CircuitBreaker to attempt retry on requesting event bus. Based on the ReplyException.ReplyFailure I want to skip or avoid retries. For example I don't want retry when the event bus responds with…
vel
  • 173
  • 9
2
votes
2 answers

Vertx executeBatch not returning all rows

I am using vertx JDBC client pool and trying to insert multiple records to table. The insertion is done successfully but the inserted records are not returned instead only first record is returned. Code to insert multiple record using…
vel
  • 173
  • 9
2
votes
0 answers

Vertx Sockjs Eventbus handler authorization

Im building a social platform and just started on the websocket portion. I'm having trouble understanding where to hook my auth into the Vert.x SockJsHandler. I found a code example using "SockJsServer" via vertx.createSockJsServer here but it…
Micah Smith
  • 311
  • 2
  • 11
2
votes
1 answer

Vertx Service Proxy Compilation error Cannot resolved to be a type

I am working with vertx service proxy. As I try to add all the required dependencies and package-info java file. I still get vertx compilation error cannot be resolved to a type. From tutorial I have learnt that it is a generated file but It does…
2
votes
1 answer

Replacing JavaScript SockJS client with Java Vert.x client

I have a working server in java vertx and a client but in SockJS, i would like to make this client in java, how can i convert this to java: const EB_EVENT_TO_SERVER = "event.to.server"; const EB_EVENT_TO_CLIENT = "event.to.client."; const…
1
2 3 4 5 6 7