@Test public void messageReceived() { final String body = "[\"some message\"]"; final FullHttpResponse response = processHttpRequest(requestWithBody(body)); assertThat(response.getStatus(), equalTo(HttpResponseStatus.OK)); assertThat(response.getProtocolVersion(), equalTo(HttpVersion.HTTP_1_1)); assertThat(response.content().toString(CharsetUtil.UTF_8), equalTo("ok")); SockJsTestUtil.verifyDefaultResponseHeaders(response, Transports.CONTENT_TYPE_PLAIN); }
@Override public String toString() { return StringUtil.simpleClassName(this) + "[config=" + config + ']'; }
JsonpSendTransport extends AbstractSendTransport { @Override public String toString() { return StringUtil.simpleClassName(this) + "[config=" + config + ']'; } }
JsonpSendTransport extends AbstractSendTransport { @Override public String toString() { return StringUtil.simpleClassName(this) + "[config=" + config + ']'; } JsonpSendTransport(final SockJsConfig config); }
JsonpSendTransport extends AbstractSendTransport { @Override public String toString() { return StringUtil.simpleClassName(this) + "[config=" + config + ']'; } JsonpSendTransport(final SockJsConfig config); @Override void respond(final ChannelHandlerContext ctx, final FullHttpRequest request); @Override String toString(); }
JsonpSendTransport extends AbstractSendTransport { @Override public String toString() { return StringUtil.simpleClassName(this) + "[config=" + config + ']'; } JsonpSendTransport(final SockJsConfig config); @Override void respond(final ChannelHandlerContext ctx, final FullHttpRequest request); @Override String toString();  }