diff --git a/client.go b/client.go index 58f5b53c..3f3fe759 100644 --- a/client.go +++ b/client.go @@ -461,6 +461,12 @@ func (c *Client) monitor(ctx context.Context) { // recreate them all if that fails. res, err := c.transferSubscriptions(ctx, subIDs) switch { + + case errors.Is(err, ua.StatusBadServiceUnsupported): + dlog.Printf("transfer subscriptions not supported. Recreating all subscriptions: %v", err) + subsToRepublish = nil + subsToRecreate = subIDs + case err != nil: dlog.Printf("transfer subscriptions failed. Recreating all subscriptions: %v", err) subsToRepublish = nil