vertx

Type Members

1. class AkkaSerializationMessageCodec extends MessageCodec[AnyRef, AnyRef]

   

2. case class EventEnvelope(address: String, evt: DurableEvent) extends Product with Serializable

   

3. class LogEventDispatcher extends Actor

   

4. class PayloadSerializationExtension extends Extension

   

5. final class ProcessingResult extends Enum[ProcessingResult]

   

6. trait ProgressStore[R, W] extends AnyRef

   

7. trait SequenceNumberProgressStore extends ProgressStore[Long, Long]

   

8. class VertxAdapter extends AnyRef

   

   A Vert.x adapter connects event logs to a Vert.x instance.

   A Vert.x adapter connects event logs to a Vert.x instance.

   Event exchange is performed over the Vert.x event bus by event producers. An event producer is a unidirectional connection between an event log and one or multiple event bus endpoints. Events can be exchanged in both directions by different event producers.

   Event producers are created using the EventProducer factory methods and supplied to the adapter via the VertxAdapterConfig.

   An adapter manages multiple event producers, initializes the producers and establishes the connection to the supplied Vert.x instance.

   A StorageProvider is used by the adapter to persist the replication progress of the individual event producers.

   Example:

   val config = VertxAdapterConfig()
      .addProducer(
        EventProducer.fromLog(sourceLog)
          .publishTo { case _ => "address-1" }
          .as("vertx-producer")
      )
      .addProducer(
        EventProducer.fromEndpoints("address-2")
          .writeTo(destinationLog)
          .as("log-producer")
      )
   
   val adapter = VertxAdapter(config, vertx, storageProvider)(actorSystem)
   adapter.start()

9. trait VertxEventDispatcher[R, W] extends EventsourcedWriter[R, W] with ProgressStore[R, W]

   

10. trait VertxProducer extends AnyRef

    

11. trait VertxPublisher extends VertxProducer

    

12. trait VertxSender extends VertxProducer