diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
index c7a58247f..e81a1446a 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
@@ -361,10 +361,7 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
         .limitRate(MESSAGE_PUBLISHER_LIMIT_RATE)
         .flatMapSequential(envelope ->
             Mono.fromFuture(() -> sendMessage(envelope)
-                        .orTimeout(sendFuturesTimeoutMillis, TimeUnit.MILLISECONDS),
-                    // suppressCancel=true, because attempting to cancel the future has no effect, other than
-                    // causing dropped errors
-                    true)
+                    .orTimeout(sendFuturesTimeoutMillis, TimeUnit.MILLISECONDS))
                 .onErrorResume(
                     // let the first error pass through to terminate the subscription
                     e -> {