def poke(self, context):
sqs_hook = SQSHook(aws_conn_id=self.aws_conn_id)<EOL>sqs_conn = sqs_hook.get_conn()<EOL>self.log.info('<STR_LIT>', self.sqs_queue)<EOL>messages = sqs_conn.receive_message(QueueUrl=self.sqs_queue,<EOL>MaxNumberOfMessages=self.max_messages,<EOL>WaitTimeSeconds=self.wait_time_seconds)<EOL>self.log.info("<STR_LIT>", str(messages))<EOL>if '<STR_LIT>' in messages and len(messages['<STR_LIT>']) > <NUM_LIT:0>:<EOL><INDENT>entries = [{'<STR_LIT>': message['<STR_LIT>'], '<STR_LIT>': message['<STR_LIT>']}<EOL>for message in messages['<STR_LIT>']]<EOL>result = sqs_conn.delete_message_batch(QueueUrl=self.sqs_queue,<EOL>Entries=entries)<EOL>if '<STR_LIT>' in result:<EOL><INDENT>context['<STR_LIT>'].xcom_push(key='<STR_LIT>', value=messages)<EOL>return True<EOL><DEDENT>else:<EOL><INDENT>raise AirflowException(<EOL>'<STR_LIT>' + str(result) + '<STR_LIT>' + str(messages))<EOL><DEDENT><DEDENT>return False<EOL>
Check for message on subscribed queue and write to xcom the message with key ``messages``

:param context: the context object
:type context: dict
:return: ``True`` if message is available or ``False``