### Question:
PutEventsRequestMarshaller implements
        Marshaller<Request<PutEventsRequest>, PutEventsRequest> { @Override public Request<PutEventsRequest> marshall(PutEventsRequest putEventsRequest) { if (putEventsRequest == null) { throw new AmazonClientException("Invalid argument passed to marshall(PutEventsRequest)"); } final Request<PutEventsRequest> request = new DefaultRequest<PutEventsRequest>(putEventsRequest, "AmazonPinpointAnalytics"); request.setHttpMethod(HttpMethodName.POST); if (putEventsRequest.getClientContext() != null) { request.addHeader("x-amz-Client-Context", StringUtils.fromString(putEventsRequest.getClientContext())); } if (putEventsRequest.getClientContextEncoding() != null) { request.addHeader("x-amz-Client-Context-Encoding", StringUtils.fromString(putEventsRequest.getClientContextEncoding())); } final String uriResourcePath = "/2014-06-05/events"; request.setResourcePath(uriResourcePath); try { final ByteArrayOutputStream baos = new ByteArrayOutputStream(); final GZIPOutputStream gos = new GZIPOutputStream(baos, 8192); final Writer writer = new OutputStreamWriter(gos, StringUtils.UTF8); final AwsJsonWriter jsonWriter = JsonUtils.getJsonWriter(writer); jsonWriter.beginObject(); if (putEventsRequest.getEvents() != null) { final java.util.List<Event> events = putEventsRequest.getEvents(); jsonWriter.name("events"); jsonWriter.beginArray(); for (final Event eventsItem : events) { if (eventsItem != null) { EventJsonMarshaller.getInstance().marshall(eventsItem, jsonWriter); } } jsonWriter.endArray(); } jsonWriter.endObject(); jsonWriter.flush(); gos.finish(); writer.close(); final byte[] content = baos.toByteArray(); request.setContent(new ByteArrayInputStream(content)); request.addHeader("Content-Length", Integer.toString(content.length)); request.addHeader("Content-Encoding", "gzip"); } catch (final Throwable t) { throw new AmazonClientException( "Unable to marshall request to JSON: " + t.getMessage(), t); } if (!request.getHeaders().containsKey("Content-Type")) { request.addHeader("Content-Type", "application/x-amz-json-1.0"); } return request; }  @Override Request<PutEventsRequest> marshall(PutEventsRequest putEventsRequest);  }### Answer:
@Test public void test() throws Exception { PutEventsRequest putEventsRequest = new PutEventsRequest(); List<Event> events = new ArrayList<Event>(); events.add(createEvent()); events.add(createEvent()); putEventsRequest.setEvents(events); PutEventsRequestMarshaller marshaller = new PutEventsRequestMarshaller(); Request<PutEventsRequest> request = marshaller.marshall(putEventsRequest); assertEquals("content encoding", "gzip", request.getHeaders().get("Content-Encoding")); byte[] content = IOUtils.toByteArray(request.getContent()); System.out.println(content.length); assertEquals("content length", request.getHeaders().get("Content-Length"), String.valueOf(content.length)); GZIPInputStream gis = new GZIPInputStream(new ByteArrayInputStream(content)); String str = IOUtils.toString(gis); assertTrue("data is compressed", content.length < str.length()); }