@@ -573,9 +573,8 @@ AlterSubscription_refresh(Subscription *sub, bool copy_data)
573573 copy_data ? SUBREL_STATE_INIT : SUBREL_STATE_READY ,
574574 InvalidXLogRecPtr , false);
575575 ereport (DEBUG1 ,
576- (errmsg ("added subscription for table %s.%s" ,
577- quote_identifier (rv -> schemaname ),
578- quote_identifier (rv -> relname ))));
576+ (errmsg ("table \"%s.%s\" added to subscription \"%s\"" ,
577+ rv -> schemaname , rv -> relname , sub -> name )));
579578 }
580579 }
581580
@@ -593,17 +592,15 @@ AlterSubscription_refresh(Subscription *sub, bool copy_data)
593592 if (!bsearch (& relid , pubrel_local_oids ,
594593 list_length (pubrel_names ), sizeof (Oid ), oid_cmp ))
595594 {
596- char * namespace ;
597-
598595 RemoveSubscriptionRel (sub -> oid , relid );
599596
600597 logicalrep_worker_stop_at_commit (sub -> oid , relid );
601598
602- namespace = get_namespace_name (get_rel_namespace (relid ));
603599 ereport (DEBUG1 ,
604- (errmsg ("removed subscription for table %s.%s" ,
605- quote_identifier (namespace ),
606- quote_identifier (get_rel_name (relid )))));
600+ (errmsg ("table \"%s.%s\" removed from subscription \"%s\"" ,
601+ get_namespace_name (get_rel_namespace (relid )),
602+ get_rel_name (relid ),
603+ sub -> name )));
607604 }
608605 }
609606}
0 commit comments