Add the schema name prefix.
diff --git a/listener.go b/listener.go
index 2152bea..ad662da 100644
--- a/listener.go
+++ b/listener.go
@@ -80,30 +80,30 @@
for _, payload := range changes.Changes {
switch payload.Table {
- case "public.developer":
+ case "kms.developer", "public.developer":
switch payload.Operation {
case 1:
insertCreateDeveloper(payload.NewRow, db)
}
- case "public.app":
+ case "kms.app", "public.app":
switch payload.Operation {
case 1:
insertCreateApplication(payload.NewRow, db)
}
- case "public.app_credential":
+ case "kms.app_credential", "public.app_credential":
switch payload.Operation {
case 1:
insertCreateCredential(payload.NewRow, db)
}
- case "public.api_product":
+ case "kms.api_product", "public.api_product":
switch payload.Operation {
case 1:
insertAPIproduct(payload.NewRow, db)
}
- case "public.app_credential_apiproduct_mapper":
+ case "kms.app_credential_apiproduct_mapper", "public.app_credential_apiproduct_mapper":
switch payload.Operation {
case 1:
insertApiProductMapper(payload.NewRow, db)
