luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

KCL more aggressively logs errors

Browse source
This commit is contained in:
Xavi Ramirez 2017-07-21 01:27:17 +00:00
parent ae37b57e61
commit 0cb14948a3
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
kcl/kcl.go
View file

@ -284,11 +284,17 @@ func (kclp *KCLProcess) Run() {
for { for {
line, err := kclp.ioHandler.readLine() line, err := kclp.ioHandler.readLine()
if err != nil { if err != nil {
kclp.ioHandler.writeError(err.Error()) kclp.ioHandler.writeError("Read line error: " + err.Error())
return return
} else if line == nil { } else if line == nil {
break kclp.ioHandler.writeError("Empty read line recieved")
return
}
err = kclp.handleLine(line.String())
if err != nil {
kclp.ioHandler.writeError("Handle line error: " + err.Error())
return
} }
kclp.handleLine(line.String())
} }
} }