diff options
Diffstat (limited to 'internal/federation/federatingdb/move.go')
| -rw-r--r-- | internal/federation/federatingdb/move.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/internal/federation/federatingdb/move.go b/internal/federation/federatingdb/move.go index 2e8049e08..59dc2529c 100644 --- a/internal/federation/federatingdb/move.go +++ b/internal/federation/federatingdb/move.go @@ -170,12 +170,12 @@ func (f *federatingDB) Move(ctx context.Context, move vocab.ActivityStreamsMove) // We had a Move already or stored a new Move. // Pass back to a worker for async processing. - f.state.Workers.EnqueueFediAPI(ctx, messages.FromFediAPI{ - APObjectType: ap.ObjectProfile, - APActivityType: ap.ActivityMove, - GTSModel: stubMove, - RequestingAccount: requestingAcct, - ReceivingAccount: receivingAcct, + f.state.Workers.Federator.Queue.Push(&messages.FromFediAPI{ + APObjectType: ap.ObjectProfile, + APActivityType: ap.ActivityMove, + GTSModel: stubMove, + Requesting: requestingAcct, + Receiving: receivingAcct, }) return nil |