move elasticsearch driver from pyES to elasticsearch-py
refactor organization and loading of data handlers
hoist route_message into sink namespace
raise sink list into package namespace
adding streaming bulk for elastisearch sink
correct import
add logging
changes to pool.map
use cpu_count for default ocncurrency
change logging
add logging
singe process
testing
testing
process pool with map
update sig handling
remove debug code
remove debug code
remove debug code
no timeout