diff --git a/src/java/com/threerings/presents/client/BlockingCommunicator.java b/src/java/com/threerings/presents/client/BlockingCommunicator.java index 7450b4627..f3b989a38 100644 --- a/src/java/com/threerings/presents/client/BlockingCommunicator.java +++ b/src/java/com/threerings/presents/client/BlockingCommunicator.java @@ -953,8 +953,13 @@ public class BlockingCommunicator extends Communicator return; } - // make sure we're not exceeding our outgoing throttle rate - throttleOutgoingMessage(); + // if we're exceeding our outgoing throttle rate, drop the packet + Throttle throttle = _client.getOutgoingMessageThrottle(); + synchronized(throttle) { + if (throttle.throttleOp()) { + return; + } + } try { // write the message out the socket