@Test
public void shouldPublishFromAppMessage() throws Exception {

	Message message = mock(Message.class);
	SessionID sessionId = mock(SessionID.class);
	clientApplication.fromApp(message, sessionId);
	await().atMost(FIVE_SECONDS).until(() -> receivedEvents.size() > 0);
	assertThat(receivedEvents.get(0)).isInstanceOf(FromApp.class);
	assertThat(((FromApp) receivedEvents.get(0)).getMessage()).isEqualTo(message);
	assertThat(((FromApp) receivedEvents.get(0)).getSessionId()).isEqualTo(sessionId);
}