Uses of Class
com.kingsrook.qqq.backend.core.realtime.RealtimeMessage

Packages that use RealtimeMessage

Package	Description
com.kingsrook.qqq.backend.core.realtime
com.kingsrook.qqq.esb.realtime

Uses of RealtimeMessage in com.kingsrook.qqq.backend.core.realtime

Methods in com.kingsrook.qqq.backend.core.realtime that return RealtimeMessage

Modifier and Type	Method	Description
RealtimeMessage	RealtimeMessage.withAt(Instant at)	Fluent setter for at
RealtimeMessage	RealtimeMessage.withChannel(String channel)	Fluent setter for channel
RealtimeMessage	RealtimeMessage.withData(Map<String,Serializable> data)	Fluent setter for data
RealtimeMessage	RealtimeMessage.withEvent(String event)	Fluent setter for event
RealtimeMessage	RealtimeMessage.withId(String id)	Fluent setter for id

Methods in com.kingsrook.qqq.backend.core.realtime with parameters of type RealtimeMessage

Modifier and Type	Method	Description
void	InMemoryRealtimeBus.publish(RealtimeMessage message)	Run each listener independently and await this publication.
void	RealtimeBusInterface.publish(RealtimeMessage message)	Publish an invalidation to all local or distributed listeners.

Method parameters in com.kingsrook.qqq.backend.core.realtime with type arguments of type RealtimeMessage

Modifier and Type	Method	Description
AutoCloseable	InMemoryRealtimeBus.subscribe(Consumer<RealtimeMessage> listener)	The subscription handle removes only this listener.
AutoCloseable	RealtimeBusInterface.subscribe(Consumer<RealtimeMessage> listener)	Subscribe until the returned handle is closed.

Uses of RealtimeMessage in com.kingsrook.qqq.esb.realtime

Methods in com.kingsrook.qqq.esb.realtime with parameters of type RealtimeMessage

Modifier and Type	Method	Description
void	EsbRealtimeBus.publish(RealtimeMessage message)	Use a non-transacted, auto-ack session like the control topic.

Method parameters in com.kingsrook.qqq.esb.realtime with type arguments of type RealtimeMessage

Modifier and Type	Method	Description
AutoCloseable	EsbRealtimeBus.subscribe(Consumer<RealtimeMessage> listener)	Subscribe locally; the broker sends each message to every pod, including its producer.