diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/providers/MultiRecipientMessageProvider.java b/service/src/main/java/org/whispersystems/textsecuregcm/providers/MultiRecipientMessageProvider.java index 4adfb1c65..86e9f4142 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/providers/MultiRecipientMessageProvider.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/providers/MultiRecipientMessageProvider.java @@ -5,7 +5,11 @@ package org.whispersystems.textsecuregcm.providers; +import static org.whispersystems.textsecuregcm.metrics.MetricsUtil.name; + import io.dropwizard.util.DataSizeUnit; +import io.micrometer.core.instrument.DistributionSummary; +import io.micrometer.core.instrument.Metrics; import java.io.IOException; import java.io.InputStream; import java.lang.annotation.Annotation; @@ -18,9 +22,9 @@ import javax.ws.rs.core.NoContentException; import javax.ws.rs.ext.MessageBodyReader; import javax.ws.rs.ext.Provider; -import org.signal.libsignal.protocol.SealedSenderMultiRecipientMessage; import org.signal.libsignal.protocol.InvalidMessageException; import org.signal.libsignal.protocol.InvalidVersionException; +import org.signal.libsignal.protocol.SealedSenderMultiRecipientMessage; @Provider @Consumes(MultiRecipientMessageProvider.MEDIA_TYPE) @@ -30,6 +34,11 @@ public class MultiRecipientMessageProvider implements MessageBodyReader type, Type genericType, Annotation[] annotations, MediaType mediaType) { return MEDIA_TYPE.equals(mediaType.toString()) && SealedSenderMultiRecipientMessage.class.isAssignableFrom(type); @@ -46,6 +55,8 @@ public SealedSenderMultiRecipientMessage readFrom(Class message.messageSizeForRecipient(r) > MAX_MESSAGE_SIZE)) { throw new BadRequestException("message payload too large"); }