Refactor bulk message processing.

Remove go routine implementation to avoid 'panic' under some conditions.