Interface RealtimeBusInterface

All Known Implementing Classes:

EsbRealtimeBus, InMemoryRealtimeBus

public interface RealtimeBusInterface

Best-effort invalidations shared by core and qbits. Close subscriptions when their owner stops.

Method Summary

Modifier and Type	Method	Description
void	publish(RealtimeMessage message)	Publish an invalidation to all local or distributed listeners.
AutoCloseable	subscribe(Consumer<RealtimeMessage> listener)	Subscribe until the returned handle is closed.

Method Details

publish

void publish(RealtimeMessage message)

Publish an invalidation to all local or distributed listeners.

subscribe

AutoCloseable subscribe(Consumer<RealtimeMessage> listener)

Subscribe until the returned handle is closed.