It can be deployed normally on AWS

![image](https://user-images.githubusercontent.com/38454210/78279329-f1528180-7549-11ea-8aec-ba9620a16609.png)

![image](https://user-images.githubusercontent.com/38454210/78279477-25c63d80-754a-11ea-92bc-313e7950424c.png)


result = self.sqs_client.receive_message(QueueUrl=self.dlq_url, MessageAttributeNames=['All'])
            self.assertGreater(len(result['Messages']), 0)
            self.assertEqual(
                json.loads(json.loads(result['Messages'][0]['Body'])['Message'][0])['message'],
                'test_redrive_policy'
            )
        retry(receive_dlq, retries=10, sleep=2)
    def test_publish_with_empty_subject(self):
        topic_arn = self.sns_client.create_topic(Name=TEST_TOPIC_NAME_2)['TopicArn']
        # P
        rs = self.sns_client.publish(
            TopicArn=topic_arn,
            Message=json.dumps({'message': 'test_publish'})
        )
        self.assertEqual(rs['ResponseMetadata']['HTTPStatusCode'], 200)
        try:
            # P
            self.sns_client.publish(
                TopicArn=topic_arn,
                Subject='',
                Message=json.dumps({'message': 'test_publish'})
            )
            self.fail('This call should not be successful as the subject is empty')
        except ClientError as e:
            self.assertEqual(e.response['Error']['Code'], 'InvalidParameter')
        # c
        self.sns_client.delete_topic(TopicArn=topic_arn)
    def test_create_topic_test_arn(self):