diff --git a/CHANGELOG.md b/CHANGELOG.md
index b110dadf..5470dd7a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -6,6 +6,11 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+## [3.12.0] - 2024-04-08
+### Added
+- Satori: Added `IApiLiveEvent.Id` for accessing live event identifiers.
+- Satori: Added support for new Satori Messages API: `IClient.GetMessageListAsync`, `IClient.UpdateMessageAsync` and `IClient.DeleteMessageAsync`.
+
 ## [3.11.0] - 2024-03-08
 ### Added
 - Nakama: New `IClient` event called `ReceivedSessionUpdated` when session expires and is refreshed.
diff --git a/Satori/ApiClient.gen.cs b/Satori/ApiClient.gen.cs
index afddbffc..4619edeb 100644
--- a/Satori/ApiClient.gen.cs
+++ b/Satori/ApiClient.gen.cs
@@ -40,6 +40,44 @@ public override string ToString()
         }
     }
 
+    /// <summary>
+    /// The request to update the status of a message.
+    /// </summary>
+    public interface IApiUpdateMessageRequest
+    {
+
+        /// <summary>
+        /// The time the message was consumed by the identity.
+        /// </summary>
+        string ConsumeTime { get; }
+
+        /// <summary>
+        /// The time the message was read at the client.
+        /// </summary>
+        string ReadTime { get; }
+    }
+
+    /// <inheritdoc />
+    internal class ApiUpdateMessageRequest : IApiUpdateMessageRequest
+    {
+
+        /// <inheritdoc />
+        [DataMember(Name="consume_time"), Preserve]
+        public string ConsumeTime { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="read_time"), Preserve]
+        public string ReadTime { get; set; }
+
+        public override string ToString()
+        {
+            var output = "";
+            output = string.Concat(output, "ConsumeTime: ", ConsumeTime, ", ");
+            output = string.Concat(output, "ReadTime: ", ReadTime, ", ");
+            return output;
+        }
+    }
+
     /// <summary>
     /// Log out a session, invalidate a refresh token, or log out all sessions/refresh tokens for a user.
     /// </summary>
@@ -422,6 +460,66 @@ public override string ToString()
         }
     }
 
+    /// <summary>
+    /// A response containing all the messages for an identity.
+    /// </summary>
+    public interface IApiGetMessageListResponse
+    {
+
+        /// <summary>
+        /// Cacheable cursor to list newer messages. Durable and designed to be stored, unlike next/prev cursors.
+        /// </summary>
+        string CacheableCursor { get; }
+
+        /// <summary>
+        /// The list of messages.
+        /// </summary>
+        IEnumerable<IApiMessage> Messages { get; }
+
+        /// <summary>
+        /// The cursor to send when retrieving the next page, if any.
+        /// </summary>
+        string NextCursor { get; }
+
+        /// <summary>
+        /// The cursor to send when retrieving the previous page, if any.
+        /// </summary>
+        string PrevCursor { get; }
+    }
+
+    /// <inheritdoc />
+    internal class ApiGetMessageListResponse : IApiGetMessageListResponse
+    {
+
+        /// <inheritdoc />
+        [DataMember(Name="cacheable_cursor"), Preserve]
+        public string CacheableCursor { get; set; }
+
+        /// <inheritdoc />
+        [IgnoreDataMember]
+        public IEnumerable<IApiMessage> Messages => _messages ?? new List<ApiMessage>(0);
+        [DataMember(Name="messages"), Preserve]
+        public List<ApiMessage> _messages { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="next_cursor"), Preserve]
+        public string NextCursor { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="prev_cursor"), Preserve]
+        public string PrevCursor { get; set; }
+
+        public override string ToString()
+        {
+            var output = "";
+            output = string.Concat(output, "CacheableCursor: ", CacheableCursor, ", ");
+            output = string.Concat(output, "Messages: [", string.Join(", ", Messages), "], ");
+            output = string.Concat(output, "NextCursor: ", NextCursor, ", ");
+            output = string.Concat(output, "PrevCursor: ", PrevCursor, ", ");
+            return output;
+        }
+    }
+
     /// <summary>
     /// Enrich/replace the current session with a new ID.
     /// </summary>
@@ -507,6 +605,11 @@ public interface IApiLiveEvent
         /// </summary>
         string Description { get; }
 
+        /// <summary>
+        /// The live event identifier.
+        /// </summary>
+        string Id { get; }
+
         /// <summary>
         /// Name.
         /// </summary>
@@ -534,6 +637,10 @@ internal class ApiLiveEvent : IApiLiveEvent
         [DataMember(Name="description"), Preserve]
         public string Description { get; set; }
 
+        /// <inheritdoc />
+        [DataMember(Name="id"), Preserve]
+        public string Id { get; set; }
+
         /// <inheritdoc />
         [DataMember(Name="name"), Preserve]
         public string Name { get; set; }
@@ -548,6 +655,7 @@ public override string ToString()
             output = string.Concat(output, "ActiveEndTimeSec: ", ActiveEndTimeSec, ", ");
             output = string.Concat(output, "ActiveStartTimeSec: ", ActiveStartTimeSec, ", ");
             output = string.Concat(output, "Description: ", Description, ", ");
+            output = string.Concat(output, "Id: ", Id, ", ");
             output = string.Concat(output, "Name: ", Name, ", ");
             output = string.Concat(output, "Value: ", Value, ", ");
             return output;
@@ -584,6 +692,122 @@ public override string ToString()
         }
     }
 
+    /// <summary>
+    /// A scheduled message.
+    /// </summary>
+    public interface IApiMessage
+    {
+
+        /// <summary>
+        /// The time the message was consumed by the identity.
+        /// </summary>
+        string ConsumeTime { get; }
+
+        /// <summary>
+        /// The time the message was created.
+        /// </summary>
+        string CreateTime { get; }
+
+        /// <summary>
+        /// The message's unique identifier.
+        /// </summary>
+        string Id { get; }
+
+        /// <summary>
+        /// A key-value pairs of metadata.
+        /// </summary>
+        IDictionary<string, string> Metadata { get; }
+
+        /// <summary>
+        /// The time the message was read by the client.
+        /// </summary>
+        string ReadTime { get; }
+
+        /// <summary>
+        /// The identifier of the schedule.
+        /// </summary>
+        string ScheduleId { get; }
+
+        /// <summary>
+        /// The send time for the message.
+        /// </summary>
+        string SendTime { get; }
+
+        /// <summary>
+        /// The message's text.
+        /// </summary>
+        string Text { get; }
+
+        /// <summary>
+        /// The time the message was updated.
+        /// </summary>
+        string UpdateTime { get; }
+    }
+
+    /// <inheritdoc />
+    internal class ApiMessage : IApiMessage
+    {
+
+        /// <inheritdoc />
+        [DataMember(Name="consume_time"), Preserve]
+        public string ConsumeTime { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="create_time"), Preserve]
+        public string CreateTime { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="id"), Preserve]
+        public string Id { get; set; }
+
+        /// <inheritdoc />
+        [IgnoreDataMember]
+        public IDictionary<string, string> Metadata => _metadata ?? new Dictionary<string, string>();
+        [DataMember(Name="metadata"), Preserve]
+        public Dictionary<string, string> _metadata { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="read_time"), Preserve]
+        public string ReadTime { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="schedule_id"), Preserve]
+        public string ScheduleId { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="send_time"), Preserve]
+        public string SendTime { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="text"), Preserve]
+        public string Text { get; set; }
+
+        /// <inheritdoc />
+        [DataMember(Name="update_time"), Preserve]
+        public string UpdateTime { get; set; }
+
+        public override string ToString()
+        {
+            var output = "";
+            output = string.Concat(output, "ConsumeTime: ", ConsumeTime, ", ");
+            output = string.Concat(output, "CreateTime: ", CreateTime, ", ");
+            output = string.Concat(output, "Id: ", Id, ", ");
+
+            var metadataString = "";
+            foreach (var kvp in Metadata)
+            {
+                metadataString = string.Concat(metadataString, "{" + kvp.Key + "=" + kvp.Value + "}");
+            }
+            output = string.Concat(output, "Metadata: [" + metadataString + "]");
+            output = string.Concat(output, "ReadTime: ", ReadTime, ", ");
+            output = string.Concat(output, "ScheduleId: ", ScheduleId, ", ");
+            output = string.Concat(output, "SendTime: ", SendTime, ", ");
+            output = string.Concat(output, "Text: ", Text, ", ");
+            output = string.Concat(output, "UpdateTime: ", UpdateTime, ", ");
+            return output;
+        }
+    }
+
     /// <summary>
     /// Properties associated with an identity.
     /// </summary>
@@ -877,9 +1101,11 @@ public async Task SatoriHealthcheckAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -904,9 +1130,11 @@ public async Task SatoriReadycheckAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -937,9 +1165,11 @@ public async Task<IApiSession> SatoriAuthenticateAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -976,9 +1206,11 @@ public async Task SatoriAuthenticateLogoutAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1011,9 +1243,11 @@ public async Task<IApiSession> SatoriAuthenticateRefreshAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1050,9 +1284,11 @@ public async Task SatoriEventAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1084,9 +1320,11 @@ public async Task<IApiExperimentList> SatoriGetExperimentsAsync(
                 queryParams = string.Concat(queryParams, "names=", Uri.EscapeDataString(elem), "&");
             }
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1119,9 +1357,11 @@ public async Task<IApiFlagList> SatoriGetFlagsAsync(
                 queryParams = string.Concat(queryParams, "names=", Uri.EscapeDataString(elem), "&");
             }
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1161,9 +1401,11 @@ public async Task<IApiSession> SatoriIdentifyAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1191,9 +1433,11 @@ public async Task SatoriDeleteIdentityAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1223,9 +1467,11 @@ public async Task<IApiLiveEventList> SatoriGetLiveEventsAsync(
                 queryParams = string.Concat(queryParams, "names=", Uri.EscapeDataString(elem), "&");
             }
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1239,6 +1485,125 @@ public async Task<IApiLiveEventList> SatoriGetLiveEventsAsync(
             return contents.FromJson<ApiLiveEventList>();
         }
 
+        /// <summary>
+        /// Get the list of messages for the identity.
+        /// </summary>
+        public async Task<IApiGetMessageListResponse> SatoriGetMessageListAsync(
+            string bearerToken,
+            int? limit,
+            bool? forward,
+            string cursor,
+            CancellationToken? cancellationToken)
+        {
+
+            var urlpath = "/v1/message";
+
+            var queryParams = "";
+            if (limit != null) {
+                queryParams = string.Concat(queryParams, "limit=", limit, "&");
+            }
+            if (forward != null) {
+                queryParams = string.Concat(queryParams, "forward=", forward.ToString().ToLower(), "&");
+            }
+            if (cursor != null) {
+                queryParams = string.Concat(queryParams, "cursor=", Uri.EscapeDataString(cursor), "&");
+            }
+
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
+            var uri = new UriBuilder(_baseUri)
+            {
+                Path = path,
+                Query = queryParams
+            }.Uri;
+
+            var method = "GET";
+            var headers = new Dictionary<string, string>();
+            var header = string.Concat("Bearer ", bearerToken);
+            headers.Add("Authorization", header);
+
+            byte[] content = null;
+            var contents = await HttpAdapter.SendAsync(method, uri, headers, content, Timeout, cancellationToken);
+            return contents.FromJson<ApiGetMessageListResponse>();
+        }
+
+        /// <summary>
+        /// Deletes a message for an identity.
+        /// </summary>
+        public async Task SatoriDeleteMessageAsync(
+            string bearerToken,
+            string id,
+            CancellationToken? cancellationToken)
+        {
+            if (id == null)
+            {
+                throw new ArgumentException("'id' is required but was null.");
+            }
+
+            var urlpath = "/v1/message/{id}";
+            urlpath = urlpath.Replace("{id}", Uri.EscapeDataString(id));
+
+            var queryParams = "";
+
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
+            var uri = new UriBuilder(_baseUri)
+            {
+                Path = path,
+                Query = queryParams
+            }.Uri;
+
+            var method = "DELETE";
+            var headers = new Dictionary<string, string>();
+            var header = string.Concat("Bearer ", bearerToken);
+            headers.Add("Authorization", header);
+
+            byte[] content = null;
+            await HttpAdapter.SendAsync(method, uri, headers, content, Timeout, cancellationToken);
+        }
+
+        /// <summary>
+        /// Updates a message for an identity.
+        /// </summary>
+        public async Task SatoriUpdateMessageAsync(
+            string bearerToken,
+            string id,
+            ApiUpdateMessageRequest body,
+            CancellationToken? cancellationToken)
+        {
+            if (id == null)
+            {
+                throw new ArgumentException("'id' is required but was null.");
+            }
+            if (body == null)
+            {
+                throw new ArgumentException("'body' is required but was null.");
+            }
+
+            var urlpath = "/v1/message/{id}";
+            urlpath = urlpath.Replace("{id}", Uri.EscapeDataString(id));
+
+            var queryParams = "";
+
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
+            var uri = new UriBuilder(_baseUri)
+            {
+                Path = path,
+                Query = queryParams
+            }.Uri;
+
+            var method = "PUT";
+            var headers = new Dictionary<string, string>();
+            var header = string.Concat("Bearer ", bearerToken);
+            headers.Add("Authorization", header);
+
+            byte[] content = null;
+            var jsonBody = body.ToJson();
+            content = Encoding.UTF8.GetBytes(jsonBody);
+            await HttpAdapter.SendAsync(method, uri, headers, content, Timeout, cancellationToken);
+        }
+
         /// <summary>
         /// List properties associated with this identity.
         /// </summary>
@@ -1251,9 +1616,11 @@ public async Task<IApiProperties> SatoriListPropertiesAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
@@ -1284,9 +1651,11 @@ public async Task SatoriUpdatePropertiesAsync(
 
             var queryParams = "";
 
+            string path = _baseUri.AbsolutePath.TrimEnd('/') + urlpath;
+
             var uri = new UriBuilder(_baseUri)
             {
-                Path = urlpath,
+                Path = path,
                 Query = queryParams
             }.Uri;
 
diff --git a/Satori/Client.cs b/Satori/Client.cs
index b3fb2aa6..24229b40 100644
--- a/Satori/Client.cs
+++ b/Satori/Client.cs
@@ -330,14 +330,14 @@ public async Task UpdatePropertiesAsync(ISession session, Dictionary<string, str
                 await SessionRefreshAsync(session, cancellationToken);
             }
 
-            ApiUpdatePropertiesRequest payload = new ApiUpdatePropertiesRequest { 
-                _default = defaultProperties, 
+            ApiUpdatePropertiesRequest payload = new ApiUpdatePropertiesRequest {
+                _default = defaultProperties,
                 _custom = customProperties,
                 Recompute = recompute,
             };
             await _apiClient.SatoriUpdatePropertiesAsync(session.AuthToken, payload, cancellationToken);
         }
-        
+
         /// <inheritdoc cref="DeleteIdentityAsync" />
         public async Task DeleteIdentityAsync(ISession session, CancellationToken? cancellationToken = default)
         {
@@ -349,5 +349,41 @@ public async Task DeleteIdentityAsync(ISession session, CancellationToken? cance
 
             await _apiClient.SatoriDeleteIdentityAsync(session.AuthToken, cancellationToken);
         }
+
+        /// <inheritdoc cref="GetMessageListAsync" />
+        public async Task<IApiGetMessageListResponse> GetMessageListAsync(ISession session, int limit = 1, bool forward = true, string cursor = null, CancellationToken? cancellationToken = default)
+        {
+            if (AutoRefreshSession && !string.IsNullOrEmpty(session.RefreshToken) &&
+                session.HasExpired(DateTime.UtcNow.Add(DefaultExpiredTimeSpan)))
+            {
+                await SessionRefreshAsync(session, cancellationToken);
+            }
+
+            return await _apiClient.SatoriGetMessageListAsync(session.AuthToken, limit, forward, cursor, cancellationToken);
+        }
+
+        /// <inheritdoc cref="UpdateMessageAsync" />
+        public async Task UpdateMessageAsync(ISession session, string id, string consumeTime, string readTime, CancellationToken? cancellationToken = default)
+        {
+            if (AutoRefreshSession && !string.IsNullOrEmpty(session.RefreshToken) &&
+                session.HasExpired(DateTime.UtcNow.Add(DefaultExpiredTimeSpan)))
+            {
+                await SessionRefreshAsync(session, cancellationToken);
+            }
+
+            await _apiClient.SatoriUpdateMessageAsync(session.AuthToken, id, new ApiUpdateMessageRequest{ConsumeTime = consumeTime, ReadTime = readTime}, cancellationToken);
+        }
+
+        /// <inheritdoc cref="DeleteMessageAsync" />
+        public async Task DeleteMessageAsync(ISession session, string id, CancellationToken? cancellationToken = default)
+        {
+            if (AutoRefreshSession && !string.IsNullOrEmpty(session.RefreshToken) &&
+                session.HasExpired(DateTime.UtcNow.Add(DefaultExpiredTimeSpan)))
+            {
+                await SessionRefreshAsync(session, cancellationToken);
+            }
+
+            await _apiClient.SatoriDeleteMessageAsync(session.AuthToken, id, cancellationToken);
+        }
     }
-}
\ No newline at end of file
+}
diff --git a/Satori/IClient.cs b/Satori/IClient.cs
index cdd9ac83..d12fa8bf 100644
--- a/Satori/IClient.cs
+++ b/Satori/IClient.cs
@@ -211,5 +211,36 @@ public Task UpdatePropertiesAsync(ISession session, Dictionary<string, string> d
         /// <param name="cancellationToken">The <see cref="CancellationToken"/> that can be used to cancel the request while mid-flight.</param>
         /// <returns>A task object.</returns>
         public Task DeleteIdentityAsync(ISession session, CancellationToken? cancellationToken = default);
+
+        /// <summary>
+        /// Get all the messages for an identity.
+        /// </summary>
+        /// <param name="session">The session of the user.</param>
+        /// <param name="limit">Max number of messages to return. Between 1 and 100.</param>
+        /// <param name="forward">True if listing should be older messages to newer, false if reverse.</param>
+        /// <param name="cursor">A pagination cursor, if any.</param>
+        /// <param name="cancellationToken">The <see cref="CancellationToken"/> that can be used to cancel the request while mid-flight.</param>
+        /// <returns>A task object which resolves to a list of messages.</returns>
+        public Task<IApiGetMessageListResponse> GetMessageListAsync(ISession session, int limit = 1, bool forward = true, string cursor = null, CancellationToken? cancellationToken = default);
+
+        /// <summary>
+        /// Update the status of a message.
+        /// </summary>
+        /// <param name="session">The session of the user.</param>
+        /// <param name="id">The message's unique identifier.</param>
+        /// <param name="consumeTime">The time the message was consumed by the identity.</param>
+        /// <param name="readTime">The time the message was read at the client.</param>
+        /// <param name="cancellationToken">The <see cref="CancellationToken"/> that can be used to cancel the request while mid-flight.</param>
+        /// <returns>A task object.</returns>
+        public Task UpdateMessageAsync(ISession session, string id, string consumeTime, string readTime, CancellationToken? cancellationToken = default);
+
+        /// <summary>
+        /// Delete a scheduled message.
+        /// </summary>
+        /// <param name="session">The session of the user.</param>
+        /// <param name="id">The identifier of the message.</param>
+        /// <param name="cancellationToken">The <see cref="CancellationToken"/> that can be used to cancel the request while mid-flight.</param>
+        /// <returns>A task object.</returns>
+        public Task DeleteMessageAsync(ISession session, string id, CancellationToken? cancellationToken = default);
     }
 }