diff --git a/javatests/google/registry/flows/domain/DomainTransferApproveFlowTest.java b/javatests/google/registry/flows/domain/DomainTransferApproveFlowTest.java
index dc3df37c2..087273f67 100644
--- a/javatests/google/registry/flows/domain/DomainTransferApproveFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainTransferApproveFlowTest.java
@@ -31,8 +31,8 @@ import static google.registry.testing.DatastoreHelper.getPollMessages;
 import static google.registry.testing.DatastoreHelper.loadRegistrar;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.HistoryEntrySubject.assertAboutHistoryEntries;
-import static google.registry.testing.JUnitBackports.assertThrows;
 import static google.registry.testing.JUnitBackports.expectThrows;
 import static google.registry.util.DateTimeUtils.START_OF_TIME;
 import static org.joda.money.CurrencyUnit.USD;
@@ -44,6 +44,7 @@ import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.ImmutableSortedMap;
 import com.google.common.collect.Ordering;
 import com.googlecode.objectify.Key;
+import google.registry.flows.EppException;
 import google.registry.flows.ResourceFlowUtils.BadAuthInfoForResourceException;
 import google.registry.flows.ResourceFlowUtils.ResourceDoesNotExistException;
 import google.registry.flows.ResourceFlowUtils.ResourceNotOwnedException;
@@ -107,15 +108,19 @@ public class DomainTransferApproveFlowTest
   }
 
   private void assertTransferApproved(DomainResource domain, TransferData oldTransferData) {
-    assertAboutDomains().that(domain)
-        .hasCurrentSponsorClientId("NewRegistrar").and()
-        .hasLastTransferTime(clock.nowUtc()).and()
+    assertAboutDomains()
+        .that(domain)
+        .hasCurrentSponsorClientId("NewRegistrar")
+        .and()
+        .hasLastTransferTime(clock.nowUtc())
+        .and()
         .doesNotHaveStatusValue(StatusValue.PENDING_TRANSFER);
     // The domain TransferData should reflect the approved transfer as we expect, with
     // all the speculative server-approve fields nulled out.
     assertThat(domain.getTransferData())
         .isEqualTo(
-            oldTransferData.copyConstantFieldsToBuilder()
+            oldTransferData
+                .copyConstantFieldsToBuilder()
                 .setTransferStatus(TransferStatus.CLIENT_APPROVED)
                 .setPendingTransferExpirationTime(clock.nowUtc())
                 .setTransferredRegistrationExpirationTime(domain.getRegistrationExpirationTime())
@@ -139,12 +144,10 @@ public class DomainTransferApproveFlowTest
       String expectedXmlFilename,
       DateTime expectedExpirationTime,
       int expectedYearsToCharge,
-      BillingEvent.Cancellation.Builder... expectedCancellationBillingEvents) throws Exception {
+      BillingEvent.Cancellation.Builder... expectedCancellationBillingEvents)
+      throws Exception {
     runSuccessfulFlowWithAssertions(
-        tld,
-        commandFilename,
-        expectedXmlFilename,
-        expectedExpirationTime);
+        tld, commandFilename, expectedXmlFilename, expectedExpirationTime);
     assertHistoryEntriesContainBillingEventsAndGracePeriods(
         tld, expectedYearsToCharge, expectedCancellationBillingEvents);
   }
@@ -153,7 +156,8 @@ public class DomainTransferApproveFlowTest
       String tld,
       String commandFilename,
       String expectedXmlFilename,
-      DateTime expectedExpirationTime) throws Exception {
+      DateTime expectedExpirationTime)
+      throws Exception {
     setEppLoader(commandFilename);
     Registry registry = Registry.get(tld);
     domain = reloadResourceByForeignKey();
@@ -179,8 +183,7 @@ public class DomainTransferApproveFlowTest
             DOMAIN_CREATE, DOMAIN_TRANSFER_REQUEST, DOMAIN_TRANSFER_APPROVE);
     final HistoryEntry historyEntryTransferApproved =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_APPROVE);
-    assertAboutHistoryEntries().that(historyEntryTransferApproved)
-        .hasOtherClientId("NewRegistrar");
+    assertAboutHistoryEntries().that(historyEntryTransferApproved).hasOtherClientId("NewRegistrar");
     assertTransferApproved(domain, originalTransferData);
     assertAboutDomains().that(domain).hasRegistrationExpirationTime(expectedExpirationTime);
     assertThat(ofy().load().key(domain.getAutorenewBillingEvent()).now().getEventTime())
@@ -197,11 +200,12 @@ public class DomainTransferApproveFlowTest
 
     PollMessage gainingTransferPollMessage =
         getOnlyPollMessage(domain, "NewRegistrar", clock.nowUtc(), PollMessage.OneTime.class);
-    PollMessage gainingAutorenewPollMessage = getOnlyPollMessage(
-        domain,
-        "NewRegistrar",
-        domain.getRegistrationExpirationTime(),
-        PollMessage.Autorenew.class);
+    PollMessage gainingAutorenewPollMessage =
+        getOnlyPollMessage(
+            domain,
+            "NewRegistrar",
+            domain.getRegistrationExpirationTime(),
+            PollMessage.Autorenew.class);
     assertThat(gainingTransferPollMessage.getEventTime()).isEqualTo(clock.nowUtc());
     assertThat(gainingAutorenewPollMessage.getEventTime())
         .isEqualTo(domain.getRegistrationExpirationTime());
@@ -228,8 +232,10 @@ public class DomainTransferApproveFlowTest
 
     // After the expected grace time, the grace period should be gone.
     assertThat(
-        domain.cloneProjectedAtTime(clock.nowUtc().plus(registry.getTransferGracePeriodLength()))
-            .getGracePeriods()).isEmpty();
+            domain
+                .cloneProjectedAtTime(clock.nowUtc().plus(registry.getTransferGracePeriodLength()))
+                .getGracePeriods())
+        .isEmpty();
   }
 
   private void assertHistoryEntriesContainBillingEventsAndGracePeriods(
@@ -285,8 +291,7 @@ public class DomainTransferApproveFlowTest
   }
 
   private void assertHistoryEntriesDoNotContainTransferBillingEventsOrGracePeriods(
-      BillingEvent.Cancellation.Builder... expectedCancellationBillingEvents)
-      throws Exception {
+      BillingEvent.Cancellation.Builder... expectedCancellationBillingEvents) throws Exception {
     domain = reloadResourceByForeignKey();
     final HistoryEntry historyEntryTransferApproved =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_APPROVE);
@@ -354,9 +359,7 @@ public class DomainTransferApproveFlowTest
             .build());
     setupDomainWithPendingTransfer("example", "net");
     doSuccessfulTest(
-        "net",
-        "domain_transfer_approve_net.xml",
-        "domain_transfer_approve_response_net.xml");
+        "net", "domain_transfer_approve_net.xml", "domain_transfer_approve_response_net.xml");
   }
 
   @Test
@@ -379,9 +382,7 @@ public class DomainTransferApproveFlowTest
   public void testSuccess_autorenewBeforeTransfer() throws Exception {
     domain = reloadResourceByForeignKey();
     DateTime oldExpirationTime = clock.nowUtc().minusDays(1);
-    persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(oldExpirationTime)
-        .build());
+    persistResource(domain.asBuilder().setRegistrationExpirationTime(oldExpirationTime).build());
     // The autorenew should be subsumed into the transfer resulting in 1 year of renewal in total.
     clock.advanceOneMilli();
     doSuccessfulTest(
@@ -395,7 +396,7 @@ public class DomainTransferApproveFlowTest
             .setReason(Reason.RENEW)
             .setTargetId("example.tld")
             .setClientId("TheRegistrar")
-            .setEventTime(clock.nowUtc())  // The cancellation happens at the moment of transfer.
+            .setEventTime(clock.nowUtc()) // The cancellation happens at the moment of transfer.
             .setBillingTime(
                 oldExpirationTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()))
             .setRecurringEventKey(domain.getAutorenewBillingEvent()));
@@ -404,86 +405,109 @@ public class DomainTransferApproveFlowTest
   @Test
   public void testFailure_badContactPassword() throws Exception {
     // Change the contact's password so it does not match the password in the file.
-    contact = persistResource(
-        contact.asBuilder()
-            .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_approve_contact_authinfo.xml"));
+    contact =
+        persistResource(
+            contact
+                .asBuilder()
+                .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_approve_contact_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badDomainPassword() throws Exception {
     // Change the domain's password so it does not match the password in the file.
-    persistResource(domain.asBuilder()
-        .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
-        .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_approve_domain_authinfo.xml"));
+    persistResource(
+        domain
+            .asBuilder()
+            .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
+            .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_approve_domain_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_neverBeenTransferred() throws Exception {
     changeTransferStatus(null);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_clientApproved() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientRejected() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_REJECTED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientCancelled() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverApproved() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverCancelled() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_gainingClient() throws Exception {
     setClientIdForFlow("NewRegistrar");
-    assertThrows(
-        ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_unrelatedClient() throws Exception {
     setClientIdForFlow("ClientZ");
-    assertThrows(
-        ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    EppException thrown =
+        expectThrows(
+            ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_approve.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_deletedDomain() throws Exception {
-    persistResource(
-        domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
+    persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
     ResourceDoesNotExistException thrown =
         expectThrows(
             ResourceDoesNotExistException.class,
@@ -505,11 +529,13 @@ public class DomainTransferApproveFlowTest
   public void testFailure_notAuthorizedForTld() throws Exception {
     persistResource(
         loadRegistrar("TheRegistrar").asBuilder().setAllowedTlds(ImmutableSet.of()).build());
-    assertThrows(
-        NotAuthorizedForTldException.class,
-        () ->
-            doSuccessfulTest(
-                "tld", "domain_transfer_approve.xml", "domain_transfer_approve_response.xml"));
+    EppException thrown =
+        expectThrows(
+            NotAuthorizedForTldException.class,
+            () ->
+                doSuccessfulTest(
+                    "tld", "domain_transfer_approve.xml", "domain_transfer_approve_response.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -559,8 +585,7 @@ public class DomainTransferApproveFlowTest
     clock.advanceOneMilli();
     setUpGracePeriodDurations();
     DomainTransactionRecord previousSuccessRecord =
-        DomainTransactionRecord.create(
-            "tld", clock.nowUtc().plusDays(1), TRANSFER_SUCCESSFUL, 1);
+        DomainTransactionRecord.create("tld", clock.nowUtc().plusDays(1), TRANSFER_SUCCESSFUL, 1);
     // We only want to cancel TRANSFER_SUCCESSFUL records
     DomainTransactionRecord notCancellableRecord =
         DomainTransactionRecord.create("tld", clock.nowUtc().plusDays(1), NET_ADDS_4_YR, 5);
diff --git a/javatests/google/registry/flows/domain/DomainTransferCancelFlowTest.java b/javatests/google/registry/flows/domain/DomainTransferCancelFlowTest.java
index 54bdcbc50..422e5662f 100644
--- a/javatests/google/registry/flows/domain/DomainTransferCancelFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainTransferCancelFlowTest.java
@@ -28,13 +28,14 @@ import static google.registry.testing.DatastoreHelper.getPollMessages;
 import static google.registry.testing.DatastoreHelper.loadRegistrar;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.HistoryEntrySubject.assertAboutHistoryEntries;
-import static google.registry.testing.JUnitBackports.assertThrows;
 import static google.registry.testing.JUnitBackports.expectThrows;
 import static google.registry.util.DateTimeUtils.END_OF_TIME;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableSet;
+import google.registry.flows.EppException;
 import google.registry.flows.ResourceFlowUtils.BadAuthInfoForResourceException;
 import google.registry.flows.ResourceFlowUtils.ResourceDoesNotExistException;
 import google.registry.flows.domain.DomainFlowUtils.NotAuthorizedForTldException;
@@ -124,8 +125,10 @@ public class DomainTransferCancelFlowTest
     // Transfer should have been cancelled. Verify correct fields were set.
     domain = reloadResourceByForeignKey();
     assertTransferFailed(domain, TransferStatus.CLIENT_CANCELLED, originalTransferData);
-    assertAboutDomains().that(domain)
-        .hasRegistrationExpirationTime(originalExpirationTime).and()
+    assertAboutDomains()
+        .that(domain)
+        .hasRegistrationExpirationTime(originalExpirationTime)
+        .and()
         .hasLastTransferTimeNotEqualTo(clock.nowUtc());
     assertAboutDomains()
         .that(domain)
@@ -133,14 +136,16 @@ public class DomainTransferCancelFlowTest
             DOMAIN_CREATE, DOMAIN_TRANSFER_REQUEST, DOMAIN_TRANSFER_CANCEL);
     final HistoryEntry historyEntryTransferCancel =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_CANCEL);
-    assertAboutHistoryEntries().that(historyEntryTransferCancel).hasClientId("NewRegistrar")
-        .and().hasOtherClientId("TheRegistrar");
+    assertAboutHistoryEntries()
+        .that(historyEntryTransferCancel)
+        .hasClientId("NewRegistrar")
+        .and()
+        .hasOtherClientId("TheRegistrar");
     // The only billing event left should be the original autorenew event, now reopened.
     assertBillingEvents(
         getLosingClientAutorenewEvent().asBuilder().setRecurrenceEndTime(END_OF_TIME).build());
     // The poll message (in the future) to the gaining registrar for implicit ack should be gone.
-    assertThat(getPollMessages("NewRegistrar", clock.nowUtc().plusMonths(1)))
-        .isEmpty();
+    assertThat(getPollMessages("NewRegistrar", clock.nowUtc().plusMonths(1))).isEmpty();
     // The poll message in the future to the losing registrar should be gone too, but there should
     // be two at the current time to the losing registrar - one for the original autorenew event,
     // and another for the transfer being cancelled.
@@ -157,14 +162,16 @@ public class DomainTransferCancelFlowTest
         new PollMessage.OneTime.Builder()
             .setClientId("TheRegistrar")
             .setEventTime(clock.nowUtc())
-            .setResponseData(ImmutableList.of(new DomainTransferResponse.Builder()
-                .setFullyQualifiedDomainName(getUniqueIdFromCommand())
-                .setTransferStatus(TransferStatus.CLIENT_CANCELLED)
-                .setTransferRequestTime(TRANSFER_REQUEST_TIME)
-                .setGainingClientId("NewRegistrar")
-                .setLosingClientId("TheRegistrar")
-                .setPendingTransferExpirationTime(clock.nowUtc())
-                .build()))
+            .setResponseData(
+                ImmutableList.of(
+                    new DomainTransferResponse.Builder()
+                        .setFullyQualifiedDomainName(getUniqueIdFromCommand())
+                        .setTransferStatus(TransferStatus.CLIENT_CANCELLED)
+                        .setTransferRequestTime(TRANSFER_REQUEST_TIME)
+                        .setGainingClientId("NewRegistrar")
+                        .setLosingClientId("TheRegistrar")
+                        .setPendingTransferExpirationTime(clock.nowUtc())
+                        .build()))
             .setMsg("Transfer cancelled.")
             .setParent(getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_CANCEL))
             .build());
@@ -196,99 +203,124 @@ public class DomainTransferCancelFlowTest
 
   @Test
   public void testSuccess_domainAuthInfo() throws Exception {
-    doSuccessfulTest("domain_transfer_cancel_domain_authinfo.xml",
-        "domain_transfer_cancel_response.xml");
+    doSuccessfulTest(
+        "domain_transfer_cancel_domain_authinfo.xml", "domain_transfer_cancel_response.xml");
   }
 
   @Test
   public void testSuccess_contactAuthInfo() throws Exception {
-    doSuccessfulTest("domain_transfer_cancel_contact_authinfo.xml",
-        "domain_transfer_cancel_response.xml");
+    doSuccessfulTest(
+        "domain_transfer_cancel_contact_authinfo.xml", "domain_transfer_cancel_response.xml");
   }
 
   @Test
   public void testFailure_badContactPassword() throws Exception {
     // Change the contact's password so it does not match the password in the file.
-    contact = persistResource(
-        contact.asBuilder()
-            .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_cancel_contact_authinfo.xml"));
+    contact =
+        persistResource(
+            contact
+                .asBuilder()
+                .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_cancel_contact_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badDomainPassword() throws Exception {
     // Change the domain's password so it does not match the password in the file.
-    domain = persistResource(domain.asBuilder()
-        .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
-        .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_cancel_domain_authinfo.xml"));
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_cancel_domain_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_neverBeenTransferred() throws Exception {
     changeTransferStatus(null);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_clientApproved() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientRejected() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_REJECTED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientCancelled() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverApproved() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverCancelled() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_sponsoringClient() throws Exception {
     setClientIdForFlow("TheRegistrar");
-    assertThrows(
-        NotTransferInitiatorException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotTransferInitiatorException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_unrelatedClient() throws Exception {
     setClientIdForFlow("ClientZ");
-    assertThrows(
-        NotTransferInitiatorException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    EppException thrown =
+        expectThrows(
+            NotTransferInitiatorException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_deletedDomain() throws Exception {
-    domain = persistResource(
-        domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
+    domain =
+        persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
     ResourceDoesNotExistException thrown =
         expectThrows(
             ResourceDoesNotExistException.class, () -> doFailingTest("domain_transfer_cancel.xml"));
@@ -308,10 +340,13 @@ public class DomainTransferCancelFlowTest
   public void testFailure_notAuthorizedForTld() throws Exception {
     persistResource(
         loadRegistrar("NewRegistrar").asBuilder().setAllowedTlds(ImmutableSet.of()).build());
-    assertThrows(
-        NotAuthorizedForTldException.class,
-        () ->
-            doSuccessfulTest("domain_transfer_cancel.xml", "domain_transfer_cancel_response.xml"));
+    EppException thrown =
+        expectThrows(
+            NotAuthorizedForTldException.class,
+            () ->
+                doSuccessfulTest(
+                    "domain_transfer_cancel.xml", "domain_transfer_cancel_response.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
diff --git a/javatests/google/registry/flows/domain/DomainTransferQueryFlowTest.java b/javatests/google/registry/flows/domain/DomainTransferQueryFlowTest.java
index 36c8471e4..0dadbff74 100644
--- a/javatests/google/registry/flows/domain/DomainTransferQueryFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainTransferQueryFlowTest.java
@@ -20,9 +20,10 @@ import static google.registry.testing.DatastoreHelper.deleteResource;
 import static google.registry.testing.DatastoreHelper.getPollMessages;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
-import static google.registry.testing.JUnitBackports.assertThrows;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.JUnitBackports.expectThrows;
 
+import google.registry.flows.EppException;
 import google.registry.flows.ResourceFlowUtils.BadAuthInfoForResourceException;
 import google.registry.flows.ResourceFlowUtils.ResourceDoesNotExistException;
 import google.registry.flows.exceptions.NoTransferHistoryToQueryException;
@@ -47,18 +48,18 @@ public class DomainTransferQueryFlowTest
     setupDomainWithPendingTransfer("example", "tld");
   }
 
-  private void doSuccessfulTest(
-      String commandFilename,
-      String expectedXmlFilename) throws Exception {
+  private void doSuccessfulTest(String commandFilename, String expectedXmlFilename)
+      throws Exception {
     setEppInput(commandFilename);
     // Replace the ROID in the xml file with the one generated in our test.
     eppLoader.replaceAll("JD1234-REP", contact.getRepoId());
     // Setup done; run the test.
     assertTransactionalFlow(false);
     runFlowAssertResponse(loadFile(expectedXmlFilename));
-    assertAboutDomains().that(domain).hasOneHistoryEntryEachOfTypes(
-        HistoryEntry.Type.DOMAIN_CREATE,
-        HistoryEntry.Type.DOMAIN_TRANSFER_REQUEST);
+    assertAboutDomains()
+        .that(domain)
+        .hasOneHistoryEntryEachOfTypes(
+            HistoryEntry.Type.DOMAIN_CREATE, HistoryEntry.Type.DOMAIN_TRANSFER_REQUEST);
     assertBillingEvents(
         getBillingEventForImplicitTransfer(),
         getGainingClientAutorenewEvent(),
@@ -79,139 +80,142 @@ public class DomainTransferQueryFlowTest
 
   @Test
   public void testSuccess() throws Exception {
-    doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response.xml");
+    doSuccessfulTest("domain_transfer_query.xml", "domain_transfer_query_response.xml");
   }
 
   @Test
   public void testSuccess_sponsoringClient() throws Exception {
     setClientIdForFlow("TheRegistrar");
-    doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response.xml");
+    doSuccessfulTest("domain_transfer_query.xml", "domain_transfer_query_response.xml");
   }
 
   @Test
   public void testSuccess_domainAuthInfo() throws Exception {
     setClientIdForFlow("ClientZ");
     doSuccessfulTest(
-        "domain_transfer_query_domain_authinfo.xml",
-        "domain_transfer_query_response.xml");
+        "domain_transfer_query_domain_authinfo.xml", "domain_transfer_query_response.xml");
   }
 
   @Test
   public void testSuccess_contactAuthInfo() throws Exception {
     setClientIdForFlow("ClientZ");
     doSuccessfulTest(
-        "domain_transfer_query_contact_authinfo.xml",
-        "domain_transfer_query_response.xml");
+        "domain_transfer_query_contact_authinfo.xml", "domain_transfer_query_response.xml");
   }
 
   @Test
   public void testSuccess_clientApproved() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_APPROVED);
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_client_approved.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_client_approved.xml");
   }
 
- @Test
+  @Test
   public void testSuccess_clientRejected() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_REJECTED);
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_client_rejected.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_client_rejected.xml");
   }
 
- @Test
+  @Test
   public void testSuccess_clientCancelled() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_CANCELLED);
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_client_cancelled.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_client_cancelled.xml");
   }
 
   @Test
   public void testSuccess_serverApproved() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_APPROVED);
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_server_approved.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_server_approved.xml");
   }
 
   @Test
   public void testSuccess_serverCancelled() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_CANCELLED);
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_server_cancelled.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_server_cancelled.xml");
   }
 
   @Test
   public void testSuccess_tenYears() throws Exception {
     // Extend registration by 9 years here; with the extra 1 year from the transfer, we should
     // hit the 10-year capping.
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(domain.getRegistrationExpirationTime().plusYears(9))
-        .build());
-    doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_10_years.xml");
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setRegistrationExpirationTime(domain.getRegistrationExpirationTime().plusYears(9))
+                .build());
+    doSuccessfulTest("domain_transfer_query.xml", "domain_transfer_query_response_10_years.xml");
   }
 
   @Test
   public void testFailure_pendingDeleteDomain() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_CANCELLED);
-    domain = persistResource(
-        domain.asBuilder().setDeletionTime(clock.nowUtc().plusDays(1)).build());
+    domain =
+        persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().plusDays(1)).build());
     doSuccessfulTest(
-        "domain_transfer_query.xml",
-        "domain_transfer_query_response_server_cancelled.xml");
+        "domain_transfer_query.xml", "domain_transfer_query_response_server_cancelled.xml");
   }
 
   @Test
   public void testFailure_badContactPassword() throws Exception {
     // Change the contact's password so it does not match the password in the file.
-    contact = persistResource(
-        contact.asBuilder()
-            .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_query_contact_authinfo.xml"));
+    contact =
+        persistResource(
+            contact
+                .asBuilder()
+                .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_query_contact_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badDomainPassword() throws Exception {
     // Change the domain's password so it does not match the password in the file.
-    domain = persistResource(domain.asBuilder()
-        .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
-        .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_query_domain_authinfo.xml"));
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_query_domain_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_neverBeenTransferred() throws Exception {
     changeTransferStatus(null);
-    assertThrows(
-        NoTransferHistoryToQueryException.class, () -> doFailingTest("domain_transfer_query.xml"));
+    EppException thrown =
+        expectThrows(
+            NoTransferHistoryToQueryException.class,
+            () -> doFailingTest("domain_transfer_query.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_unrelatedClient() throws Exception {
     setClientIdForFlow("ClientZ");
-    assertThrows(
-        NotAuthorizedToViewTransferException.class,
-        () -> doFailingTest("domain_transfer_query.xml"));
+    EppException thrown =
+        expectThrows(
+            NotAuthorizedToViewTransferException.class,
+            () -> doFailingTest("domain_transfer_query.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_deletedDomain() throws Exception {
-    domain = persistResource(
-            domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
+    domain =
+        persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
     ResourceDoesNotExistException thrown =
         expectThrows(
             ResourceDoesNotExistException.class, () -> doFailingTest("domain_transfer_query.xml"));
diff --git a/javatests/google/registry/flows/domain/DomainTransferRejectFlowTest.java b/javatests/google/registry/flows/domain/DomainTransferRejectFlowTest.java
index 9287f430a..3ded11f77 100644
--- a/javatests/google/registry/flows/domain/DomainTransferRejectFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainTransferRejectFlowTest.java
@@ -30,12 +30,13 @@ import static google.registry.testing.DatastoreHelper.getPollMessages;
 import static google.registry.testing.DatastoreHelper.loadRegistrar;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.HistoryEntrySubject.assertAboutHistoryEntries;
-import static google.registry.testing.JUnitBackports.assertThrows;
 import static google.registry.testing.JUnitBackports.expectThrows;
 import static google.registry.util.DateTimeUtils.END_OF_TIME;
 
 import com.google.common.collect.ImmutableSet;
+import google.registry.flows.EppException;
 import google.registry.flows.ResourceFlowUtils.BadAuthInfoForResourceException;
 import google.registry.flows.ResourceFlowUtils.ResourceDoesNotExistException;
 import google.registry.flows.ResourceFlowUtils.ResourceNotOwnedException;
@@ -83,10 +84,8 @@ public class DomainTransferRejectFlowTest
         getGainingClientAutorenewEvent(),
         getLosingClientAutorenewEvent());
     // Look in the future and make sure the poll messages for implicit ack are there.
-    assertThat(getPollMessages("NewRegistrar", clock.nowUtc().plusMonths(1)))
-        .hasSize(1);
-    assertThat(getPollMessages("TheRegistrar", clock.nowUtc().plusMonths(1)))
-        .hasSize(1);
+    assertThat(getPollMessages("NewRegistrar", clock.nowUtc().plusMonths(1))).hasSize(1);
+    assertThat(getPollMessages("TheRegistrar", clock.nowUtc().plusMonths(1))).hasSize(1);
     // Setup done; run the test.
     assertTransactionalFlow(true);
     DateTime originalExpirationTime = domain.getRegistrationExpirationTime();
@@ -96,22 +95,22 @@ public class DomainTransferRejectFlowTest
     // Transfer should have been rejected. Verify correct fields were set.
     domain = reloadResourceByForeignKey();
     assertTransferFailed(domain, TransferStatus.CLIENT_REJECTED, originalTransferData);
-    assertAboutDomains().that(domain)
-        .hasRegistrationExpirationTime(originalExpirationTime).and()
-        .hasLastTransferTimeNotEqualTo(clock.nowUtc()).and()
+    assertAboutDomains()
+        .that(domain)
+        .hasRegistrationExpirationTime(originalExpirationTime)
+        .and()
+        .hasLastTransferTimeNotEqualTo(clock.nowUtc())
+        .and()
         .hasOneHistoryEntryEachOfTypes(
             DOMAIN_CREATE, DOMAIN_TRANSFER_REQUEST, DOMAIN_TRANSFER_REJECT);
     final HistoryEntry historyEntryTransferRejected =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_REJECT);
-    assertAboutHistoryEntries()
-        .that(historyEntryTransferRejected)
-        .hasOtherClientId("NewRegistrar");
+    assertAboutHistoryEntries().that(historyEntryTransferRejected).hasOtherClientId("NewRegistrar");
     // The only billing event left should be the original autorenew event, now reopened.
     assertBillingEvents(
         getLosingClientAutorenewEvent().asBuilder().setRecurrenceEndTime(END_OF_TIME).build());
     // The poll message (in the future) to the losing registrar for implicit ack should be gone.
-    assertThat(getPollMessages("TheRegistrar", clock.nowUtc().plusMonths(1)))
-        .isEmpty();
+    assertThat(getPollMessages("TheRegistrar", clock.nowUtc().plusMonths(1))).isEmpty();
     // The poll message in the future to the gaining registrar should be gone too, but there
     // should be one at the current time to the gaining registrar.
     PollMessage gainingPollMessage = getOnlyPollMessage("NewRegistrar");
@@ -162,24 +161,27 @@ public class DomainTransferRejectFlowTest
 
   @Test
   public void testSuccess_domainAuthInfo() throws Exception {
-    doSuccessfulTest("domain_transfer_reject_domain_authinfo.xml",
-        "domain_transfer_reject_response.xml");
+    doSuccessfulTest(
+        "domain_transfer_reject_domain_authinfo.xml", "domain_transfer_reject_response.xml");
   }
 
   @Test
   public void testSuccess_contactAuthInfo() throws Exception {
-    doSuccessfulTest("domain_transfer_reject_contact_authinfo.xml",
-        "domain_transfer_reject_response.xml");
+    doSuccessfulTest(
+        "domain_transfer_reject_contact_authinfo.xml", "domain_transfer_reject_response.xml");
   }
 
   @Test
   public void testFailure_notAuthorizedForTld() throws Exception {
     persistResource(
         loadRegistrar("TheRegistrar").asBuilder().setAllowedTlds(ImmutableSet.of()).build());
-    assertThrows(
-        NotAuthorizedForTldException.class,
-        () ->
-            doSuccessfulTest("domain_transfer_reject.xml", "domain_transfer_reject_response.xml"));
+    EppException thrown =
+        expectThrows(
+            NotAuthorizedForTldException.class,
+            () ->
+                doSuccessfulTest(
+                    "domain_transfer_reject.xml", "domain_transfer_reject_response.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -193,87 +195,111 @@ public class DomainTransferRejectFlowTest
   @Test
   public void testFailure_badContactPassword() throws Exception {
     // Change the contact's password so it does not match the password in the file.
-    contact = persistResource(
-        contact.asBuilder()
-            .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_reject_contact_authinfo.xml"));
+    contact =
+        persistResource(
+            contact
+                .asBuilder()
+                .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_reject_contact_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badDomainPassword() throws Exception {
     // Change the domain's password so it does not match the password in the file.
-    domain = persistResource(
-        domain.asBuilder()
-            .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_reject_domain_authinfo.xml"));
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_reject_domain_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_neverBeenTransferred() throws Exception {
     changeTransferStatus(null);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_clientApproved() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientRejected() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_REJECTED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
- @Test
+  @Test
   public void testFailure_clientCancelled() throws Exception {
     changeTransferStatus(TransferStatus.CLIENT_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverApproved() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_APPROVED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverCancelled() throws Exception {
     changeTransferStatus(TransferStatus.SERVER_CANCELLED);
-    assertThrows(
-        NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            NotPendingTransferException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_gainingClient() throws Exception {
     setClientIdForFlow("NewRegistrar");
-    assertThrows(
-        ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_unrelatedClient() throws Exception {
     setClientIdForFlow("ClientZ");
-    assertThrows(
-        ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    EppException thrown =
+        expectThrows(
+            ResourceNotOwnedException.class, () -> doFailingTest("domain_transfer_reject.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_deletedDomain() throws Exception {
-    domain = persistResource(
-        domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
+    domain =
+        persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
     ResourceDoesNotExistException thrown =
         expectThrows(
             ResourceDoesNotExistException.class, () -> doFailingTest("domain_transfer_reject.xml"));
@@ -322,8 +348,7 @@ public class DomainTransferRejectFlowTest
   public void testIcannTransactionRecord_cancelsPreviousRecords() throws Exception {
     setUpGracePeriodDurations();
     DomainTransactionRecord previousSuccessRecord =
-        DomainTransactionRecord.create(
-            "tld", clock.nowUtc().plusDays(1), TRANSFER_SUCCESSFUL, 1);
+        DomainTransactionRecord.create("tld", clock.nowUtc().plusDays(1), TRANSFER_SUCCESSFUL, 1);
     // We only want to cancel TRANSFER_SUCCESSFUL records
     DomainTransactionRecord notCancellableRecord =
         DomainTransactionRecord.create("tld", clock.nowUtc().plusDays(1), NET_RENEWS_3_YR, 5);
diff --git a/javatests/google/registry/flows/domain/DomainTransferRequestFlowTest.java b/javatests/google/registry/flows/domain/DomainTransferRequestFlowTest.java
index 8f60fd9f2..7499807d0 100644
--- a/javatests/google/registry/flows/domain/DomainTransferRequestFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainTransferRequestFlowTest.java
@@ -31,6 +31,7 @@ import static google.registry.testing.DatastoreHelper.loadRegistrar;
 import static google.registry.testing.DatastoreHelper.persistActiveContact;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.HistoryEntrySubject.assertAboutHistoryEntries;
 import static google.registry.testing.HostResourceSubject.assertAboutHosts;
 import static google.registry.testing.JUnitBackports.assertThrows;
@@ -49,6 +50,7 @@ import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.ImmutableSortedMap;
 import com.google.common.collect.Iterables;
 import com.googlecode.objectify.Key;
+import google.registry.flows.EppException;
 import google.registry.flows.EppRequestSource;
 import google.registry.flows.ResourceFlowUtils.BadAuthInfoForResourceException;
 import google.registry.flows.ResourceFlowUtils.ResourceDoesNotExistException;
@@ -136,9 +138,12 @@ public class DomainTransferRequestFlowTest
       DomainResource domain,
       DateTime automaticTransferTime,
       Period expectedPeriod,
-      DateTime expectedExpirationTime) throws Exception {
-    assertAboutDomains().that(domain)
-        .hasCurrentSponsorClientId("TheRegistrar").and()
+      DateTime expectedExpirationTime)
+      throws Exception {
+    assertAboutDomains()
+        .that(domain)
+        .hasCurrentSponsorClientId("TheRegistrar")
+        .and()
         .hasStatusValue(StatusValue.PENDING_TRANSFER);
     Trid expectedTrid =
         Trid.create(
@@ -149,7 +154,9 @@ public class DomainTransferRequestFlowTest
             // Compare against only the following fields by rebuilding the existing TransferData.
             // Equivalent to assertThat(transferData.getGainingClientId()).isEqualTo("NewReg")
             // and similar individual assertions, but produces a nicer error message this way.
-            domain.getTransferData().asBuilder()
+            domain
+                .getTransferData()
+                .asBuilder()
                 .setGainingClientId("NewRegistrar")
                 .setLosingClientId("TheRegistrar")
                 .setTransferRequestTrid(expectedTrid)
@@ -166,9 +173,12 @@ public class DomainTransferRequestFlowTest
   private void assertTransferApproved(
       DomainResource domain, DateTime automaticTransferTime, Period expectedPeriod)
       throws Exception {
-    assertAboutDomains().that(domain)
-        .hasCurrentSponsorClientId("NewRegistrar").and()
-        .hasLastTransferTime(automaticTransferTime).and()
+    assertAboutDomains()
+        .that(domain)
+        .hasCurrentSponsorClientId("NewRegistrar")
+        .and()
+        .hasLastTransferTime(automaticTransferTime)
+        .and()
         .doesNotHaveStatusValue(StatusValue.PENDING_TRANSFER);
     Trid expectedTrid =
         Trid.create(
@@ -190,7 +200,7 @@ public class DomainTransferRequestFlowTest
   }
 
   /**
-   * Runs a successful test.  The extraExpectedBillingEvents parameter consists of cancellation
+   * Runs a successful test. The extraExpectedBillingEvents parameter consists of cancellation
    * billing event builders that have had all of their attributes set except for the parent history
    * entry, which is filled in during the execution of this method.
    */
@@ -200,7 +210,8 @@ public class DomainTransferRequestFlowTest
       DateTime expectedExpirationTime,
       Map<String, String> substitutions,
       Optional<Money> transferCost,
-      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents) throws Exception {
+      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents)
+      throws Exception {
     setEppInput(commandFilename, substitutions);
     ImmutableSet<GracePeriod> originalGracePeriods = domain.getGracePeriods();
     // Replace the ROID in the xml file with the one generated in our test.
@@ -216,7 +227,8 @@ public class DomainTransferRequestFlowTest
     // Transfer should have been requested.
     domain = reloadResourceByForeignKey();
     // Verify that HistoryEntry was created.
-    assertAboutDomains().that(domain)
+    assertAboutDomains()
+        .that(domain)
         .hasOneHistoryEntryEachOfTypes(DOMAIN_CREATE, DOMAIN_TRANSFER_REQUEST);
     final HistoryEntry historyEntryTransferRequest =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_REQUEST);
@@ -285,13 +297,12 @@ public class DomainTransferRequestFlowTest
     // request by definition takes place on day 1, so we need to edit the times in the
     // autorenew events from the base test case.
     BillingEvent.Recurring losingClientAutorenew =
-        getLosingClientAutorenewEvent().asBuilder()
+        getLosingClientAutorenewEvent()
+            .asBuilder()
             .setRecurrenceEndTime(implicitTransferTime)
             .build();
     BillingEvent.Recurring gainingClientAutorenew =
-        getGainingClientAutorenewEvent().asBuilder()
-            .setEventTime(expectedExpirationTime)
-            .build();
+        getGainingClientAutorenewEvent().asBuilder().setEventTime(expectedExpirationTime).build();
     // Construct extra billing events expected by the specific test.
     Set<BillingEvent> extraBillingEvents =
         Stream.of(extraExpectedBillingEvents)
@@ -364,10 +375,10 @@ public class DomainTransferRequestFlowTest
     // Two poll messages on the gaining registrar's side at the expected expiration time: a
     // (OneTime) transfer approved message, and an Autorenew poll message.
     assertThat(getPollMessages("NewRegistrar", expectedExpirationTime)).hasSize(2);
-    PollMessage transferApprovedPollMessage = getOnlyPollMessage(
-        "NewRegistrar", implicitTransferTime, PollMessage.OneTime.class);
-    PollMessage autorenewPollMessage = getOnlyPollMessage(
-        "NewRegistrar", expectedExpirationTime, PollMessage.Autorenew.class);
+    PollMessage transferApprovedPollMessage =
+        getOnlyPollMessage("NewRegistrar", implicitTransferTime, PollMessage.OneTime.class);
+    PollMessage autorenewPollMessage =
+        getOnlyPollMessage("NewRegistrar", expectedExpirationTime, PollMessage.Autorenew.class);
     assertThat(transferApprovedPollMessage.getEventTime()).isEqualTo(implicitTransferTime);
     assertThat(autorenewPollMessage.getEventTime()).isEqualTo(expectedExpirationTime);
     assertThat(
@@ -431,15 +442,14 @@ public class DomainTransferRequestFlowTest
     // OneTime messages to gaining and losing registrars plus the gaining client autorenew.
     assertPollMessagesEqual(
         Iterables.filter(
-            ofy().load()
+            ofy()
+                .load()
                 // Use toArray() to coerce the type to something keys() will accept.
-                .keys(domain.getTransferData().getServerApproveEntities().toArray(new Key<?>[]{}))
+                .keys(domain.getTransferData().getServerApproveEntities().toArray(new Key<?>[] {}))
                 .values(),
             PollMessage.class),
         ImmutableList.of(
-            transferApprovedPollMessage,
-            losingTransferApprovedPollMessage,
-            autorenewPollMessage));
+            transferApprovedPollMessage, losingTransferApprovedPollMessage, autorenewPollMessage));
   }
 
   private void assertAboutDomainAfterAutomaticTransfer(
@@ -448,15 +458,23 @@ public class DomainTransferRequestFlowTest
     Registry registry = Registry.get(domain.getTld());
     DomainResource domainAfterAutomaticTransfer = domain.cloneProjectedAtTime(implicitTransferTime);
     assertTransferApproved(domainAfterAutomaticTransfer, implicitTransferTime, expectedPeriod);
-    assertAboutDomains().that(domainAfterAutomaticTransfer)
+    assertAboutDomains()
+        .that(domainAfterAutomaticTransfer)
         .hasRegistrationExpirationTime(expectedExpirationTime);
-    assertThat(ofy().load().key(domainAfterAutomaticTransfer.getAutorenewBillingEvent()).now()
-        .getEventTime())
-            .isEqualTo(expectedExpirationTime);
+    assertThat(
+            ofy()
+                .load()
+                .key(domainAfterAutomaticTransfer.getAutorenewBillingEvent())
+                .now()
+                .getEventTime())
+        .isEqualTo(expectedExpirationTime);
     // And after the expected grace time, the grace period should be gone.
-    DomainResource afterGracePeriod = domain.cloneProjectedAtTime(
-        clock.nowUtc().plus(registry.getAutomaticTransferLength()).plus(
-            registry.getTransferGracePeriodLength()));
+    DomainResource afterGracePeriod =
+        domain.cloneProjectedAtTime(
+            clock
+                .nowUtc()
+                .plus(registry.getAutomaticTransferLength())
+                .plus(registry.getTransferGracePeriodLength()));
     assertThat(afterGracePeriod.getGracePeriods()).isEmpty();
   }
 
@@ -464,7 +482,8 @@ public class DomainTransferRequestFlowTest
       String commandFilename,
       String expectedXmlFilename,
       DateTime expectedExpirationTime,
-      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents) throws Exception {
+      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents)
+      throws Exception {
     doSuccessfulTest(
         commandFilename,
         expectedXmlFilename,
@@ -475,9 +494,8 @@ public class DomainTransferRequestFlowTest
   }
 
   private void doSuccessfulTest(
-      String commandFilename,
-      String expectedXmlFilename,
-      Map<String, String> substitutions) throws Exception {
+      String commandFilename, String expectedXmlFilename, Map<String, String> substitutions)
+      throws Exception {
     clock.advanceOneMilli();
     doSuccessfulTest(
         commandFilename,
@@ -502,7 +520,8 @@ public class DomainTransferRequestFlowTest
       Optional<Money> transferCost,
       Period expectedPeriod,
       Duration expectedAutomaticTransferLength,
-      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents) throws Exception {
+      BillingEvent.Cancellation.Builder... extraExpectedBillingEvents)
+      throws Exception {
     setEppInput(commandFilename, substitutions);
     ImmutableSet<GracePeriod> originalGracePeriods = domain.getGracePeriods();
     // Replace the ROID in the xml file with the one generated in our test.
@@ -526,7 +545,8 @@ public class DomainTransferRequestFlowTest
       domain = reloadResourceByForeignKey();
     }
     // Verify that HistoryEntry was created.
-    assertAboutDomains().that(domain)
+    assertAboutDomains()
+        .that(domain)
         .hasOneHistoryEntryEachOfTypes(DOMAIN_CREATE, DOMAIN_TRANSFER_REQUEST);
     final HistoryEntry historyEntryTransferRequest =
         getOnlyHistoryEntryOfType(domain, DOMAIN_TRANSFER_REQUEST);
@@ -556,9 +576,8 @@ public class DomainTransferRequestFlowTest
   }
 
   private void runTest(
-      String commandFilename,
-      UserPrivileges userPrivileges,
-      Map<String, String> substitutions) throws Exception {
+      String commandFilename, UserPrivileges userPrivileges, Map<String, String> substitutions)
+      throws Exception {
     setEppInput(commandFilename, substitutions);
     // Replace the ROID in the xml file with the one generated in our test.
     eppLoader.replaceAll("JD1234-REP", contact.getRepoId());
@@ -571,8 +590,8 @@ public class DomainTransferRequestFlowTest
     runTest(commandFilename, userPrivileges, ImmutableMap.of());
   }
 
-  private void doFailingTest(
-      String commandFilename, Map<String, String> substitutions) throws Exception {
+  private void doFailingTest(String commandFilename, Map<String, String> substitutions)
+      throws Exception {
     runTest(commandFilename, UserPrivileges.NORMAL, substitutions);
   }
 
@@ -645,73 +664,91 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_refundableFee_v06() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_06_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_06_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_refundableFee_v11() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_11_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_11_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_refundableFee_v12() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_12_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_refundable.xml", FEE_12_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_gracePeriodFee_v06() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_06_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_06_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_gracePeriodFee_v11() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_11_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_11_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_gracePeriodFee_v12() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_12_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_grace_period.xml", FEE_12_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_appliedFee_v06() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_06_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_06_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_appliedFee_v11() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_11_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_11_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_appliedFee_v12() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        UnsupportedFeeAttributeException.class,
-        () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_12_MAP));
+    EppException thrown =
+        expectThrows(
+            UnsupportedFeeAttributeException.class,
+            () -> doFailingTest("domain_transfer_request_fee_applied.xml", FEE_12_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -723,8 +760,7 @@ public class DomainTransferRequestFlowTest
             .setAutomaticTransferLength(Duration.standardMinutes(15))
             .build());
     doSuccessfulTest(
-        "domain_transfer_request.xml",
-        "domain_transfer_request_response_15_minutes.xml");
+        "domain_transfer_request.xml", "domain_transfer_request_response_15_minutes.xml");
   }
 
   @Test
@@ -742,17 +778,18 @@ public class DomainTransferRequestFlowTest
   public void testSuccess_missingPeriod_defaultsToOneYear() throws Exception {
     setupDomain("example", "tld");
     doSuccessfulTest(
-        "domain_transfer_request_missing_period.xml",
-        "domain_transfer_request_response.xml");
+        "domain_transfer_request_missing_period.xml", "domain_transfer_request_response.xml");
   }
 
   @Test
   public void testFailure_multiYearPeriod() throws Exception {
     setupDomain("example", "tld");
     clock.advanceOneMilli();
-    assertThrows(
-        TransferPeriodMustBeOneYearException.class,
-        () -> doFailingTest("domain_transfer_request_2_years.xml"));
+    EppException thrown =
+        expectThrows(
+            TransferPeriodMustBeOneYearException.class,
+            () -> doFailingTest("domain_transfer_request_2_years.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -804,24 +841,26 @@ public class DomainTransferRequestFlowTest
   }
 
   @Test
-  public void testSuccess_superuserExtension_zeroPeriod_autorenewGraceActive()
-      throws Exception {
+  public void testSuccess_superuserExtension_zeroPeriod_autorenewGraceActive() throws Exception {
     eppRequestSource = EppRequestSource.TOOL;
     setupDomain("example", "tld");
-    Key<BillingEvent.Recurring> existingAutorenewEvent =
-        domain.getAutorenewBillingEvent();
+    Key<BillingEvent.Recurring> existingAutorenewEvent = domain.getAutorenewBillingEvent();
     // Set domain to have auto-renewed just before the transfer request, so that it will have an
     // active autorenew grace period spanning the entire transfer window.
     DateTime autorenewTime = clock.nowUtc().minusDays(1);
     DateTime expirationTime = autorenewTime.plusYears(1);
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(expirationTime)
-        .addGracePeriod(GracePeriod.createForRecurring(
-            GracePeriodStatus.AUTO_RENEW,
-            autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
-            "TheRegistrar",
-            existingAutorenewEvent))
-        .build());
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setRegistrationExpirationTime(expirationTime)
+                .addGracePeriod(
+                    GracePeriod.createForRecurring(
+                        GracePeriodStatus.AUTO_RENEW,
+                        autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
+                        "TheRegistrar",
+                        existingAutorenewEvent))
+                .build());
     clock.advanceOneMilli();
     doSuccessfulSuperuserExtensionTest(
         "domain_transfer_request_superuser_extension.xml",
@@ -865,9 +904,9 @@ public class DomainTransferRequestFlowTest
   public void testSuccess_cappedExpiration() throws Exception {
     setupDomain("example", "tld");
     // Set the domain to expire 10 years from now (as if it were just created with a 10-year term).
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(clock.nowUtc().plusYears(10))
-        .build());
+    domain =
+        persistResource(
+            domain.asBuilder().setRegistrationExpirationTime(clock.nowUtc().plusYears(10)).build());
     // New expiration time should be capped at exactly 10 years from the transfer server-approve
     // time, so the domain only ends up gaining the 5-day transfer window's worth of extra
     // registration time.
@@ -882,8 +921,7 @@ public class DomainTransferRequestFlowTest
   public void testSuccess_domainAuthInfo() throws Exception {
     setupDomain("example", "tld");
     doSuccessfulTest(
-        "domain_transfer_request_domain_authinfo.xml",
-        "domain_transfer_request_response.xml");
+        "domain_transfer_request_domain_authinfo.xml", "domain_transfer_request_response.xml");
   }
 
   @Test
@@ -910,11 +948,13 @@ public class DomainTransferRequestFlowTest
     setupDomain("example", "tld");
     persistResource(
         loadRegistrar("NewRegistrar").asBuilder().setAllowedTlds(ImmutableSet.of()).build());
-    assertThrows(
-        NotAuthorizedForTldException.class,
-        () ->
-            doSuccessfulTest(
-                "domain_transfer_request.xml", "domain_transfer_request_response.xml"));
+    EppException thrown =
+        expectThrows(
+            NotAuthorizedForTldException.class,
+            () ->
+                doSuccessfulTest(
+                    "domain_transfer_request.xml", "domain_transfer_request_response.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -935,14 +975,18 @@ public class DomainTransferRequestFlowTest
     DateTime autorenewTime =
         clock.nowUtc().minus(Registry.get("tld").getAutoRenewGracePeriodLength()).plusDays(1);
     DateTime expirationTime = autorenewTime.plusYears(1);
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(expirationTime)
-        .addGracePeriod(GracePeriod.createForRecurring(
-            GracePeriodStatus.AUTO_RENEW,
-            autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
-            "TheRegistrar",
-            domain.getAutorenewBillingEvent()))
-        .build());
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setRegistrationExpirationTime(expirationTime)
+                .addGracePeriod(
+                    GracePeriod.createForRecurring(
+                        GracePeriodStatus.AUTO_RENEW,
+                        autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
+                        "TheRegistrar",
+                        domain.getAutorenewBillingEvent()))
+                .build());
     clock.advanceOneMilli();
     // Since the autorenew grace period will have ended by the automatic transfer time, subsuming
     // will not occur in the server-approve case, so the transfer will add 1 year to the current
@@ -958,20 +1002,23 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testSuccess_autorenewGraceActive_throughoutTransferWindow() throws Exception {
     setupDomain("example", "tld");
-    Key<BillingEvent.Recurring> existingAutorenewEvent =
-        domain.getAutorenewBillingEvent();
+    Key<BillingEvent.Recurring> existingAutorenewEvent = domain.getAutorenewBillingEvent();
     // Set domain to have auto-renewed just before the transfer request, so that it will have an
     // active autorenew grace period spanning the entire transfer window.
     DateTime autorenewTime = clock.nowUtc().minusDays(1);
     DateTime expirationTime = autorenewTime.plusYears(1);
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(expirationTime)
-        .addGracePeriod(GracePeriod.createForRecurring(
-            GracePeriodStatus.AUTO_RENEW,
-            autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
-            "TheRegistrar",
-            existingAutorenewEvent))
-        .build());
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setRegistrationExpirationTime(expirationTime)
+                .addGracePeriod(
+                    GracePeriod.createForRecurring(
+                        GracePeriodStatus.AUTO_RENEW,
+                        autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()),
+                        "TheRegistrar",
+                        existingAutorenewEvent))
+                .build());
     clock.advanceOneMilli();
     // The transfer will subsume the recent autorenew, so there will be no net change in expiration
     // time caused by the transfer, but we must write a Cancellation.
@@ -985,8 +1032,7 @@ public class DomainTransferRequestFlowTest
             .setClientId("TheRegistrar")
             // The cancellation happens at the moment of transfer.
             .setEventTime(clock.nowUtc().plus(Registry.get("tld").getAutomaticTransferLength()))
-            .setBillingTime(autorenewTime.plus(
-                Registry.get("tld").getAutoRenewGracePeriodLength()))
+            .setBillingTime(autorenewTime.plus(Registry.get("tld").getAutoRenewGracePeriodLength()))
             // The cancellation should refer to the old autorenew billing event.
             .setRecurringEventKey(existingAutorenewEvent));
   }
@@ -994,14 +1040,12 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testSuccess_autorenewGraceActive_onlyAtAutomaticTransferTime() throws Exception {
     setupDomain("example", "tld");
-    Key<BillingEvent.Recurring> existingAutorenewEvent =
-        domain.getAutorenewBillingEvent();
+    Key<BillingEvent.Recurring> existingAutorenewEvent = domain.getAutorenewBillingEvent();
     // Set domain to expire in 1 day, so that it will be in the autorenew grace period by the
     // automatic transfer time, even though it isn't yet.
     DateTime expirationTime = clock.nowUtc().plusDays(1);
-    domain = persistResource(domain.asBuilder()
-        .setRegistrationExpirationTime(expirationTime)
-        .build());
+    domain =
+        persistResource(domain.asBuilder().setRegistrationExpirationTime(expirationTime).build());
     clock.advanceOneMilli();
     // The transfer will subsume the future autorenew, meaning that the expected server-approve
     // expiration time will be 1 year beyond the current one, and we must write a Cancellation.
@@ -1036,8 +1080,7 @@ public class DomainTransferRequestFlowTest
     persistResource(Registry.get("example").asBuilder().setPremiumPriceAckRequired(false).build());
     clock.advanceOneMilli();
     // Modify the Registrar to block premium names.
-    persistResource(
-        loadRegistrar("NewRegistrar").asBuilder().setBlockPremiumNames(true).build());
+    persistResource(loadRegistrar("NewRegistrar").asBuilder().setBlockPremiumNames(true).build());
     // We don't verify the results; just check that the flow doesn't fail.
     runTest("domain_transfer_request_premium.xml", UserPrivileges.SUPERUSER);
   }
@@ -1054,9 +1097,11 @@ public class DomainTransferRequestFlowTest
             .setEapFeeSchedule(ImmutableSortedMap.of(START_OF_TIME, Money.zero(EUR)))
             .setServerStatusChangeBillingCost(Money.of(EUR, 19))
             .build());
-    assertThrows(
-        CurrencyUnitMismatchException.class,
-        () -> doFailingTest("domain_transfer_request_fee.xml", substitutions));
+    EppException thrown =
+        expectThrows(
+            CurrencyUnitMismatchException.class,
+            () -> doFailingTest("domain_transfer_request_fee.xml", substitutions));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1080,25 +1125,31 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_feeGivenInWrongScale_v06() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        CurrencyValueScaleException.class,
-        () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_06_MAP));
+    EppException thrown =
+        expectThrows(
+            CurrencyValueScaleException.class,
+            () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_06_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_feeGivenInWrongScale_v11() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        CurrencyValueScaleException.class,
-        () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_11_MAP));
+    EppException thrown =
+        expectThrows(
+            CurrencyValueScaleException.class,
+            () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_11_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_feeGivenInWrongScale_v12() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        CurrencyValueScaleException.class,
-        () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_12_MAP));
+    EppException thrown =
+        expectThrows(
+            CurrencyValueScaleException.class,
+            () -> doFailingTest("domain_transfer_request_fee_bad_scale.xml", FEE_12_MAP));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   private void runWrongFeeAmountTest(Map<String, String> substitutions) throws Exception {
@@ -1107,9 +1158,11 @@ public class DomainTransferRequestFlowTest
             .asBuilder()
             .setRenewBillingCostTransitions(ImmutableSortedMap.of(START_OF_TIME, Money.of(USD, 20)))
             .build());
-    assertThrows(
-        FeesMismatchException.class,
-        () -> doFailingTest("domain_transfer_request_fee.xml", substitutions));
+    EppException thrown =
+        expectThrows(
+            FeesMismatchException.class,
+            () -> doFailingTest("domain_transfer_request_fee.xml", substitutions));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1134,39 +1187,49 @@ public class DomainTransferRequestFlowTest
   public void testFailure_premiumBlocked() throws Exception {
     setupDomain("rich", "example");
     // Modify the Registrar to block premium names.
-    persistResource(
-        loadRegistrar("NewRegistrar").asBuilder().setBlockPremiumNames(true).build());
-    assertThrows(
-        PremiumNameBlockedException.class,
-        () -> doFailingTest("domain_transfer_request_premium.xml"));
+    persistResource(loadRegistrar("NewRegistrar").asBuilder().setBlockPremiumNames(true).build());
+    EppException thrown =
+        expectThrows(
+            PremiumNameBlockedException.class,
+            () -> doFailingTest("domain_transfer_request_premium.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_feeNotProvidedOnPremiumName() throws Exception {
     setupDomain("rich", "example");
-    assertThrows(
-        FeesRequiredForPremiumNameException.class,
-        () -> doFailingTest("domain_transfer_request_premium.xml"));
+    EppException thrown =
+        expectThrows(
+            FeesRequiredForPremiumNameException.class,
+            () -> doFailingTest("domain_transfer_request_premium.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_noAuthInfo() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        MissingTransferRequestAuthInfoException.class,
-        () -> doFailingTest("domain_transfer_request_no_authinfo.xml"));
+    EppException thrown =
+        expectThrows(
+            MissingTransferRequestAuthInfoException.class,
+            () -> doFailingTest("domain_transfer_request_no_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badContactPassword() throws Exception {
     setupDomain("example", "tld");
     // Change the contact's password so it does not match the password in the file.
-    contact = persistResource(
-        contact.asBuilder()
-            .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
-            .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class, () -> doFailingTest("domain_transfer_request.xml"));
+    contact =
+        persistResource(
+            contact
+                .asBuilder()
+                .setAuthInfo(ContactAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_request.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1175,8 +1238,11 @@ public class DomainTransferRequestFlowTest
     // Set the contact to a different ROID, but don't persist it; this is just so the substitution
     // code above will write the wrong ROID into the file.
     contact = contact.asBuilder().setRepoId("DEADBEEF_TLD-ROID").build();
-    assertThrows(
-        BadAuthInfoForResourceException.class, () -> doFailingTest("domain_transfer_request.xml"));
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_request.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1217,41 +1283,58 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_pending() throws Exception {
     setupDomain("example", "tld");
-    domain = persistResource(domain.asBuilder()
-        .setTransferData(domain.getTransferData().asBuilder()
-            .setTransferStatus(TransferStatus.PENDING)
-            .setPendingTransferExpirationTime(clock.nowUtc().plusDays(1))
-            .build())
-        .build());
-    assertThrows(
-        AlreadyPendingTransferException.class, () -> doFailingTest("domain_transfer_request.xml"));
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setTransferData(
+                    domain
+                        .getTransferData()
+                        .asBuilder()
+                        .setTransferStatus(TransferStatus.PENDING)
+                        .setPendingTransferExpirationTime(clock.nowUtc().plusDays(1))
+                        .build())
+                .build());
+    EppException thrown =
+        expectThrows(
+            AlreadyPendingTransferException.class,
+            () -> doFailingTest("domain_transfer_request.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_badDomainPassword() throws Exception {
     setupDomain("example", "tld");
     // Change the domain's password so it does not match the password in the file.
-    domain = persistResource(domain.asBuilder()
-        .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
-        .build());
-    assertThrows(
-        BadAuthInfoForResourceException.class,
-        () -> doFailingTest("domain_transfer_request_domain_authinfo.xml"));
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .setAuthInfo(DomainAuthInfo.create(PasswordAuth.create("badpassword")))
+                .build());
+    EppException thrown =
+        expectThrows(
+            BadAuthInfoForResourceException.class,
+            () -> doFailingTest("domain_transfer_request_domain_authinfo.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_sponsoringClient() throws Exception {
     setupDomain("example", "tld");
     setClientIdForFlow("TheRegistrar");
-    assertThrows(
-        ObjectAlreadySponsoredException.class, () -> doFailingTest("domain_transfer_request.xml"));
+    EppException thrown =
+        expectThrows(
+            ObjectAlreadySponsoredException.class,
+            () -> doFailingTest("domain_transfer_request.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_deletedDomain() throws Exception {
     setupDomain("example", "tld");
-    domain = persistResource(
-        domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
+    domain =
+        persistResource(domain.asBuilder().setDeletionTime(clock.nowUtc().minusDays(1)).build());
     ResourceDoesNotExistException thrown =
         expectThrows(
             ResourceDoesNotExistException.class,
@@ -1288,15 +1371,19 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_periodInMonths() throws Exception {
     setupDomain("example", "tld");
-    assertThrows(
-        BadPeriodUnitException.class, () -> doFailingTest("domain_transfer_request_months.xml"));
+    EppException thrown =
+        expectThrows(
+            BadPeriodUnitException.class,
+            () -> doFailingTest("domain_transfer_request_months.xml"));
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_clientTransferProhibited() throws Exception {
     setupDomain("example", "tld");
-    domain = persistResource(
-        domain.asBuilder().addStatusValue(StatusValue.CLIENT_TRANSFER_PROHIBITED).build());
+    domain =
+        persistResource(
+            domain.asBuilder().addStatusValue(StatusValue.CLIENT_TRANSFER_PROHIBITED).build());
     ResourceStatusProhibitsOperationException thrown =
         expectThrows(
             ResourceStatusProhibitsOperationException.class,
@@ -1307,8 +1394,9 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_serverTransferProhibited() throws Exception {
     setupDomain("example", "tld");
-    domain = persistResource(
-        domain.asBuilder().addStatusValue(StatusValue.SERVER_TRANSFER_PROHIBITED).build());
+    domain =
+        persistResource(
+            domain.asBuilder().addStatusValue(StatusValue.SERVER_TRANSFER_PROHIBITED).build());
     ResourceStatusProhibitsOperationException thrown =
         expectThrows(
             ResourceStatusProhibitsOperationException.class,
@@ -1319,8 +1407,7 @@ public class DomainTransferRequestFlowTest
   @Test
   public void testFailure_pendingDelete() throws Exception {
     setupDomain("example", "tld");
-    domain = persistResource(
-        domain.asBuilder().addStatusValue(StatusValue.PENDING_DELETE).build());
+    domain = persistResource(domain.asBuilder().addStatusValue(StatusValue.PENDING_DELETE).build());
     ResourceStatusProhibitsOperationException thrown =
         expectThrows(
             ResourceStatusProhibitsOperationException.class,
diff --git a/javatests/google/registry/flows/domain/DomainUpdateFlowTest.java b/javatests/google/registry/flows/domain/DomainUpdateFlowTest.java
index 2d1b9e27c..eb1ff52cd 100644
--- a/javatests/google/registry/flows/domain/DomainUpdateFlowTest.java
+++ b/javatests/google/registry/flows/domain/DomainUpdateFlowTest.java
@@ -34,8 +34,8 @@ import static google.registry.testing.DatastoreHelper.persistDeletedDomain;
 import static google.registry.testing.DatastoreHelper.persistReservedList;
 import static google.registry.testing.DatastoreHelper.persistResource;
 import static google.registry.testing.DomainResourceSubject.assertAboutDomains;
+import static google.registry.testing.EppExceptionSubject.assertAboutEppExceptions;
 import static google.registry.testing.HistoryEntrySubject.assertAboutHistoryEntries;
-import static google.registry.testing.JUnitBackports.assertThrows;
 import static google.registry.testing.JUnitBackports.expectThrows;
 import static google.registry.testing.TaskQueueHelper.assertDnsTasksEnqueued;
 import static org.joda.money.CurrencyUnit.USD;
@@ -44,6 +44,7 @@ import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
 import com.googlecode.objectify.Key;
+import google.registry.flows.EppException;
 import google.registry.flows.EppException.UnimplementedExtensionException;
 import google.registry.flows.EppRequestSource;
 import google.registry.flows.ResourceFlowTestCase;
@@ -97,7 +98,7 @@ import org.junit.Test;
 public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow, DomainResource> {
 
   private static final DelegationSignerData SOME_DSDATA =
-      DelegationSignerData.create(1, 2, 3, new byte[]{0, 1, 2});
+      DelegationSignerData.create(1, 2, 3, new byte[] {0, 1, 2});
 
   ContactResource sh8013Contact;
   ContactResource mak21Contact;
@@ -125,18 +126,22 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
 
   private DomainResource persistDomain() throws Exception {
     HostResource host = loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc());
-    DomainResource domain = persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setContacts(ImmutableSet.of(
-                DesignatedContact.create(Type.TECH, Key.create(sh8013Contact)),
-                DesignatedContact.create(Type.ADMIN, Key.create(unusedContact))))
-            .setNameservers(ImmutableSet.of(Key.create(host)))
-            .build());
-    historyEntryDomainCreate = persistResource(
-        new HistoryEntry.Builder()
-            .setType(HistoryEntry.Type.DOMAIN_CREATE)
-            .setParent(domain)
-            .build());
+    DomainResource domain =
+        persistResource(
+            newDomainResource(getUniqueIdFromCommand())
+                .asBuilder()
+                .setContacts(
+                    ImmutableSet.of(
+                        DesignatedContact.create(Type.TECH, Key.create(sh8013Contact)),
+                        DesignatedContact.create(Type.ADMIN, Key.create(unusedContact))))
+                .setNameservers(ImmutableSet.of(Key.create(host)))
+                .build());
+    historyEntryDomainCreate =
+        persistResource(
+            new HistoryEntry.Builder()
+                .setType(HistoryEntry.Type.DOMAIN_CREATE)
+                .setParent(domain)
+                .build());
     clock.advanceOneMilli();
     return domain;
   }
@@ -145,12 +150,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     assertTransactionalFlow(true);
     runFlowAssertResponse(loadFile("domain_update_response.xml"));
     // Check that the domain was updated. These values came from the xml.
-    assertAboutDomains().that(reloadResourceByForeignKey())
-        .hasStatusValue(StatusValue.CLIENT_HOLD).and()
-        .hasAuthInfoPwd("2BARfoo").and()
+    assertAboutDomains()
+        .that(reloadResourceByForeignKey())
+        .hasStatusValue(StatusValue.CLIENT_HOLD)
+        .and()
+        .hasAuthInfoPwd("2BARfoo")
+        .and()
         .hasOneHistoryEntryEachOfTypes(
-            HistoryEntry.Type.DOMAIN_CREATE,
-            HistoryEntry.Type.DOMAIN_UPDATE);
+            HistoryEntry.Type.DOMAIN_CREATE, HistoryEntry.Type.DOMAIN_UPDATE);
     assertNoBillingEvents();
     assertDnsTasksEnqueued("example.tld");
   }
@@ -172,31 +179,32 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
   private void doSunrushAddTest(
       BillingEvent.OneTime sunrushAddBillingEvent,
       UserPrivileges userPrivileges,
-      DateTime addExpirationTime) throws Exception {
+      DateTime addExpirationTime)
+      throws Exception {
     // The billing event for the original sunrush add should already exist; check for it now to
     // avoid a confusing assertBillingEvents() later if it doesn't exist.
     assertBillingEvents(sunrushAddBillingEvent);
 
-    runFlowAssertResponse(
-        CommitMode.LIVE, userPrivileges, loadFile("domain_update_response.xml"));
+    runFlowAssertResponse(CommitMode.LIVE, userPrivileges, loadFile("domain_update_response.xml"));
 
     // Verify that the domain now has the new nameserver and is in the add grace period.
     DomainResource resource = reloadResourceByForeignKey();
     HistoryEntry historyEntryDomainUpdate =
         getOnlyHistoryEntryOfType(resource, HistoryEntry.Type.DOMAIN_UPDATE);
-    assertThat(resource.getNameservers()).containsExactly(
-        Key.create(
-            loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
-    BillingEvent.OneTime regularAddBillingEvent = new BillingEvent.OneTime.Builder()
-        .setReason(Reason.CREATE)
-        .setTargetId("example.tld")
-        .setClientId("TheRegistrar")
-        .setCost(Money.of(USD, 50))
-        .setPeriodYears(4)
-        .setEventTime(clock.nowUtc())
-        .setBillingTime(addExpirationTime)
-        .setParent(historyEntryDomainUpdate)
-        .build();
+    assertThat(resource.getNameservers())
+        .containsExactly(
+            Key.create(loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
+    BillingEvent.OneTime regularAddBillingEvent =
+        new BillingEvent.OneTime.Builder()
+            .setReason(Reason.CREATE)
+            .setTargetId("example.tld")
+            .setClientId("TheRegistrar")
+            .setCost(Money.of(USD, 50))
+            .setPeriodYears(4)
+            .setEventTime(clock.nowUtc())
+            .setBillingTime(addExpirationTime)
+            .setParent(historyEntryDomainUpdate)
+            .build();
     assertBillingEvents(
         sunrushAddBillingEvent,
         // There should be a cancellation for the original sunrush add billing event.
@@ -235,14 +243,15 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_add_nameserver.xml");
     persistReferencedEntities();
     persistDomain();
-    BillingEvent.OneTime sunrushAddBillingEvent = persistResource(
-            getSunrushAddBillingEvent(clock.nowUtc().plusDays(20)));
+    BillingEvent.OneTime sunrushAddBillingEvent =
+        persistResource(getSunrushAddBillingEvent(clock.nowUtc().plusDays(20)));
     // Modify domain so it has no nameservers and is in the sunrush add grace period.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
+        reloadResourceByForeignKey()
+            .asBuilder()
             .setNameservers(null)
-            .addGracePeriod(GracePeriod.forBillingEvent(
-                GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
+            .addGracePeriod(
+                GracePeriod.forBillingEvent(GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
             .build());
     clock.advanceOneMilli();
     doSunrushAddTest(
@@ -263,10 +272,11 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // that grace period only has a couple days left so that the resultant add grace period will get
     // truncated.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
+        reloadResourceByForeignKey()
+            .asBuilder()
             .setNameservers(null)
-            .addGracePeriod(GracePeriod.forBillingEvent(
-                GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
+            .addGracePeriod(
+                GracePeriod.forBillingEvent(GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
             .build());
     clock.advanceOneMilli();
     doSunrushAddTest(sunrushAddBillingEvent, UserPrivileges.NORMAL, billingTime);
@@ -282,11 +292,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // Modify domain so that it is in the sunrush add grace period, has nameservers, but has a
     // serverHold on it.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
-            .setNameservers(ImmutableSet.of(Key.create(
-                loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
-            .addGracePeriod(GracePeriod.forBillingEvent(
-                GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
+        reloadResourceByForeignKey()
+            .asBuilder()
+            .setNameservers(
+                ImmutableSet.of(
+                    Key.create(
+                        loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
+            .addGracePeriod(
+                GracePeriod.forBillingEvent(GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
             .addStatusValue(StatusValue.SERVER_HOLD)
             .build());
     clock.advanceOneMilli();
@@ -306,11 +319,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // Modify domain so that it is in the sunrush add grace period, has nameservers, but has a
     // serverHold on it.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
-            .setNameservers(ImmutableSet.of(Key.create(
-                loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
-            .addGracePeriod(GracePeriod.forBillingEvent(
-                GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
+        reloadResourceByForeignKey()
+            .asBuilder()
+            .setNameservers(
+                ImmutableSet.of(
+                    Key.create(
+                        loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
+            .addGracePeriod(
+                GracePeriod.forBillingEvent(GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
             .addStatusValue(StatusValue.CLIENT_HOLD)
             .build());
     clock.advanceOneMilli();
@@ -331,10 +347,11 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // Modify domain so it has no nameservers and is in the sunrush add grace period, but also has a
     // server hold on it that will prevent the sunrush add grace period from being removed.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
+        reloadResourceByForeignKey()
+            .asBuilder()
             .setNameservers(null)
-            .addGracePeriod(GracePeriod.forBillingEvent(
-                GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
+            .addGracePeriod(
+                GracePeriod.forBillingEvent(GracePeriodStatus.SUNRUSH_ADD, sunrushAddBillingEvent))
             .addStatusValue(StatusValue.SERVER_HOLD)
             .build());
     clock.advanceOneMilli();
@@ -353,14 +370,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     ImmutableSet.Builder<Key<HostResource>> nameservers = new ImmutableSet.Builder<>();
     for (int i = 1; i < 15; i++) {
       if (i != 2) { // Skip 2 since that's the one that the tests will add.
-        nameservers.add(Key.create(loadByForeignKey(
-            HostResource.class, String.format("ns%d.example.foo", i), clock.nowUtc())));
+        nameservers.add(
+            Key.create(
+                loadByForeignKey(
+                    HostResource.class, String.format("ns%d.example.foo", i), clock.nowUtc())));
       }
     }
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
-            .setNameservers(nameservers.build())
-            .build());
+        reloadResourceByForeignKey().asBuilder().setNameservers(nameservers.build()).build());
     clock.advanceOneMilli();
   }
 
@@ -395,7 +412,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     }
     ImmutableList<DesignatedContact> contacts = contactsBuilder.build();
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
+        reloadResourceByForeignKey()
+            .asBuilder()
             .setNameservers(nameservers.build())
             .setContacts(ImmutableSet.copyOf(contacts.subList(0, 3)))
             .setRegistrant(contacts.get(3).getContactKey())
@@ -404,10 +422,10 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     assertTransactionalFlow(true);
     runFlowAssertResponse(loadFile("domain_update_response.xml"));
     DomainResource domain = reloadResourceByForeignKey();
-    assertAboutDomains().that(domain)
+    assertAboutDomains()
+        .that(domain)
         .hasOneHistoryEntryEachOfTypes(
-            HistoryEntry.Type.DOMAIN_CREATE,
-            HistoryEntry.Type.DOMAIN_UPDATE);
+            HistoryEntry.Type.DOMAIN_CREATE, HistoryEntry.Type.DOMAIN_UPDATE);
     assertThat(domain.getNameservers()).hasSize(13);
     // getContacts does not return contacts of type REGISTRANT, so check these separately.
     assertThat(domain.getContacts()).hasSize(3);
@@ -425,13 +443,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistDomain();
     runFlow();
     DomainResource domain = reloadResourceByForeignKey();
-    assertAboutDomains().that(domain)
+    assertAboutDomains()
+        .that(domain)
         .hasOneHistoryEntryEachOfTypes(
-            HistoryEntry.Type.DOMAIN_CREATE,
-            HistoryEntry.Type.DOMAIN_UPDATE);
+            HistoryEntry.Type.DOMAIN_CREATE, HistoryEntry.Type.DOMAIN_UPDATE);
     assertAboutHistoryEntries()
         .that(getOnlyHistoryEntryOfType(domain, HistoryEntry.Type.DOMAIN_UPDATE))
-        .hasMetadataReason("domain-update-test").and()
+        .hasMetadataReason("domain-update-test")
+        .and()
         .hasMetadataRequestedByRegistrar(true);
   }
 
@@ -440,7 +459,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_metadata.xml");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(OnlyToolCanPassMetadataException.class, this::runFlow);
+    EppException thrown = expectThrows(OnlyToolCanPassMetadataException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -460,12 +480,18 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     DomainResource domain = persistDomain();
     HostResource existingHost = persistActiveSubordinateHost("ns1.example.tld", domain);
     HostResource addedHost = persistActiveSubordinateHost("ns2.example.tld", domain);
-    domain = persistResource(domain.asBuilder()
-        .addSubordinateHost("ns1.example.tld")
-        .addSubordinateHost("ns2.example.tld")
-        .setNameservers(ImmutableSet.of(Key.create(
-            loadByForeignKey(HostResource.class, "ns1.example.tld", clock.nowUtc()))))
-        .build());
+    domain =
+        persistResource(
+            domain
+                .asBuilder()
+                .addSubordinateHost("ns1.example.tld")
+                .addSubordinateHost("ns2.example.tld")
+                .setNameservers(
+                    ImmutableSet.of(
+                        Key.create(
+                            loadByForeignKey(
+                                HostResource.class, "ns1.example.tld", clock.nowUtc()))))
+                .build());
     clock.advanceOneMilli();
     assertTransactionalFlow(true);
     runFlowAssertResponse(loadFile("domain_update_response.xml"));
@@ -484,7 +510,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     ContactResource sh8013 = loadByForeignKey(ContactResource.class, "sh8013", clock.nowUtc());
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
             .setRegistrant(Key.create(sh8013))
             .build());
     clock.advanceOneMilli();
@@ -498,12 +525,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     ContactResource sh8013 = loadByForeignKey(ContactResource.class, "sh8013", clock.nowUtc());
     Key<ContactResource> sh8013Key = Key.create(sh8013);
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
             .setRegistrant(sh8013Key)
-            .setContacts(ImmutableSet.of(
-                DesignatedContact.create(Type.ADMIN, sh8013Key),
-                DesignatedContact.create(Type.BILLING, sh8013Key),
-                DesignatedContact.create(Type.TECH, sh8013Key)))
+            .setContacts(
+                ImmutableSet.of(
+                    DesignatedContact.create(Type.ADMIN, sh8013Key),
+                    DesignatedContact.create(Type.BILLING, sh8013Key),
+                    DesignatedContact.create(Type.TECH, sh8013Key)))
             .build());
     clock.advanceOneMilli();
     runFlowAssertResponse(loadFile("domain_update_response.xml"));
@@ -513,12 +542,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
   public void testSuccess_removeClientUpdateProhibited() throws Exception {
     persistReferencedEntities();
     persistResource(
-        persistDomain().asBuilder()
+        persistDomain()
+            .asBuilder()
             .setStatusValues(ImmutableSet.of(StatusValue.CLIENT_UPDATE_PROHIBITED))
             .build());
     clock.advanceOneMilli();
     runFlow();
-    assertAboutDomains().that(reloadResourceByForeignKey())
+    assertAboutDomains()
+        .that(reloadResourceByForeignKey())
         .doesNotHaveStatusValue(StatusValue.CLIENT_UPDATE_PROHIBITED);
   }
 
@@ -529,14 +560,13 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
       throws Exception {
     setEppInput(xmlFilename);
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setDsData(originalDsData)
-            .build());
+        newDomainResource(getUniqueIdFromCommand()).asBuilder().setDsData(originalDsData).build());
     assertTransactionalFlow(true);
     clock.advanceOneMilli();
     runFlowAssertResponse(loadFile("domain_update_response.xml"));
     DomainResource resource = reloadResourceByForeignKey();
-    assertAboutDomains().that(resource)
+    assertAboutDomains()
+        .that(resource)
         .hasOnlyOneHistoryEntryWhich()
         .hasType(HistoryEntry.Type.DOMAIN_UPDATE);
     assertThat(resource.getDsData()).isEqualTo(expectedDsData);
@@ -548,8 +578,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_add.xml",
         null,
-        ImmutableSet.of(DelegationSignerData.create(
-            12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
+        ImmutableSet.of(
+            DelegationSignerData.create(12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
   }
 
   @Test
@@ -557,15 +587,16 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_add.xml",
         ImmutableSet.of(SOME_DSDATA),
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
   }
 
   @Test
   public void testSuccess_secDnsAddToMaxRecords() throws Exception {
     ImmutableSet.Builder<DelegationSignerData> builder = new ImmutableSet.Builder<>();
     for (int i = 0; i < 7; ++i) {
-      builder.add(DelegationSignerData.create(i, 2, 3, new byte[]{0, 1, 2}));
+      builder.add(DelegationSignerData.create(i, 2, 3, new byte[] {0, 1, 2}));
     }
     ImmutableSet<DelegationSignerData> commonDsData = builder.build();
 
@@ -573,16 +604,20 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
         "domain_update_dsdata_add.xml",
         commonDsData,
         ImmutableSet.copyOf(
-            union(commonDsData, ImmutableSet.of(DelegationSignerData.create(
-                12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))))));
+            union(
+                commonDsData,
+                ImmutableSet.of(
+                    DelegationSignerData.create(
+                        12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))))));
   }
 
   @Test
   public void testSuccess_secDnsRemove() throws Exception {
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_rem.xml",
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))),
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))),
         ImmutableSet.of(SOME_DSDATA));
   }
 
@@ -591,8 +626,9 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // As an aside, this test also validates that it's ok to set the 'urgent' attribute to false.
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_rem_all.xml",
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))),
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))),
         ImmutableSet.of());
   }
 
@@ -600,28 +636,36 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
   public void testSuccess_secDnsAddRemove() throws Exception {
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_add_rem.xml",
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))),
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))),
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))));
   }
 
   @Test
   public void testSuccess_secDnsAddRemoveToMaxRecords() throws Exception {
     ImmutableSet.Builder<DelegationSignerData> builder = new ImmutableSet.Builder<>();
     for (int i = 0; i < 7; ++i) {
-      builder.add(DelegationSignerData.create(i, 2, 3, new byte[]{0, 1, 2}));
+      builder.add(DelegationSignerData.create(i, 2, 3, new byte[] {0, 1, 2}));
     }
     ImmutableSet<DelegationSignerData> commonDsData = builder.build();
 
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_add_rem.xml",
         ImmutableSet.copyOf(
-            union(commonDsData, ImmutableSet.of(DelegationSignerData.create(
-                12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))))),
+            union(
+                commonDsData,
+                ImmutableSet.of(
+                    DelegationSignerData.create(
+                        12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))))),
         ImmutableSet.copyOf(
-            union(commonDsData, ImmutableSet.of(DelegationSignerData.create(
-                12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))))));
+            union(
+                commonDsData,
+                ImmutableSet.of(
+                    DelegationSignerData.create(
+                        12346, 3, 1, base16().decode("38EC35D5B3A34B44C39B"))))));
   }
 
   @Test
@@ -629,44 +673,43 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // Adding and removing the same dsData is a no-op because removes are processed first.
     doSecDnsSuccessfulTest(
         "domain_update_dsdata_add_rem_same.xml",
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))),
-        ImmutableSet.of(SOME_DSDATA, DelegationSignerData.create(
-            12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))));
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))),
+        ImmutableSet.of(
+            SOME_DSDATA,
+            DelegationSignerData.create(12345, 3, 1, base16().decode("38EC35D5B3A34B33C99B"))));
   }
 
   @Test
   public void testSuccess_secDnsRemoveAlreadyNotThere() throws Exception {
     // Removing a dsData that isn't there is a no-op.
     doSecDnsSuccessfulTest(
-        "domain_update_dsdata_rem.xml",
-        ImmutableSet.of(SOME_DSDATA),
-        ImmutableSet.of(SOME_DSDATA));
+        "domain_update_dsdata_rem.xml", ImmutableSet.of(SOME_DSDATA), ImmutableSet.of(SOME_DSDATA));
   }
 
   public void doServerStatusBillingTest(String xmlFilename, boolean isBillable) throws Exception {
     setEppInput(xmlFilename);
     clock.advanceOneMilli();
     runFlowAssertResponse(
-        CommitMode.LIVE,
-        UserPrivileges.SUPERUSER,
-        loadFile("domain_update_response.xml"));
+        CommitMode.LIVE, UserPrivileges.SUPERUSER, loadFile("domain_update_response.xml"));
 
-     if (isBillable) {
-       assertBillingEvents(
-           new BillingEvent.OneTime.Builder()
-               .setReason(Reason.SERVER_STATUS)
-               .setTargetId("example.tld")
-               .setClientId("TheRegistrar")
-               .setCost(Money.of(USD, 19))
-               .setEventTime(clock.nowUtc())
-               .setBillingTime(clock.nowUtc())
-               .setParent(getOnlyHistoryEntryOfType(
-                   reloadResourceByForeignKey(), HistoryEntry.Type.DOMAIN_UPDATE))
-               .build());
-     } else {
-       assertNoBillingEvents();
-     }
+    if (isBillable) {
+      assertBillingEvents(
+          new BillingEvent.OneTime.Builder()
+              .setReason(Reason.SERVER_STATUS)
+              .setTargetId("example.tld")
+              .setClientId("TheRegistrar")
+              .setCost(Money.of(USD, 19))
+              .setEventTime(clock.nowUtc())
+              .setBillingTime(clock.nowUtc())
+              .setParent(
+                  getOnlyHistoryEntryOfType(
+                      reloadResourceByForeignKey(), HistoryEntry.Type.DOMAIN_UPDATE))
+              .build());
+    } else {
+      assertNoBillingEvents();
+    }
   }
 
   @Test
@@ -682,9 +725,7 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     eppRequestSource = EppRequestSource.TOOL;
     DomainResource addStatusDomain = persistActiveDomain(getUniqueIdFromCommand());
     persistResource(
-        addStatusDomain.asBuilder()
-            .addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED)
-            .build());
+        addStatusDomain.asBuilder().addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED).build());
     doServerStatusBillingTest("domain_update_add_server_status.xml", false);
   }
 
@@ -694,9 +735,7 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     DomainResource removeStatusDomain = persistDomain();
     persistResource(
-        removeStatusDomain.asBuilder()
-            .addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED)
-            .build());
+        removeStatusDomain.asBuilder().addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED).build());
     doServerStatusBillingTest("domain_update_remove_server_status.xml", true);
   }
 
@@ -706,9 +745,7 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     DomainResource changeStatusDomain = persistDomain();
     persistResource(
-        changeStatusDomain.asBuilder()
-            .addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED)
-            .build());
+        changeStatusDomain.asBuilder().addStatusValue(StatusValue.SERVER_RENEW_PROHIBITED).build());
     doServerStatusBillingTest("domain_update_change_server_status.xml", true);
   }
 
@@ -736,31 +773,32 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_add_server_hold_status.xml");
     persistReferencedEntities();
     persistResource(
-        persistActiveDomain(getUniqueIdFromCommand()).asBuilder()
+        persistActiveDomain(getUniqueIdFromCommand())
+            .asBuilder()
             .setStatusValues(ImmutableSet.of(StatusValue.CLIENT_UPDATE_PROHIBITED))
             .build());
     clock.advanceOneMilli();
     runFlowAssertResponse(
-        CommitMode.LIVE,
-        UserPrivileges.SUPERUSER,
-        loadFile("domain_update_response.xml"));
-    assertAboutDomains().that(reloadResourceByForeignKey())
-        .hasStatusValue(StatusValue.CLIENT_UPDATE_PROHIBITED).and()
+        CommitMode.LIVE, UserPrivileges.SUPERUSER, loadFile("domain_update_response.xml"));
+    assertAboutDomains()
+        .that(reloadResourceByForeignKey())
+        .hasStatusValue(StatusValue.CLIENT_UPDATE_PROHIBITED)
+        .and()
         .hasStatusValue(StatusValue.SERVER_HOLD);
   }
 
-  private void doSecDnsFailingTest(Class<? extends Exception> expectedException, String xmlFilename)
-      throws Exception {
+  private void doSecDnsFailingTest(
+      Class<? extends EppException> expectedException, String xmlFilename) throws Exception {
     setEppInput(xmlFilename);
     persistReferencedEntities();
     persistActiveDomain(getUniqueIdFromCommand());
-    assertThrows(expectedException, this::runFlow);
+    EppException thrown = expectThrows(expectedException, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_secDnsAllCannotBeFalse() throws Exception {
-    doSecDnsFailingTest(
-        SecDnsAllUsageException.class, "domain_update_dsdata_rem_all_false.xml");
+    doSecDnsFailingTest(SecDnsAllUsageException.class, "domain_update_dsdata_rem_all_false.xml");
   }
 
   @Test
@@ -771,30 +809,27 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
   @Test
   public void testFailure_secDnsUrgentNotSupported() throws Exception {
     doSecDnsFailingTest(
-        UrgentAttributeNotSupportedException.class,
-        "domain_update_dsdata_urgent.xml");
+        UrgentAttributeNotSupportedException.class, "domain_update_dsdata_urgent.xml");
   }
 
   @Test
   public void testFailure_secDnsChangeNotSupported() throws Exception {
     doSecDnsFailingTest(
-        MaxSigLifeChangeNotSupportedException.class,
-        "domain_update_maxsiglife.xml");
+        MaxSigLifeChangeNotSupportedException.class, "domain_update_maxsiglife.xml");
   }
 
   @Test
   public void testFailure_secDnsTooManyDsRecords() throws Exception {
     ImmutableSet.Builder<DelegationSignerData> builder = new ImmutableSet.Builder<>();
     for (int i = 0; i < 8; ++i) {
-      builder.add(DelegationSignerData.create(i, 2, 3, new byte[]{0, 1, 2}));
+      builder.add(DelegationSignerData.create(i, 2, 3, new byte[] {0, 1, 2}));
     }
 
     setEppInput("domain_update_dsdata_add.xml");
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setDsData(builder.build())
-            .build());
-    assertThrows(TooManyDsRecordsException.class, this::runFlow);
+        newDomainResource(getUniqueIdFromCommand()).asBuilder().setDsData(builder.build()).build());
+    EppException thrown = expectThrows(TooManyDsRecordsException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -804,7 +839,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistDomain();
     // Modify domain so it has 13 nameservers. We will then try to add one in the test.
     modifyDomainToHave13Nameservers();
-    assertThrows(TooManyNameserversException.class, this::runFlow);
+    EppException thrown = expectThrows(TooManyNameserversException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -812,7 +848,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_wrong_extension.xml");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(UnimplementedExtensionException.class, this::runFlow);
+    EppException thrown = expectThrows(UnimplementedExtensionException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -862,12 +899,17 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     // Add a tech contact to the persisted entity, which should cause the flow to fail when it tries
     // to add "mak21" as a second tech contact.
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
-            .setContacts(ImmutableSet.of(
-                DesignatedContact.create(Type.TECH, Key.create(
-                    loadByForeignKey(ContactResource.class, "foo", clock.nowUtc())))))
+        reloadResourceByForeignKey()
+            .asBuilder()
+            .setContacts(
+                ImmutableSet.of(
+                    DesignatedContact.create(
+                        Type.TECH,
+                        Key.create(
+                            loadByForeignKey(ContactResource.class, "foo", clock.nowUtc())))))
             .build());
-    assertThrows(DuplicateContactForRoleException.class, this::runFlow);
+    EppException thrown = expectThrows(DuplicateContactForRoleException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -875,7 +917,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_prohibited_status.xml");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(StatusNotClientSettableException.class, this::runFlow);
+    EppException thrown = expectThrows(StatusNotClientSettableException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -932,17 +975,21 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_authinfo.xml");
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
             .setStatusValues(ImmutableSet.of(StatusValue.CLIENT_UPDATE_PROHIBITED))
             .build());
-    assertThrows(ResourceHasClientUpdateProhibitedException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(ResourceHasClientUpdateProhibitedException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
   public void testFailure_serverUpdateProhibited() throws Exception {
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
             .setStatusValues(ImmutableSet.of(SERVER_UPDATE_PROHIBITED))
             .build());
     ResourceStatusProhibitsOperationException thrown =
@@ -954,7 +1001,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
   public void testFailure_pendingDelete() throws Exception {
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
             .setDeletionTime(clock.nowUtc().plusDays(1))
             .addStatusValue(StatusValue.PENDING_DELETE)
             .build());
@@ -968,7 +1016,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_duplicate_contact.xml");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(DuplicateContactForRoleException.class, this::runFlow);
+    EppException thrown = expectThrows(DuplicateContactForRoleException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -977,7 +1026,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_missing_contact_type.xml");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(MissingContactTypeException.class, this::runFlow);
+    EppException thrown = expectThrows(MissingContactTypeException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -985,7 +1035,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     sessionMetadata.setClientId("NewRegistrar");
     persistReferencedEntities();
     persistDomain();
-    assertThrows(ResourceNotOwnedException.class, this::runFlow);
+    EppException thrown = expectThrows(ResourceNotOwnedException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1004,7 +1055,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
         loadRegistrar("TheRegistrar").asBuilder().setAllowedTlds(ImmutableSet.of()).build());
     persistReferencedEntities();
     persistDomain();
-    assertThrows(NotAuthorizedForTldException.class, this::runFlow);
+    EppException thrown = expectThrows(NotAuthorizedForTldException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1023,11 +1075,15 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_add_remove_same_host.xml");
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setNameservers(ImmutableSet.of(Key.create(
-                loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc()))))
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
+            .setNameservers(
+                ImmutableSet.of(
+                    Key.create(
+                        loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc()))))
             .build());
-    assertThrows(AddRemoveSameValueException.class, this::runFlow);
+    EppException thrown = expectThrows(AddRemoveSameValueException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1035,13 +1091,17 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_add_remove_same_contact.xml");
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setContacts(ImmutableSet.of(DesignatedContact.create(
-                Type.TECH,
-                Key.create(
-                    loadByForeignKey(ContactResource.class, "sh8013", clock.nowUtc())))))
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
+            .setContacts(
+                ImmutableSet.of(
+                    DesignatedContact.create(
+                        Type.TECH,
+                        Key.create(
+                            loadByForeignKey(ContactResource.class, "sh8013", clock.nowUtc())))))
             .build());
-    assertThrows(AddRemoveSameValueException.class, this::runFlow);
+    EppException thrown = expectThrows(AddRemoveSameValueException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1049,12 +1109,15 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_remove_admin.xml");
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setContacts(ImmutableSet.of(
-                DesignatedContact.create(Type.ADMIN, Key.create(sh8013Contact)),
-                DesignatedContact.create(Type.TECH, Key.create(sh8013Contact))))
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
+            .setContacts(
+                ImmutableSet.of(
+                    DesignatedContact.create(Type.ADMIN, Key.create(sh8013Contact)),
+                    DesignatedContact.create(Type.TECH, Key.create(sh8013Contact))))
             .build());
-    assertThrows(MissingAdminContactException.class, this::runFlow);
+    EppException thrown = expectThrows(MissingAdminContactException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1062,12 +1125,15 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_remove_tech.xml");
     persistReferencedEntities();
     persistResource(
-        newDomainResource(getUniqueIdFromCommand()).asBuilder()
-            .setContacts(ImmutableSet.of(
-                DesignatedContact.create(Type.ADMIN, Key.create(sh8013Contact)),
-                DesignatedContact.create(Type.TECH, Key.create(sh8013Contact))))
+        newDomainResource(getUniqueIdFromCommand())
+            .asBuilder()
+            .setContacts(
+                ImmutableSet.of(
+                    DesignatedContact.create(Type.ADMIN, Key.create(sh8013Contact)),
+                    DesignatedContact.create(Type.TECH, Key.create(sh8013Contact))))
             .build());
-    assertThrows(MissingTechnicalContactException.class, this::runFlow);
+    EppException thrown = expectThrows(MissingTechnicalContactException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1077,13 +1143,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistActiveHost("ns1.example.foo");
     persistActiveHost("ns2.example.foo");
     persistActiveContact("sh8013");
-    persistResource(loadByForeignKey(ContactResource.class, "mak21", clock.nowUtc()).asBuilder()
-        .addStatusValue(StatusValue.PENDING_DELETE)
-        .build());
+    persistResource(
+        loadByForeignKey(ContactResource.class, "mak21", clock.nowUtc())
+            .asBuilder()
+            .addStatusValue(StatusValue.PENDING_DELETE)
+            .build());
     clock.advanceOneMilli();
     LinkedResourceInPendingDeleteProhibitsOperationException thrown =
-        expectThrows(
-            LinkedResourceInPendingDeleteProhibitsOperationException.class, this::runFlow);
+        expectThrows(LinkedResourceInPendingDeleteProhibitsOperationException.class, this::runFlow);
     assertThat(thrown).hasMessageThat().contains("mak21");
   }
 
@@ -1095,13 +1162,13 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistActiveContact("mak21");
     persistActiveContact("sh8013");
     persistResource(
-        loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()).asBuilder()
-          .addStatusValue(StatusValue.PENDING_DELETE)
-          .build());
+        loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())
+            .asBuilder()
+            .addStatusValue(StatusValue.PENDING_DELETE)
+            .build());
     clock.advanceOneMilli();
     LinkedResourceInPendingDeleteProhibitsOperationException thrown =
-        expectThrows(
-            LinkedResourceInPendingDeleteProhibitsOperationException.class, this::runFlow);
+        expectThrows(LinkedResourceInPendingDeleteProhibitsOperationException.class, this::runFlow);
     assertThat(thrown).hasMessageThat().contains("ns2.example.foo");
   }
 
@@ -1110,11 +1177,13 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     persistDomain();
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedRegistrantContactIds(ImmutableSet.of("contact1234"))
             .build());
     clock.advanceOneMilli();
-    assertThrows(RegistrantNotAllowedException.class, this::runFlow);
+    EppException thrown = expectThrows(RegistrantNotAllowedException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1122,11 +1191,13 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     persistDomain();
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedFullyQualifiedHostNames(ImmutableSet.of("ns1.example.foo"))
             .build());
     clock.advanceOneMilli();
-    assertThrows(NameserversNotAllowedForTldException.class, this::runFlow);
+    EppException thrown = expectThrows(NameserversNotAllowedForTldException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1136,16 +1207,19 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistDomain();
     // No registrant is given but both nameserver and registrant whitelist exist.
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedRegistrantContactIds(ImmutableSet.of("sh8013"))
             .setAllowedFullyQualifiedHostNames(
                 ImmutableSet.of("ns1.example.foo", "ns2.example.foo"))
             .build());
-    assertThat(reloadResourceByForeignKey().getNameservers()).doesNotContain(
-        Key.create(loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
+    assertThat(reloadResourceByForeignKey().getNameservers())
+        .doesNotContain(
+            Key.create(loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
     runFlow();
-    assertThat(reloadResourceByForeignKey().getNameservers()).contains(
-        Key.create(loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
+    assertThat(reloadResourceByForeignKey().getNameservers())
+        .contains(
+            Key.create(loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc())));
   }
 
   @Test
@@ -1155,7 +1229,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistDomain();
     // Only changes registrant, with both nameserver and registrant whitelist on the TLD.
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedRegistrantContactIds(ImmutableSet.of("sh8013"))
             .setAllowedFullyQualifiedHostNames(ImmutableSet.of("ns1.example.foo"))
             .build());
@@ -1169,7 +1244,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     persistDomain();
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedRegistrantContactIds(ImmutableSet.of("sh8013"))
             .setAllowedFullyQualifiedHostNames(ImmutableSet.of("ns2.example.foo"))
             .build());
@@ -1182,21 +1258,27 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistReferencedEntities();
     persistDomain();
     persistResource(
-        reloadResourceByForeignKey().asBuilder()
-            .addNameservers(ImmutableSet.of(Key.create(
-                loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
+        reloadResourceByForeignKey()
+            .asBuilder()
+            .addNameservers(
+                ImmutableSet.of(
+                    Key.create(
+                        loadByForeignKey(HostResource.class, "ns2.example.foo", clock.nowUtc()))))
             .build());
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedFullyQualifiedHostNames(
                 ImmutableSet.of("ns1.example.foo", "ns2.example.foo"))
             .build());
-    assertThat(reloadResourceByForeignKey().getNameservers()).contains(
-        Key.create(loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc())));
+    assertThat(reloadResourceByForeignKey().getNameservers())
+        .contains(
+            Key.create(loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc())));
     clock.advanceOneMilli();
     runFlow();
-    assertThat(reloadResourceByForeignKey().getNameservers()).doesNotContain(
-        Key.create(loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc())));
+    assertThat(reloadResourceByForeignKey().getNameservers())
+        .doesNotContain(
+            Key.create(loadByForeignKey(HostResource.class, "ns1.example.foo", clock.nowUtc())));
   }
 
   @Test
@@ -1205,11 +1287,14 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     persistDomain();
     setEppInput("domain_update_remove_nameserver.xml");
     persistResource(
-        Registry.get("tld").asBuilder()
+        Registry.get("tld")
+            .asBuilder()
             .setAllowedFullyQualifiedHostNames(ImmutableSet.of("ns1.example.foo"))
             .build());
-    assertThrows(
-        NameserversNotSpecifiedForTldWithNameserverWhitelistException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(
+            NameserversNotSpecifiedForTldWithNameserverWhitelistException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1254,8 +1339,10 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
                 persistReservedList(
                     "reserved", "example,NAMESERVER_RESTRICTED,ns1.example.foo:ns2.example.foo"))
             .build());
-    assertThrows(
-        NameserversNotSpecifiedForNameserverRestrictedDomainException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(
+            NameserversNotSpecifiedForNameserverRestrictedDomainException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1372,7 +1459,9 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
                 persistReservedList(
                     "reserved", "lol,NAMESERVER_RESTRICTED,ns1.example.foo:ns2.example.foo"))
             .build());
-    assertThrows(DomainNotAllowedForTldWithCreateRestrictionException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(DomainNotAllowedForTldWithCreateRestrictionException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1387,7 +1476,9 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
                 persistReservedList(
                     "reserved", "lol,NAMESERVER_RESTRICTED,ns1.example.foo:ns2.example.foo"))
             .build());
-    assertThrows(DomainNotAllowedForTldWithCreateRestrictionException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(DomainNotAllowedForTldWithCreateRestrictionException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test
@@ -1441,7 +1532,8 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_fee.xml", ImmutableMap.of("FEE_VERSION", "0.11"));
     persistReferencedEntities();
     persistDomain();
-    assertThrows(FeesMismatchException.class, this::runFlow);
+    EppException thrown = expectThrows(FeesMismatchException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   // This test should throw an exception, because the fee extension is required when the fee is not
@@ -1451,7 +1543,9 @@ public class DomainUpdateFlowTest extends ResourceFlowTestCase<DomainUpdateFlow,
     setEppInput("domain_update_wildcard.xml", ImmutableMap.of("DOMAIN", "non-free-update.tld"));
     persistReferencedEntities();
     persistDomain();
-    assertThrows(FeesRequiredForNonFreeOperationException.class, this::runFlow);
+    EppException thrown =
+        expectThrows(FeesRequiredForNonFreeOperationException.class, this::runFlow);
+    assertAboutEppExceptions().that(thrown).marshalsToXml();
   }
 
   @Test