ReactiveMessagingReplicationStrategy (Java A2A Extras: Replicated Queue Manager MicroProfile Reactive Messaging 1.0.0.Alpha3 API)

java.lang.Object

io.a2a.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, io.a2a.spec.Event event)

Methods inherited from class java.lang.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, io.a2a.spec.Event event)
  
  Specified by:
  
  send in interface ReplicationStrategy
- onReplicatedEvent
  
  public void onReplicatedEvent(String jsonMessage)