Toggle navigation
Home
io.atomix.cluster.messaging.ClusterEventsService to io.atomix.cluster.messaging.ClusterEventingService
No. of Instances - 12
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
eventService2.<String>addSubscriber(new MessageSubject("test1"),SERIALIZER::decode,message -> { value2.set(message); } ,MoreExecutors.directExecutor())
to
eventService2.<String>subscribe("test1",SERIALIZER::decode,message -> { value2.set(message); } ,MoreExecutors.directExecutor())
eventService2.<String,String>addSubscriber(new MessageSubject("test2"),SERIALIZER::decode,message -> { value2.set(message); return message; } ,SERIALIZER::encode,MoreExecutors.directExecutor())
to
eventService2.<String,String>subscribe("test2",SERIALIZER::decode,message -> { value2.set(message); return message; } ,SERIALIZER::encode,MoreExecutors.directExecutor())
eventService.addSubscriber(new MessageSubject(subject),eventLog.listener(),MoreExecutors.directExecutor())
to
eventService.subscribe(subject,eventLog.listener(),MoreExecutors.directExecutor())
eventService3.sendAndReceive(new MessageSubject("test2"),"Hello world!").join()
to
eventService3.send("test2","Hello world!").join()
eventService3.sendAndReceive(new MessageSubject("test2"),"Hello world!").join()
to
eventService3.send("test2","Hello world!").join()
eventService3.sendAndReceive(new MessageSubject("test2"),"Hello world!").join()
to
eventService3.send("test2","Hello world!").join()
eventService.addSubscriber(new MessageSubject(subject),eventLog.listener(),MoreExecutors.directExecutor())
to
eventService.subscribe(subject,eventLog.listener(),MoreExecutors.directExecutor())
eventService1.<String>addSubscriber(new MessageSubject("test1"),SERIALIZER::decode,message -> { value1.set(message); } ,MoreExecutors.directExecutor())
to
eventService1.<String>subscribe("test1",SERIALIZER::decode,message -> { value1.set(message); } ,MoreExecutors.directExecutor())
eventService1.<String,String>addSubscriber(new MessageSubject("test2"),SERIALIZER::decode,message -> { value1.set(message); return message; } ,SERIALIZER::encode,MoreExecutors.directExecutor())
to
eventService1.<String,String>subscribe("test2",SERIALIZER::decode,message -> { value1.set(message); return message; } ,SERIALIZER::encode,MoreExecutors.directExecutor())
Wrap or Un-wrap
broadcast
to
broadcast
unicast
to
unicast
unicast
to
unicast
unicast
to
unicast
Other
new MessageSubject(subject)
to
subject