aboutsummaryrefslogtreecommitdiff
path: root/appservice/consumers
diff options
context:
space:
mode:
authorTill Faelligen <2353100+S7evinK@users.noreply.github.com>2022-08-29 14:18:33 +0200
committerTill Faelligen <2353100+S7evinK@users.noreply.github.com>2022-08-29 14:18:33 +0200
commit21ef487ff8c36f7302e5fc47d3602ea0fc5ae3d3 (patch)
tree81ec3d742f0bf601f519fdacbfa01bc79fc07921 /appservice/consumers
parent704cc5c9f500bdd41a1c99ff2ae2fcef5eb74abb (diff)
Log roomserver error
Diffstat (limited to 'appservice/consumers')
-rw-r--r--appservice/consumers/roomserver.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/appservice/consumers/roomserver.go b/appservice/consumers/roomserver.go
index 37d4ef9c..d567408b 100644
--- a/appservice/consumers/roomserver.go
+++ b/appservice/consumers/roomserver.go
@@ -18,14 +18,15 @@ import (
"context"
"encoding/json"
+ "github.com/matrix-org/gomatrixserverlib"
+ "github.com/nats-io/nats.go"
+
"github.com/matrix-org/dendrite/appservice/storage"
"github.com/matrix-org/dendrite/appservice/types"
"github.com/matrix-org/dendrite/roomserver/api"
"github.com/matrix-org/dendrite/setup/config"
"github.com/matrix-org/dendrite/setup/jetstream"
"github.com/matrix-org/dendrite/setup/process"
- "github.com/matrix-org/gomatrixserverlib"
- "github.com/nats-io/nats.go"
log "github.com/sirupsen/logrus"
)
@@ -103,6 +104,7 @@ func (s *OutputRoomEventConsumer) onMessage(ctx context.Context, msg *nats.Msg)
}
if len(eventsReq.EventIDs) > 0 {
if err := s.rsAPI.QueryEventsByID(s.ctx, eventsReq, eventsRes); err != nil {
+ log.WithError(err).Errorf("s.rsAPI.QueryEventsByID failed")
return false
}
events = append(events, eventsRes.Events...)