JettyXmppWebSocket implements WebSocket, WebSocket.OnTextMessage, Outbound { public void onMessage(String data) { LOG.info("< " + data); sessionContext.onMessage(data); } JettyXmppWebSocket(ServerRuntimeContext serverRuntimeContext, StanzaProcessor stanzaProcessor); void onOpen(Connection outbound); void onMessage(String data); void onClose(int closeCode, String message); void write(String xml);  }
@Test public void onMessage() { JettyXmppWebSocket context = new JettyXmppWebSocket(serverRuntimeContext, stanzaProcessor); context.onMessage("<test></test>"); Stanza expected = new StanzaBuilder("test").build(); Mockito.verify(stanzaProcessor).processStanza(Mockito.eq(serverRuntimeContext), Mockito.any(InternalSessionContext.class), Mockito.eq(expected), Mockito.any(SessionStateHolder.class)); }