cleaned up logging
This commit is contained in:
parent
52cecf4f26
commit
f4b8ef9c5d
|
@ -493,13 +493,15 @@ internal constructor(val type: Class<*>, internal val config: Configuration) : A
|
||||||
}
|
}
|
||||||
|
|
||||||
// more critical error sending the message. we shouldn't retry or anything.
|
// more critical error sending the message. we shouldn't retry or anything.
|
||||||
listenerManager.notifyError(newException("[${publication.sessionId()}] Error sending handshake message. $message (${
|
val exception = newException("[${publication.sessionId()}] Error sending handshake message. $message (${errorCodeName(result)})")
|
||||||
errorCodeName(result)
|
ListenerManager.cleanStackTrace(exception)
|
||||||
})"))
|
listenerManager.notifyError(exception)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
listenerManager.notifyError(newException("[${publication.sessionId()}] Error serializing handshake message $message", e))
|
val exception = newException("[${publication.sessionId()}] Error serializing handshake message $message", e)
|
||||||
|
ListenerManager.cleanStackTrace(exception)
|
||||||
|
listenerManager.notifyError(exception)
|
||||||
} finally {
|
} finally {
|
||||||
sendIdleStrategy.reset()
|
sendIdleStrategy.reset()
|
||||||
serialization.returnHandshakeKryo(kryo)
|
serialization.returnHandshakeKryo(kryo)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user