diff --git a/agents/diamagent.go b/agents/diamagent.go index 00a76e9c3..92151056c 100644 --- a/agents/diamagent.go +++ b/agents/diamagent.go @@ -256,7 +256,8 @@ func (da *DiameterAgent) handleMessage(c diam.Conn, m *diam.Message) { utils.DiameterAgent, err.Error(), m)) writeOnConn(c, diamErr) return - } else if !processed { + } + if !processed { utils.Logger.Warning( fmt.Sprintf("<%s> no request processor enabled, ignoring message %s from %s", utils.DiameterAgent, m, c.RemoteAddr())) @@ -269,7 +270,8 @@ func (da *DiameterAgent) handleMessage(c diam.Conn, m *diam.Message) { utils.Logger.Warning( fmt.Sprintf("<%s> err: %s, replying to message: %+v", utils.DiameterAgent, err.Error(), m)) - + writeOnConn(c, diamErr) + return } writeOnConn(c, a) }