Vertx: Wie können Nachrichten mit Zustelloptionen von einem verticle an ein anderes weitergeleitet werden?

Question

Ich sende eine Nachricht an ein vertikel, das es wiederum an andere verticles weiterleiten muss. Ich möchte keinen redundanten Code schreiben, um Header aus der Nachricht zu kopieren und ein weiteres Nachrichtenobjekt zu erstellen und es weiterzugeben. Gibt es eine Möglichkeit, die Nachricht in vert.x mit intallen Zustellungsoptionen weiterzuleiten?

Answer 1

Mit DeliveryOptions können Sie Nachrichten zwischen Verticles übertragen.

folgendes Beispiel:

// MainVerticle werden Daten werden empfangen und wir werden das Senden

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); 

    }); 

} 

} 

// senden diese Nachrichten an MessagingVerticle 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(); 
    } 

} 

Ich hoffe das hilft dir :)