code: def test_two_receivers(self):
      logger = logs.get_logger("test_two_receivers")
      logger.setLevel(10)
      q1 = self.get_queue()
      q1.clean()
  
      q2 = self.get_queue(q1.get_name())
  
      data1 = str(uuid.uuid4())
      data2 = str(uuid.uuid4())
  
      logger.debug("data1 = " + data1)
      logger.debug("data2 = " + data2)
  
      q1.enqueue(data1)
      recv_data1 = self.get_queue_data(
          q2.dequeue(timeout=self.get_timeout())
      )
  
      self.assertEqual(data1, recv_data1)
  
      q1.enqueue(data1)
      q1.enqueue(data2)
  
      recv_data1 = q1.dequeue(timeout=self.get_timeout())
      recv_data2 = q2.dequeue(timeout=self.get_timeout())
  
      recv1 = self.get_queue_data(recv_data1)
      recv2 = self.get_queue_data(recv_data2)
  
      logger.debug("recv1 = " + recv1)
      logger.debug("recv2 = " + recv2)
  
      self.assertTrue(data1 == recv1 or data2 == recv1)
      self.assertTrue(data1 == recv2 or data2 == recv2)
      self.assertFalse(recv1 == recv2)
  
      self.assertTrue(q1.dequeue() is None)
      self.assertTrue(q2.dequeue() is None)
  
imports: import unittest
  import uuid
  import os
  import time
  import yaml
  from studio.pubsub_queue import PubsubQueue
  from studio.queues.sqs_queue import SQSQueue
  from studio.queues.local_queue import LocalQueue
  from studio.extra_util import has_aws_credentials
  from studio import model
  from studio.util import logs
label_desc: Use image node_id 2 for calling the DistributedQueueTest obj's underlying member method code with example usage: obj.test_two_receivers() without return types