}
for _, message := range queue.Pending {
- if message.Target == agent.config.Name {
+ if (message.Notification && message.TargetID != "" && message.TargetID == agent.config.ID) || (message.TargetID == "" && message.Target == agent.config.Name) {
return fmt.Errorf("import refused: agent %q has pending deliveries", agent.config.Name)
}
}