Skip to content

Commit

Permalink
chore(deps): upgrade Go-Akt to v2.9.0
Browse files Browse the repository at this point in the history
  • Loading branch information
Tochemey committed Nov 28, 2024
1 parent 7661d97 commit d691057
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ func (engine *Engine) IsProjectionRunning(ctx context.Context, name string) (boo
return pid.IsRunning(), nil
}

return addr != nil && proto.Equal(addr.Address, address.NoSender), nil
return addr.Equals(address.NoSender()), nil
}

// Stop stops the ego engine
Expand Down Expand Up @@ -283,7 +283,7 @@ func (engine *Engine) SendCommand(ctx context.Context, entityID string, cmd Comm
case pid != nil:
reply, err = actors.Ask(ctx, pid, cmd, timeout)
case addr != nil:
res, err := engine.remoting.RemoteAsk(ctx, addr, cmd, timeout)
res, err := engine.remoting.RemoteAsk(ctx, address.NoSender(), addr, cmd, timeout)
if err == nil {
// let us unmarshal the response
reply, err = res.UnmarshalNew()
Expand Down

0 comments on commit d691057

Please sign in to comment.