I have tried CacheContinuousAsyncQueryExample.java in version 1.6, and found that trigger queries(the process in qry.setLocalListener()) are still executed in local client node, but not remote server nodes.
Is there any problem?
If I want to make the trigger queries to be executed in remote server node, how can I do?
The local listener is always executed on the node that executed the continuous query (client node in your case). But the remote filter is executed on the server node and you can use it to trigger server-side processes. See annotated CacheEntryFilter class in the CacheContinuousAsyncQueryExample.