ReactiveMessagingReplicationStrategy (Java SDK A2A Parent 1.4.0.Final API)

java.lang.Object

org.a2aproject.sdk.extras.queuemanager.replicated.mp_reactive.ReactiveMessagingReplicationStrategy

All Implemented Interfaces:: ReplicationStrategy

@ApplicationScoped public class ReactiveMessagingReplicationStrategy extends Object implements ReplicationStrategy

Constructor Summary

Constructors

Constructor

Description

ReactiveMessagingReplicationStrategy()
Method Summary

Modifier and Type

Method

Description

void

onReplicatedEvent(String jsonMessage)

void

send(String taskId, Event event)

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ReactiveMessagingReplicationStrategy
  
  public ReactiveMessagingReplicationStrategy()
Method Details
- send
  
  public void send(String taskId, Event event)
  
  Specified by:
  
  send in interface ReplicationStrategy
- onReplicatedEvent
  
  public void onReplicatedEvent(String jsonMessage)