def METHOD_NAME(self, env, result):
    # One publish server sends messages to many subscription clients as
    # shown in the diagram below:
    #
    #                  +---msg---> Client1
    #                  |
    # Server1 ---msg---+
    #                  |
    #                  +---msg---> Client2
    #
    # Server 1 sends a unique message to the clients it is connected to
    # (clients 1 & 2).
    msg = b"Hello 3"
    result.log("Server 1 is sending: {}".format(msg))
    env.server1.send(data=msg, timeout=self.timeout)
    # Client 1 receives message from server 1.
    received1 = env.client1.receive(timeout=self.timeout)
    result.equal(received1, msg, "Client 1 received")
    # Client 2 receives message from server 1.
    received2 = env.client2.receive(timeout=self.timeout)
    result.equal(received2, msg, "Client 2 received")