Clean up message processing (resolves #16)
Increase executor parallelism (resolves #18)