Created abstraction of connectors and broker/result-stores

This provides a more "DRY" approach to the amqp connections and later
other driver implementations.