master
subscribe
def subscribe(arn, endpoint, protocol) response = Excon::Response.new unless topic = self.data[:topics][arn] response.status = 400