Able to listen messages on methods and propagate to subscribers through EndpointConsumer API.