Added Endpoint support, created the Worker and Subscriber API