Hi Vladislav
Thanks for clarifying. However, we get an error when we try to use the
methods as documented (see below). Does this paradigm also apply to
IgniteMessaging?
Code:
IgniteMessaging rmtMsg = grid.message().withAsync();
rmtMsg.send(destination.topic, message)
def future = rmtMsg.future()
log.debug("got future ${future}")
Error:
Asynchronous operation not started.. Stacktrace follows:
java.lang.IllegalStateException: Asynchronous operation not started.
at
org.apache.ignite.internal.AsyncSupportAdapter.future(AsyncSupportAdapter.java:91)
at
org.apache.ignite.internal.AsyncSupportAdapter.future(AsyncSupportAdapter.java:73)
at
org.grails.ignite.MessagingService.sendMessageAsync(MessagingService.groovy:100)
at XXX.send(MessagingService.groovy:298)
at XXX.propagateCacheEvent(MessagingService.groovy:269)
at XXX.propagateCacheEvent(MessagingService.groovy:264)
at XXX.clearDataCaches(FeedRestoreService.groovy:14)
at XXX.clearCache(SettingsController.groovy:76)
at
org.apache.shiro.web.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:449)
at
org.apache.shiro.web.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365)
at
org.apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90)
at
org.apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83)
at
org.apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:383)
at
org.apache.shiro.web.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362)
at
org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)
at com.brandseye.cors.CorsFilter.doFilter(CorsFilter.java:100)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Async-messaging-tp8719p8733.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
