mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-29 01:33:10 -06:00
Update logging
This commit is contained in:
parent
f1a19e74d7
commit
040bce77d2
|
|
@ -267,7 +267,6 @@ func (t *OutputEDUConsumer) onPresenceData(msg *sarama.ConsumerMessage) error {
|
||||||
log.WithError(err).Errorf("eduserver output log: message parse failed (expected presence)")
|
log.WithError(err).Errorf("eduserver output log: message parse failed (expected presence)")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
log.Debugf("Sending Presence to federated servers: %+v", presence)
|
|
||||||
|
|
||||||
// only send presence events which originated from us
|
// only send presence events which originated from us
|
||||||
_, senderServerName, err := gomatrixserverlib.SplitID('@', presence.UserID)
|
_, senderServerName, err := gomatrixserverlib.SplitID('@', presence.UserID)
|
||||||
|
|
@ -305,7 +304,7 @@ func (t *OutputEDUConsumer) onPresenceData(msg *sarama.ConsumerMessage) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Debugf("Sending edu to federated servers: %+v", edu)
|
log.Debugf("Sending edu to federated servers: %s", string(edu.Content))
|
||||||
|
|
||||||
return t.queues.SendEDU(edu, t.ServerName, joined)
|
return t.queues.SendEDU(edu, t.ServerName, joined)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue