the Infinispan server provides a system to filter or transform the events before sending them to the client.
To use this feature you have to:install filter/transformer factory on the server.
configure the client setting the factory name into the filterFactoryName, converterFactoryName string fields.
The filter/transformer can accept parameters that you can pass via the filterFactoryParams, converterFactoryParams arguments.
If you don't need f/t just pass an empty array.
The recoveryCallback action will be executed by the client if the events socket fails, so you can implement there you recovery procedure.
Information on this subject is little fragmented at the moment, some clues:
infinispan/ClientFilterEventsTest.java at master · infinispan/infinispan · GitHub (Java test with server setup)
Thanks a lot man!