Allow the registration connector to do normal publishes but also receive
a lambda that will be called with the DB handle

This is then used by the registration agent to build a registration
database by directly writing to the Redis instance without going through
some intermediate agent