diff --git a/src/bin/broadcaster.rs b/src/bin/broadcaster.rs
index b63024a..c640fab 100644
--- a/src/bin/broadcaster.rs
+++ b/src/bin/broadcaster.rs
@@ -6,8 +6,7 @@ async fn main() -> anyhow::Result<()> {
 
     let broadcaster = j7s_matrix_sdk::MatrixBroadcaster::new(&url, &token, &device_name).await?;
 
-    let message =
-        matrix_sdk::ruma::events::room::message::RoomMessageEventContent::text_plain("Hi!");
+    let message = matrix_sdk::ruma::events::room::message::MessageType::text_plain("Hi!");
     loop {
         tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
         broadcaster.broadcast(&message).await?;
diff --git a/src/broadcaster.rs b/src/broadcaster.rs
index 9618b86..e8abdf9 100644
--- a/src/broadcaster.rs
+++ b/src/broadcaster.rs
@@ -41,15 +41,17 @@ impl MatrixBroadcaster {
 
     pub async fn broadcast(
         self: &Self,
-        msg: &matrix_sdk::ruma::events::room::message::RoomMessageEventContent,
+        msg: &matrix_sdk::ruma::events::room::message::MessageType,
     ) -> anyhow::Result<()> {
         let rooms_clone = self.rooms.clone();
         let rooms = rooms_clone.read().await.clone();
 
         for room in rooms {
-            room.send(msg.clone())
-                .await
-                .context("Failed to send message to room.")?;
+            room.send(
+                matrix_sdk::ruma::events::room::message::RoomMessageEventContent::new(msg.clone()),
+            )
+            .await
+            .context("Failed to send message to room.")?;
         }
 
         Ok(())