def peer_subscribe(self, topic_name, topic_publish, peer_publish):
        if not self.timed_out():
            self.lock.acquire()
            msgs = copy(self.msg_buffer)
            self.lock.release()
            for msg in msgs:
                peer_publish(msg)
Regression test for ticket #15075.  Allow modifying wizard's form_list
dataset/ETHPy150Open RobotWebTools/rosbridge_suite/rosbridge_library/src/rosbridge_library/internal/publishers.py/PublisherConsistencyListener.peer_subscribe--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/lib/django-1.4/django/contrib/formtools/tests/__init__.py/WizardTests.test_15075