public void sendEvent(JetstreamEvent event) throws EventException {
  if (m_stop || m_pause) {
    return;
  }
  if (event == null) {
    return;
  }
  incrementEventRecievedCounter();
  String streamType=event.getEventType();
  if (!m_streamTypeToHelperMap.containsKey(streamType)) {
    incrementEventDroppedCounter();
    return;
  }
  OutboundFileChannelHelper helper=m_streamTypeToHelperMap.get(streamType);
  FileChannelAddress address=helper.getAddress();
  JetstreamEvent userEvent=null;
  if (!address.isKeepReservedKeys()) {
    userEvent=event.getFilteredEvent();
  }
 else {
    userEvent=new JetstreamEvent();
    userEvent.putAll(event);
  }
  if (userEvent.size() == 0) {
    LOGGER.info("the event is empty. Should not happen?");
    incrementEventDroppedCounter();
    return;
  }
  String eventLineString=null;
  if (address.getColumnNameArray().length == 0) {
synchronized (this) {
      if (address.getColumnNameArray().length == 0) {
        Set<String> keys=userEvent.keySet();
        String[] keyArray=new String[keys.size()];
        keys.toArray(keyArray);
        address.setColumnNameArray(keyArray);
      }
    }
  }
  eventLineString=createEventLine(userEvent,address.getColumnNameArray(),address.getColumnDelimiter());
  if (helper.writeEvent(eventLineString)) {
    incrementEventSentCounter();
  }
 else {
    incrementEventDroppedCounter();
  }
}

public void sendEvent ( JetstreamEvent event ) throws EventException { if ( m_stop || m_pause ) { return ; } if ( event == null ) { return ; } incrementEventRecievedCounter ( ) ; String streamType = event . getEventType ( ) ; if ( ! m_streamTypeToHelperMap . containsKey ( streamType ) ) { incrementEventDroppedCounter ( ) ; return ; } OutboundFileChannelHelper helper = m_streamTypeToHelperMap . get ( streamType ) ; FileChannelAddress address = helper . getAddress ( ) ; JetstreamEvent userEvent = null ; if ( ! address . isKeepReservedKeys ( ) ) { userEvent = event . getFilteredEvent ( ) ; } else { userEvent = new JetstreamEvent ( ) ; userEvent . putAll ( event ) ; } if ( userEvent . size ( ) == 0 ) { LOGGER . info ( "the event is empty. Should not happen?" ) ; incrementEventDroppedCounter ( ) ; return ; } String eventLineString = null ; if ( address . getColumnNameArray ( ) . length == 0 ) { synchronized ( this ) { if ( address . getColumnNameArray ( ) . length == 0 ) { Set < String > keys = userEvent . keySet ( ) ; String [ ] keyArray = new String [ keys . size ( ) ] ; keys . toArray ( keyArray ) ; address . setColumnNameArray ( keyArray ) ; } } } eventLineString = createEventLine ( userEvent , address . getColumnNameArray ( ) , address . getColumnDelimiter ( ) ) ; if ( helper . writeEvent ( eventLineString ) ) { incrementEventSentCounter ( ) ; } else { incrementEventDroppedCounter ( ) ; } }
this is the point where the data get into this class
