Hi, I am trying to register CQ with transformer with keep binary option and trying to return a cutom defined object. I see the transformer properly creating custom object and returning properly.
But at the same time local listener is not receiving the custom object, instead i think it received binary object. How can i ensure that local listener is receiving custom object properly. ContinuousQueryWithTransformer<BinaryObject, BinaryObject, ListenerEvent> continuousQueryWithTransformer = new ContinuousQueryWithTransformer<>(); I want local listener to receive ListenerEvent (Custom defined object) as below: continuousQueryWithTransformer.setLocalListener(cacheEntryEvents -> cacheEntryEvents.forEach(listenerEvent -> { LOG.info("Event Received : {}", listenerEvent);} But local listener throws BinaryObject cant cast to ListenerEvent. -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/