Vertx: comment transférer des messages d'un verticle à un autre avec deliveryoptions?

Question

J'envoie un message à une verticille qui, à son tour, pourrait avoir besoin de l'envoyer à d'autres verticles. Je ne veux pas écrire de code redondant pour copier les en-têtes du message et créer un autre objet message et le transmettre. Est-il possible de transférer le message dans vert.x avec deliveryOptions intact?

Answer 1

En utilisant DeliveryOptions, vous pouvez transférer des messages entre les verticles.

Prenons exemple suivant:

// MainVerticle recevra les données et nous allons envoyer à MessagingVerticle

public class MainVerticle extends AbstractVerticle { 

@Override 
public void start(Future<Void> fut) { 
    //your logic goes here for message object to pass 
    MessageConsumer<Object> mc = vertx.eventBus().consumer("your_addressToServer").handler(message -> { 

    Object message = message.body(); 

    final DeliveryOptions options = new DeliveryOptions().setCodecName("any_messaging_address_name"); 
    vertx.eventBus().send("any_messaging_address_name", Object(message object to pass) , options); 

    }); 

} 

} 

// Envoyer les messages à MessagingVerticle

public class MessagingVerticle extends AbstractVerticle { 

@Override 
public void start(Future<Void> fut) { 
    vertx.eventBus().<Object>consumer("any_messaging_address_name", 
      message -> { 
       Object messageCommand = message.body(); // received object from MainVerticle     
      }); 
    fut.complete(); 
    } 

} 

J'espère que cela va vous aider :)