diff --git a/standard-site-sync/src/main.rs b/standard-site-sync/src/main.rs
index e5c7c9e..05e80d2 100644
--- a/standard-site-sync/src/main.rs
+++ b/standard-site-sync/src/main.rs
@@ -48,10 +48,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let config = TapConfig::builder()
         .database_url("sqlite://./tap-example.db")
         .bind(":2480")
-        .signal_collection("site.standard.document")
+        .signal_collection(Document::nsid())
         .collection_filters(vec![
-            "site.standard.publication".to_string(),
-            "site.standard.document".to_string(),
+            Publication::nsid().to_string(),
+            Document::nsid().to_string(),
         ])
         .disable_acks(false)
         .inherit_stdio(true)
@@ -139,7 +139,7 @@ fn process_record_event(event: &RecordEvent, cache: &mut Cache) {
 
     match event.action {
         RecordAction::Create | RecordAction::Update => match event.collection.as_str() {
-            "site.standard.publication" => {
+            c if c == Publication::nsid() => {
                 if let Some(json) = event.record_as_str() {
                     match serde_json::from_str::<Publication<'_>>(json) {
                         Ok(publication) => {
@@ -171,7 +171,7 @@ fn process_record_event(event: &RecordEvent, cache: &mut Cache) {
                     }
                 }
             }
-            "site.standard.document" => {
+            c if c == Document::nsid() => {
                 if let Some(json) = event.record_as_str() {
                     match serde_json::from_str::<Document<'_>>(json) {
                         Ok(document) => {
@@ -202,10 +202,10 @@ fn process_record_event(event: &RecordEvent, cache: &mut Cache) {
             _ => {}
         },
         RecordAction::Delete => match event.collection.as_str() {
-            "site.standard.publication" => {
+            c if c == Publication::nsid() => {
                 cache.publications.remove(&at_uri);
             }
-            "site.standard.document" => {
+            c if c == Document::nsid() => {
                 cache.documents.remove(&at_uri);
             }
             _ => {}