sends byte arrays as event series to apache flume . concode_field_sep boolean initDone concode_elem_sep String hostname concode_elem_sep int port concode_elem_sep boolean closeWithoutSend concode_elem_sep String host concode_elem_sep RpcClient client concode_elem_sep long serialVersionUID concode_elem_sep boolean sendAndClose concode_elem_sep Logger LOG concode_field_sep byte[] serialize concode_elem_sep void init concode_elem_sep void closeWithoutSend concode_elem_sep void invoke concode_elem_sep void sendAndClose concode_elem_sep void close
void function ( byte [ ] arg0 ) { Event loc0 = EventBuilder . withBody ( arg0 ) ; try { client . append ( loc0 ) ; } catch ( EventDeliveryException loc1 ) { client . close ( ) ; client = null ; client = RpcClientFactory . getDefaultInstance ( hostname , port ) ; } }