diff --git a/plugins/module_utils/mso.py b/plugins/module_utils/mso.py
index 05cfdab0..0f346d79 100644
--- a/plugins/module_utils/mso.py
+++ b/plugins/module_utils/mso.py
@@ -1564,7 +1564,7 @@ def listener_rules_spec():
         content_type=dict(type="str", choices=list(LISTENER_CONTENT_TYPE_MAP)),
         port=dict(type="int"),
         protocol=dict(type="str", choices=LISTENER_PROTOCOLS),
-        provider_epg_ref=dict(
+        provider_epg=dict(
             type="dict",
             options=listener_rules_provider_epg_ref_spec(),
         ),
diff --git a/plugins/modules/mso_schema_site_contract_service_graph_listener.py b/plugins/modules/mso_schema_site_contract_service_graph_listener.py
index 6cf3e836..b854f040 100644
--- a/plugins/modules/mso_schema_site_contract_service_graph_listener.py
+++ b/plugins/modules/mso_schema_site_contract_service_graph_listener.py
@@ -159,9 +159,9 @@
         - The protocol of the rule.
         type: str
         choices: [ http, https, tcp, udp, tls, inherit ]
-      provider_epg_ref:
+      provider_epg:
         description:
-        - The provider epg reference of the rule.
+        - The provider epg of the rule.
         type: dict
         suboptions:
           schema:
@@ -343,7 +343,7 @@
         action_type: forward
         port: 80
         protocol: http
-        provider_epg_ref:
+        provider_epg:
           anp_name: AP1
           epg_name: EPG1
         health_check:
@@ -647,13 +647,13 @@ def main():
             if listener_protocol in ["tcp", "udp"]:
                 mso.input_validation("listener_protocol", "tcp/udp", ["health_check"], rule)
 
-            provider_epg_ref = rule.get("provider_epg_ref")
-            if provider_epg_ref:
+            provider_epg = rule.get("provider_epg")
+            if provider_epg:
                 rule_data["providerEpgRef"] = "/schemas/{0}/templates/{1}/anps/{2}/epgs/{3}".format(
-                    provider_epg_ref.get("schema") or schema_id,
-                    provider_epg_ref.get("template_name") or template,
-                    provider_epg_ref.get("anp_name"),
-                    provider_epg_ref.get("epg_name"),
+                    provider_epg.get("schema") or schema_id,
+                    provider_epg.get("template_name") or template,
+                    provider_epg.get("anp_name"),
+                    provider_epg.get("epg_name"),
                 )
 
             health_check = rule.get("health_check")