Ceon » Jupiter

Każdy zalogowany użytkownik powinien mieć zarejstrowany topic (lub topiki), na który spływać będą informacje przeznaczone tylko dla niego. Np. informacja o zakończeniu procesu publikacji.

Event o zapisaniu dokumentu, również może być odpowiednio przefiltrowany i wysłany tylko do użytkowników, których dotyczy.

W pierwszym kroku, można rozszerzyć proces rejestrowania odbiorców wiadomości poprzez dodanie filtra, który weryfikowałby, czy dana wiadomość powinna trafić do odbiorcy. Zamiast Multimap<Class, String> można użyć Multimap<Class<T>, Registration<T>>, gdzie
Registraton<T>{
List<string> topic, (pole wymagane)
Predicate<T> filter, - jeżeli test(message) = true, wtedy wysyłamy wiadomość
Function<T, ? extends Message> mapper, do mapowania pomiędzy wiadomością a wyjściem
}

W drugim ktorku, należy rejestrować odbiorcę w momencie połączenia websocketowego i wyrejestrowywać go po zerwaniu takiego połączenia.