def METHOD_NAME(self):
    self.nats_client.is_connected = True
    self.publisher_transport._is_open = True
    buff = bytearray(1024 * 2048)
    with self.assertRaises(TTransportException) as cm:
        yield self.publisher_transport.publish('foo', buff)
    self.assertEqual(TTransportExceptionType.REQUEST_TOO_LARGE,
                     cm.exception.type)
    self.assertEqual("Message exceeds NATS max message size",
                     cm.exception.message)