diff --git a/testing/acceptance_test.py b/testing/acceptance_test.py
index d57064d..987dbe6 100644
--- a/testing/acceptance_test.py
+++ b/testing/acceptance_test.py
@@ -401,7 +401,7 @@ class TestTerminalReporting:
         )
 
     @pytest.mark.parametrize("n", ["-n0", "-n1"])
-    @pytest.mark.parametrize("warn_type", ["pytest", "builtin", "invalid"])
+    @pytest.mark.parametrize("warn_type", ["pytest", "builtin"])
     def test_warnings(self, testdir, n, warn_type):
         from pkg_resources import parse_version
 
@@ -413,8 +413,6 @@ class TestTerminalReporting:
         elif warn_type == "pytest":
             warn_code = """request.config.warn('', 'this is a warning',
                            fslocation=py.path.local())"""
-        elif warn_type == "invalid":
-            warn_code = "msg = UserWarning('this is a warning'); msg.args = (); warnings.warn(msg)"
         else:
             assert False
         testdir.makepyfile(
@@ -431,6 +429,35 @@ class TestTerminalReporting:
         result = testdir.runpytest(n)
         result.stdout.fnmatch_lines(["*this is a warning*", "*1 passed, 1 warnings*"])
 
+    @pytest.mark.parametrize("n", ["-n0", "-n1"])
+    def test_custom_subclass(self, testdir, n):
+        """Check that warning subclasses that don't honor the args attribute don't break
+        pytest-xdist (#344)
+        """
+        from pkg_resources import parse_version
+
+        if parse_version(pytest.__version__) < parse_version("3.1"):
+            pytest.skip("pytest warnings requires >= 3.1")
+
+        testdir.makepyfile(
+            """
+            import warnings, py, pytest
+
+            class MyWarning(UserWarning):
+
+                def __init__(self, p1, p2):
+                    self.p1 = p1
+                    self.p2 = p2
+                    self.args = ()
+
+            def test_func(request):
+                warnings.warn(MyWarning("foo", 1))
+        """
+        )
+        testdir.syspathinsert()
+        result = testdir.runpytest(n)
+        result.stdout.fnmatch_lines(["*MyWarning*", "*1 passed, 1 warnings*"])
+
     def test_logfinish_hook(self, testdir):
         """Ensure the pytest_runtest_logfinish hook is being properly handled"""
         from _pytest import hookspec
diff --git a/xdist/workermanage.py b/xdist/workermanage.py
index 5bc1f39..9eb6418 100644
--- a/xdist/workermanage.py
+++ b/xdist/workermanage.py
@@ -429,7 +429,7 @@ def unserialize_warning_message(data):
         try:
             message = cls(*data["message_args"])
         except TypeError:
-            message_text = "{mod}.{class}: {msg}".format(
+            message_text = "{mod}.{cls}: {msg}".format(
                 mod=data["message_module"],
                 cls=data["message_class_name"],
                 msg=data["message_str"],