diff --git a/astro.config.mjs b/astro.config.mjs
index e21b5e2..fba4773 100644
--- a/astro.config.mjs
+++ b/astro.config.mjs
@@ -241,32 +241,6 @@ export default defineConfig({
               collapsed: true,
               items: [{ autogenerate: { directory: "processors/module" } }],
             },
-            {
-              label: "MQTT",
-              collapsed: true,
-              items: [
-                {
-                  label: "Message",
-                  collapsed: true,
-                  items: [
-                    { autogenerate: { directory: "processors/mqtt/message" } },
-                  ],
-                },
-              ],
-            },
-            {
-              label: "NATS",
-              collapsed: true,
-              items: [
-                {
-                  label: "Message",
-                  collapsed: true,
-                  items: [
-                    { autogenerate: { directory: "processors/nats/message" } },
-                  ],
-                },
-              ],
-            },
             {
               label: "OSC",
               collapsed: true,
@@ -280,6 +254,11 @@ export default defineConfig({
                 },
               ],
             },
+            {
+              label: "Pub/Sub",
+              collapsed: true,
+              items: [{ autogenerate: { directory: "processors/pubsub" } }],
+            },
             {
               label: "Script",
               collapsed: true,
diff --git a/src/content/docs/processors/mqtt/message/create.mdx b/src/content/docs/processors/mqtt/message/create.mdx
deleted file mode 100644
index 58a184c..0000000
--- a/src/content/docs/processors/mqtt/message/create.mdx
+++ /dev/null
@@ -1,25 +0,0 @@
----
-title: Create MQTT Message
-sidebar:
-  order: 1
----
-
-This processor will create an MQTT message from the provided parameters. This processor will return an error if any of the required parameters are missing or if the parameters are of the wrong type.
-
-- **type**: `mqtt.message.create`
-- **params**:
-  - **topic**: the topic to publish the message to.
-  - **qos**: the QoS level of the message.
-  - **retained**: whether the message should be retained by the broker.
-  - **payload**: the payload of the message. This can be a string or a byte array.
-
-### Example
-
-```yaml
-- type: mqtt.message.create
-  params:
-    topic: "test/topic"
-    qos: 1
-    retained: false
-    payload: "Hello, World!"
-```
diff --git a/src/content/docs/processors/nats/message/create.mdx b/src/content/docs/processors/nats/message/create.mdx
deleted file mode 100644
index dc7d9e1..0000000
--- a/src/content/docs/processors/nats/message/create.mdx
+++ /dev/null
@@ -1,22 +0,0 @@
----
-title: Create NATS Message
-sidebar:
-  label: Create
-  order: 1
----
-
-This processor will create a NATS message from the provided parameters. This processor will return an error if any of the required parameters are missing or if the parameters are of the wrong type.
-
-- **type**: `nats.message.create`
-- **params**:
-  - **subject**: the subject to publish the message to.
-  - **payload**: the payload of the message.
-
-### Example
-
-```yaml
-- type: nats.message.create
-  params:
-    subject: "events"
-    payload: "Hello, World!"
-```
diff --git a/src/content/docs/processors/pubsub/publish.mdx b/src/content/docs/processors/pubsub/publish.mdx
new file mode 100644
index 0000000..a1ef373
--- /dev/null
+++ b/src/content/docs/processors/pubsub/publish.mdx
@@ -0,0 +1,22 @@
+---
+title: Publish to Pub/Sub
+sidebar:
+  label: Publish
+  order: 1
+---
+
+This processor will publish the incoming payload to a Pub/Sub capable module. This processor will return an error if any of the required parameters are missing or if the parameters are of the wrong type.
+
+- **type**: `pubsub.publish`
+- **params**:
+  - **module**: the module to publish with.
+  - **topic**: the subject to publish to.
+
+### Example
+
+```yaml
+- type: pubsub.publish
+  params:
+    module: mqtt-out
+    topic: "test"
+```