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/
