private void sendEvent ( EventHolder event , Connection connection ) { PublishRequest request = PublishRequest . builder ( ) . withSession ( id ( ) ) . withEventIndex ( event . eventIndex ) . withPreviousIndex ( Math . max ( event . previousIndex , completeIndex ) ) . withEvents ( event . events ) . build ( ) ; LOGGER . trace ( "{} - Sending {}" , id , request ) ; connection . send ( request ) ; }
Sends an event .