Update column names to match new schema
diff --git a/listener.go b/listener.go index 358c320..e2bbe6e 100644 --- a/listener.go +++ b/listener.go
@@ -7,7 +7,7 @@ const ( APIGEE_SYNC_EVENT = "ApigeeSync" - MANIFEST_TABLE = "edgex.apid_config_manifest" + MANIFEST_TABLE = "edgex.apid_config_manifest_deployment" ) func initListener(services apid.Services) { @@ -79,7 +79,7 @@ if err != nil { return err } - err = row.Get("body", &manifest) + err = row.Get("manifest_body", &manifest) if err != nil { return err }
diff --git a/listener_test.go b/listener_test.go index b4abd9f..635c6b2 100644 --- a/listener_test.go +++ b/listener_test.go
@@ -42,7 +42,7 @@ row := common.Row{} row["id"] = &common.ColumnVal{Value: deploymentID} - row["body"] = &common.ColumnVal{Value: string(depBytes)} + row["manifest_body"] = &common.ColumnVal{Value: string(depBytes)} var event = common.Snapshot{} event.Tables = []common.Table{ @@ -105,7 +105,7 @@ row := common.Row{} row["id"] = &common.ColumnVal{Value: deploymentID} - row["body"] = &common.ColumnVal{Value: string(depBytes)} + row["manifest_body"] = &common.ColumnVal{Value: string(depBytes)} var event = common.ChangeList{} event.Changes = []common.Change{