It would be great to be able to add a new feature that allows for a distributed version of an ExecutorService. This would execute a Callable or Runnable on any node that is currently running a consumer listening for such messages.