put a new message to the stream . the message will be broadcast to all registered sse clients . concode_field_sep AtomicLong nextMessageId concode_elem_sep SseBroadcaster broadcaster concode_elem_sep Logger LOGGER concode_field_sep EventOutput getMessageStream concode_elem_sep void onException
void function ( final Message arg0 ) { LOGGER . info ( "srini_string" ) ; final OutboundEvent loc0 = new OutboundEvent . Builder ( ) . id ( String . valueOf ( nextMessageId . getAndIncrement ( ) ) ) . mediaType ( MediaType . APPLICATION_JSON_TYPE ) . data ( Message . class , arg0 ) . build ( ) ; broadcaster . broadcast ( loc0 ) ; }