- public NotificationProviderService getRpcNotificationProviderService() {
- return rpcNotificationProviderService;
+ public OFRpcTaskContext getTaskContext() {
+ return taskContext;
+ }
+
+ /**
+ * submit task into rpc worker pool
+ * @return future result of task
+ */
+ public ListenableFuture<K> submit() {
+ ListenableFuture<ListenableFuture<K>> compoundResult = getTaskContext().getRpcPool().submit(this);
+ return Futures.dereference(compoundResult);