func (l *TCPListener) Start() {
	log.Infof("Starting TCP forwarder on port %d, with read buffer size: %d", l.source.Config.Port, l.frameSize)
	err := l.startListener()
	if err != nil {
		log.Errorf("Can't start TCP forwarder on port %d: %v", l.source.Config.Port, err)
		l.source.Status.Error(err)
		return
	}
	l.source.Status.Success()
	go l.run()
}
// Start starts the listener to accepts new incoming connections.
Start starts the listener to accepts new incoming connections.
// Start starts the listener to accepts new incoming connections .
func (l *TCPListener) Start() {
	log.Infof("Starting TCP forwarder on port %d, with read buffer size: %d", l.source.Config.Port, l.frameSize)
	err := l.startListener()
	if err != nil {
		log.Errorf("Can't start TCP forwarder on port %d: %v", l.source.Config.Port, err)
		l.source.Status.Error(err)
		return
	}
	l.source.Status.Success()
	go l.run()
}
func ( l * TCPListener ) Start ( ) { log . Infof ( " " , l . source . Config . Port , l . frameSize ) err := l . startListener ( ) if err != nil { log . Errorf ( " " , l . source . Config . Port , err ) l . source . Status . Error ( err ) return } l . source . Status . Success ( ) go l . run ( ) }
Start starts the listener to accepts new incoming connections.
Start starts the listener to accepts new incoming connections .