diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationEventParser.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationEventParser.java
index a9a96b00a4c0..f130e5a14f6d 100644
--- a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationEventParser.java
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/CallAutomationEventParser.java
@@ -45,6 +45,9 @@
 import com.azure.communication.callautomation.models.events.SendDtmfTonesCompleted;
 import com.azure.communication.callautomation.models.events.SendDtmfTonesFailed;
 import com.azure.communication.callautomation.models.events.TranscriptionUpdated;
+import com.azure.communication.callautomation.models.events.MediaStreamingStarted;
+import com.azure.communication.callautomation.models.events.MediaStreamingStopped;
+import com.azure.communication.callautomation.models.events.MediaStreamingFailed;
 import com.azure.core.models.CloudEvent;
 import com.azure.core.util.logging.ClientLogger;
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -190,6 +193,12 @@ private static CallAutomationEventBase parseSingleCloudEvent(String data, String
                 ret = mapper.convertValue(eventData, CreateCallFailed.class);
             } else if (Objects.equals(eventType, "Microsoft.Communication.HoldFailed")) {
                 ret = mapper.convertValue(eventData, HoldFailed.class);
+            } else if (Objects.equals(eventType, "Microsoft.Communication.MediaStreamingStarted")) {
+                ret = mapper.convertValue(eventData, MediaStreamingStarted.class);
+            } else if (Objects.equals(eventType, "Microsoft.Communication.MediaStreamingStopped")) {
+                ret = mapper.convertValue(eventData, MediaStreamingStopped.class);
+            } else if (Objects.equals(eventType, "Microsoft.Communication.MediaStreamingFailed")) {
+                ret = mapper.convertValue(eventData, MediaStreamingFailed.class);
             }
             return ret;
         } catch (RuntimeException e) {
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingFailed.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingFailed.java
new file mode 100644
index 000000000000..4f7e6eb921a6
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingFailed.java
@@ -0,0 +1,108 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.annotation.Immutable;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingFailed model. */
+@Immutable
+public final class MediaStreamingFailed {
+    /*
+     * Used by customers when calling mid-call actions to correlate the request
+     * to the response event.
+     */
+    @JsonProperty(value = "operationContext", access = JsonProperty.Access.WRITE_ONLY)
+    private String operationContext;
+
+    /*
+     * Contains the resulting SIP code, sub-code and message.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private ResultInformation resultInformation;
+
+    /*
+     * Defines the result for audio streaming update with the current status
+     * and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private MediaStreamingUpdate mediaStreamingUpdate;
+
+    /*
+     * Call connection ID.
+     */
+    @JsonProperty(value = "callConnectionId", access = JsonProperty.Access.WRITE_ONLY)
+    private String callConnectionId;
+
+    /*
+     * Server call ID.
+     */
+    @JsonProperty(value = "serverCallId", access = JsonProperty.Access.WRITE_ONLY)
+    private String serverCallId;
+
+    /*
+     * Correlation ID for event to call correlation. Also called ChainId for
+     * skype chain ID.
+     */
+    @JsonProperty(value = "correlationId", access = JsonProperty.Access.WRITE_ONLY)
+    private String correlationId;
+
+    /**
+     * Get the operationContext property: Used by customers when calling mid-call actions to correlate the request to
+     * the response event.
+     *
+     * @return the operationContext value.
+     */
+    public String getOperationContext() {
+        return this.operationContext;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code, sub-code and message.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+    /**
+     * Get the mediaStreamingUpdate property: Defines the result for audio streaming update with the current status and
+     * the details about the status.
+     *
+     * @return the mediaStreamingUpdate value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdate() {
+        return this.mediaStreamingUpdate;
+    }
+
+    /**
+     * Get the callConnectionId property: Call connection ID.
+     *
+     * @return the callConnectionId value.
+     */
+    public String getCallConnectionId() {
+        return this.callConnectionId;
+    }
+
+    /**
+     * Get the serverCallId property: Server call ID.
+     *
+     * @return the serverCallId value.
+     */
+    public String getServerCallId() {
+        return this.serverCallId;
+    }
+
+    /**
+     * Get the correlationId property: Correlation ID for event to call correlation. Also called ChainId for skype chain
+     * ID.
+     *
+     * @return the correlationId value.
+     */
+    public String getCorrelationId() {
+        return this.correlationId;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStarted.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStarted.java
new file mode 100644
index 000000000000..de6ff9beb057
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStarted.java
@@ -0,0 +1,108 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.annotation.Immutable;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingStarted model. */
+@Immutable
+public final class MediaStreamingStarted {
+    /*
+     * Used by customers when calling mid-call actions to correlate the request
+     * to the response event.
+     */
+    @JsonProperty(value = "operationContext", access = JsonProperty.Access.WRITE_ONLY)
+    private String operationContext;
+
+    /*
+     * Contains the resulting SIP code, sub-code and message.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private ResultInformation resultInformation;
+
+    /*
+     * Defines the result for audio streaming update with the current status
+     * and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private MediaStreamingUpdate mediaStreamingUpdate;
+
+    /*
+     * Call connection ID.
+     */
+    @JsonProperty(value = "callConnectionId", access = JsonProperty.Access.WRITE_ONLY)
+    private String callConnectionId;
+
+    /*
+     * Server call ID.
+     */
+    @JsonProperty(value = "serverCallId", access = JsonProperty.Access.WRITE_ONLY)
+    private String serverCallId;
+
+    /*
+     * Correlation ID for event to call correlation. Also called ChainId for
+     * skype chain ID.
+     */
+    @JsonProperty(value = "correlationId", access = JsonProperty.Access.WRITE_ONLY)
+    private String correlationId;
+
+    /**
+     * Get the operationContext property: Used by customers when calling mid-call actions to correlate the request to
+     * the response event.
+     *
+     * @return the operationContext value.
+     */
+    public String getOperationContext() {
+        return this.operationContext;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code, sub-code and message.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+    /**
+     * Get the mediaStreamingUpdate property: Defines the result for audio streaming update with the current status and
+     * the details about the status.
+     *
+     * @return the mediaStreamingUpdate value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdate() {
+        return this.mediaStreamingUpdate;
+    }
+
+    /**
+     * Get the callConnectionId property: Call connection ID.
+     *
+     * @return the callConnectionId value.
+     */
+    public String getCallConnectionId() {
+        return this.callConnectionId;
+    }
+
+    /**
+     * Get the serverCallId property: Server call ID.
+     *
+     * @return the serverCallId value.
+     */
+    public String getServerCallId() {
+        return this.serverCallId;
+    }
+
+    /**
+     * Get the correlationId property: Correlation ID for event to call correlation. Also called ChainId for skype chain
+     * ID.
+     *
+     * @return the correlationId value.
+     */
+    public String getCorrelationId() {
+        return this.correlationId;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatus.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatus.java
new file mode 100644
index 000000000000..84ae9e81ff18
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatus.java
@@ -0,0 +1,40 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.util.ExpandableStringEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.util.Collection;
+
+/** Defines values for MediaStreamingStatus. */
+public final class MediaStreamingStatus extends ExpandableStringEnum<MediaStreamingStatus> {
+    /** Static value mediaStreamingStarted for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_STARTED = fromString("mediaStreamingStarted");
+
+    /** Static value mediaStreamingFailed for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_FAILED = fromString("mediaStreamingFailed");
+
+    /** Static value mediaStreamingStopped for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_STOPPED = fromString("mediaStreamingStopped");
+
+    /** Static value unspecifiedError for MediaStreamingStatus. */
+    public static final MediaStreamingStatus UNSPECIFIED_ERROR = fromString("unspecifiedError");
+
+    /**
+     * Creates or finds a MediaStreamingStatus from its string representation.
+     *
+     * @param name a name to look for.
+     * @return the corresponding MediaStreamingStatus.
+     */
+    @JsonCreator
+    public static MediaStreamingStatus fromString(String name) {
+        return fromString(name, MediaStreamingStatus.class);
+    }
+
+    /** @return known MediaStreamingStatus values. */
+    public static Collection<MediaStreamingStatus> values() {
+        return values(MediaStreamingStatus.class);
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatusDetails.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatusDetails.java
new file mode 100644
index 000000000000..93430c0d45f5
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStatusDetails.java
@@ -0,0 +1,78 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.util.ExpandableStringEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.util.Collection;
+
+/** Defines values for MediaStreamingStatusDetails. */
+public final class MediaStreamingStatusDetails extends ExpandableStringEnum<MediaStreamingStatusDetails> {
+    /** Static value subscriptionStarted for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SUBSCRIPTION_STARTED = fromString("subscriptionStarted");
+
+    /** Static value streamConnectionReestablished for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_REESTABLISHED =
+            fromString("streamConnectionReestablished");
+
+    /** Static value streamConnectionUnsuccessful for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_UNSUCCESSFUL =
+            fromString("streamConnectionUnsuccessful");
+
+    /** Static value streamUrlMissing for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_URL_MISSING = fromString("streamUrlMissing");
+
+    /** Static value serviceShutdown for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SERVICE_SHUTDOWN = fromString("serviceShutdown");
+
+    /** Static value streamConnectionInterrupted for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_INTERRUPTED =
+            fromString("streamConnectionInterrupted");
+
+    /** Static value speechServicesConnectionError for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SPEECH_SERVICES_CONNECTION_ERROR =
+            fromString("speechServicesConnectionError");
+
+    /** Static value subscriptionStopped for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SUBSCRIPTION_STOPPED = fromString("subscriptionStopped");
+
+    /** Static value unspecifiedError for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails UNSPECIFIED_ERROR = fromString("unspecifiedError");
+
+    /** Static value authenticationFailure for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails AUTHENTICATION_FAILURE = fromString("authenticationFailure");
+
+    /** Static value badRequest for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails BAD_REQUEST = fromString("badRequest");
+
+    /** Static value tooManyRequests for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails TOO_MANY_REQUESTS = fromString("tooManyRequests");
+
+    /** Static value forbidden for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails FORBIDDEN = fromString("forbidden");
+
+    /** Static value serviceTimeout for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SERVICE_TIMEOUT = fromString("serviceTimeout");
+
+    /** Static value initialWebSocketConnectionFailed for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails INITIAL_WEB_SOCKET_CONNECTION_FAILED =
+            fromString("initialWebSocketConnectionFailed");
+
+    /**
+     * Creates or finds a MediaStreamingStatusDetails from its string representation.
+     *
+     * @param name a name to look for.
+     * @return the corresponding MediaStreamingStatusDetails.
+     */
+    @JsonCreator
+    public static MediaStreamingStatusDetails fromString(String name) {
+        return fromString(name, MediaStreamingStatusDetails.class);
+    }
+
+    /** @return known MediaStreamingStatusDetails values. */
+    public static Collection<MediaStreamingStatusDetails> values() {
+        return values(MediaStreamingStatusDetails.class);
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStopped.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStopped.java
new file mode 100644
index 000000000000..95390daa30f2
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingStopped.java
@@ -0,0 +1,108 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.annotation.Immutable;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingStopped model. */
+@Immutable
+public final class MediaStreamingStopped {
+    /*
+     * Used by customers when calling mid-call actions to correlate the request
+     * to the response event.
+     */
+    @JsonProperty(value = "operationContext", access = JsonProperty.Access.WRITE_ONLY)
+    private String operationContext;
+
+    /*
+     * Contains the resulting SIP code, sub-code and message.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private ResultInformation resultInformation;
+
+    /*
+     * Defines the result for audio streaming update with the current status
+     * and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private MediaStreamingUpdate mediaStreamingUpdate;
+
+    /*
+     * Call connection ID.
+     */
+    @JsonProperty(value = "callConnectionId", access = JsonProperty.Access.WRITE_ONLY)
+    private String callConnectionId;
+
+    /*
+     * Server call ID.
+     */
+    @JsonProperty(value = "serverCallId", access = JsonProperty.Access.WRITE_ONLY)
+    private String serverCallId;
+
+    /*
+     * Correlation ID for event to call correlation. Also called ChainId for
+     * skype chain ID.
+     */
+    @JsonProperty(value = "correlationId", access = JsonProperty.Access.WRITE_ONLY)
+    private String correlationId;
+
+    /**
+     * Get the operationContext property: Used by customers when calling mid-call actions to correlate the request to
+     * the response event.
+     *
+     * @return the operationContext value.
+     */
+    public String getOperationContext() {
+        return this.operationContext;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code, sub-code and message.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+    /**
+     * Get the mediaStreamingUpdate property: Defines the result for audio streaming update with the current status and
+     * the details about the status.
+     *
+     * @return the mediaStreamingUpdate value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdate() {
+        return this.mediaStreamingUpdate;
+    }
+
+    /**
+     * Get the callConnectionId property: Call connection ID.
+     *
+     * @return the callConnectionId value.
+     */
+    public String getCallConnectionId() {
+        return this.callConnectionId;
+    }
+
+    /**
+     * Get the serverCallId property: Server call ID.
+     *
+     * @return the serverCallId value.
+     */
+    public String getServerCallId() {
+        return this.serverCallId;
+    }
+
+    /**
+     * Get the correlationId property: Correlation ID for event to call correlation. Also called ChainId for skype chain
+     * ID.
+     *
+     * @return the correlationId value.
+     */
+    public String getCorrelationId() {
+        return this.correlationId;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingUpdate.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingUpdate.java
new file mode 100644
index 000000000000..e3b2347475b0
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/implementation/models/MediaStreamingUpdate.java
@@ -0,0 +1,91 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) AutoRest Code Generator.
+
+package com.azure.communication.callautomation.implementation.models;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingUpdate model. */
+@Fluent
+public final class MediaStreamingUpdate {
+    /*
+     * The contentType property.
+     */
+    @JsonProperty(value = "contentType")
+    private String contentType;
+
+    /*
+     * The mediaStreamingStatus property.
+     */
+    @JsonProperty(value = "mediaStreamingStatus")
+    private MediaStreamingStatus mediaStreamingStatus;
+
+    /*
+     * The mediaStreamingStatusDetails property.
+     */
+    @JsonProperty(value = "mediaStreamingStatusDetails")
+    private MediaStreamingStatusDetails mediaStreamingStatusDetails;
+
+    /**
+     * Get the contentType property: The contentType property.
+     *
+     * @return the contentType value.
+     */
+    public String getContentType() {
+        return this.contentType;
+    }
+
+    /**
+     * Set the contentType property: The contentType property.
+     *
+     * @param contentType the contentType value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setContentType(String contentType) {
+        this.contentType = contentType;
+        return this;
+    }
+
+    /**
+     * Get the mediaStreamingStatus property: The mediaStreamingStatus property.
+     *
+     * @return the mediaStreamingStatus value.
+     */
+    public MediaStreamingStatus getMediaStreamingStatus() {
+        return this.mediaStreamingStatus;
+    }
+
+    /**
+     * Set the mediaStreamingStatus property: The mediaStreamingStatus property.
+     *
+     * @param mediaStreamingStatus the mediaStreamingStatus value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setMediaStreamingStatus(MediaStreamingStatus mediaStreamingStatus) {
+        this.mediaStreamingStatus = mediaStreamingStatus;
+        return this;
+    }
+
+    /**
+     * Get the mediaStreamingStatusDetails property: The mediaStreamingStatusDetails property.
+     *
+     * @return the mediaStreamingStatusDetails value.
+     */
+    public MediaStreamingStatusDetails getMediaStreamingStatusDetails() {
+        return this.mediaStreamingStatusDetails;
+    }
+
+    /**
+     * Set the mediaStreamingStatusDetails property: The mediaStreamingStatusDetails property.
+     *
+     * @param mediaStreamingStatusDetails the mediaStreamingStatusDetails value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setMediaStreamingStatusDetails(
+            MediaStreamingStatusDetails mediaStreamingStatusDetails) {
+        this.mediaStreamingStatusDetails = mediaStreamingStatusDetails;
+        return this;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingFailed.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingFailed.java
new file mode 100644
index 000000000000..19d03128d6a6
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingFailed.java
@@ -0,0 +1,52 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingFailed model. */
+@Fluent
+public final class MediaStreamingFailed extends CallAutomationEventBase {
+    
+    /*
+     * Contains the resulting SIP code, sub-code and message.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private ResultInformation resultInformation;
+
+    /*
+     * Defines the result for audio streaming update with the current status
+     * and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private MediaStreamingUpdate mediaStreamingUpdateResult;
+
+      /**
+     * Creates an instance of MediaStreamingFailed class.
+     */
+    public MediaStreamingFailed() {
+        resultInformation = null;
+        mediaStreamingUpdateResult = null;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code, sub-code and message.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+    /**
+     * Get the mediaStreamingUpdateResult property: Defines the result for audio streaming update with the current status and
+     * the details about the status.
+     *
+     * @return the mediaStreamingUpdate value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdateResult() {
+        return this.mediaStreamingUpdateResult;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStarted.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStarted.java
new file mode 100644
index 000000000000..42514e38512b
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStarted.java
@@ -0,0 +1,53 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * The MediaStreamingStarted model.
+ */
+@Fluent
+public final class MediaStreamingStarted extends CallAutomationEventBase {
+    /*
+     * Contains the resulting SIP code/sub-code and message from NGC services.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private final ResultInformation resultInformation;
+
+    /*
+     * Defines the result for MediaStreamingUpdate with the current status and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private final MediaStreamingUpdate mediaStreamingUpdateResult;
+
+    /**
+     * Creates an instance of MediaStreamingStarted class.
+     */
+    public MediaStreamingStarted() {
+        resultInformation = null;
+        mediaStreamingUpdateResult = null;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code/sub-code and message from NGC services.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+     /**
+     * Get the mediaStreamingUpdateResult property: Defines the result for audio streaming update with the current status
+     * and the details about the status.
+     *
+     * @return the mediaStreamingUpdateResult value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdateResult() {
+        return this.mediaStreamingUpdateResult;
+    }
+
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatus.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatus.java
new file mode 100644
index 000000000000..500a49de3251
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatus.java
@@ -0,0 +1,39 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.util.ExpandableStringEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.util.Collection;
+
+/** Defines values for MediaStreamingStatus. */
+public final class MediaStreamingStatus extends ExpandableStringEnum<MediaStreamingStatus> {
+    /** Static value mediaStreamingStarted for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_STARTED = fromString("mediaStreamingStarted");
+
+    /** Static value mediaStreamingFailed for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_FAILED = fromString("mediaStreamingFailed");
+
+    /** Static value mediaStreamingStopped for MediaStreamingStatus. */
+    public static final MediaStreamingStatus MEDIA_STREAMING_STOPPED = fromString("mediaStreamingStopped");
+
+    /** Static value unspecifiedError for MediaStreamingStatus. */
+    public static final MediaStreamingStatus UNSPECIFIED_ERROR = fromString("unspecifiedError");
+
+    /**
+     * Creates or finds a MediaStreamingStatus from its string representation.
+     *
+     * @param name a name to look for.
+     * @return the corresponding MediaStreamingStatus.
+     */
+    @JsonCreator
+    public static MediaStreamingStatus fromString(String name) {
+        return fromString(name, MediaStreamingStatus.class);
+    }
+
+    /** @return known MediaStreamingStatus values. */
+    public static Collection<MediaStreamingStatus> values() {
+        return values(MediaStreamingStatus.class);
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatusDetails.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatusDetails.java
new file mode 100644
index 000000000000..97eb4cf6c605
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStatusDetails.java
@@ -0,0 +1,77 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.util.ExpandableStringEnum;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.util.Collection;
+
+/** Defines values for MediaStreamingStatusDetails. */
+public final class MediaStreamingStatusDetails extends ExpandableStringEnum<MediaStreamingStatusDetails> {
+    /** Static value subscriptionStarted for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SUBSCRIPTION_STARTED = fromString("subscriptionStarted");
+
+    /** Static value streamConnectionReestablished for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_REESTABLISHED =
+            fromString("streamConnectionReestablished");
+
+    /** Static value streamConnectionUnsuccessful for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_UNSUCCESSFUL =
+            fromString("streamConnectionUnsuccessful");
+
+    /** Static value streamUrlMissing for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_URL_MISSING = fromString("streamUrlMissing");
+
+    /** Static value serviceShutdown for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SERVICE_SHUTDOWN = fromString("serviceShutdown");
+
+    /** Static value streamConnectionInterrupted for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails STREAM_CONNECTION_INTERRUPTED =
+            fromString("streamConnectionInterrupted");
+
+    /** Static value speechServicesConnectionError for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SPEECH_SERVICES_CONNECTION_ERROR =
+            fromString("speechServicesConnectionError");
+
+    /** Static value subscriptionStopped for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SUBSCRIPTION_STOPPED = fromString("subscriptionStopped");
+
+    /** Static value unspecifiedError for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails UNSPECIFIED_ERROR = fromString("unspecifiedError");
+
+    /** Static value authenticationFailure for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails AUTHENTICATION_FAILURE = fromString("authenticationFailure");
+
+    /** Static value badRequest for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails BAD_REQUEST = fromString("badRequest");
+
+    /** Static value tooManyRequests for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails TOO_MANY_REQUESTS = fromString("tooManyRequests");
+
+    /** Static value forbidden for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails FORBIDDEN = fromString("forbidden");
+
+    /** Static value serviceTimeout for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails SERVICE_TIMEOUT = fromString("serviceTimeout");
+
+    /** Static value initialWebSocketConnectionFailed for MediaStreamingStatusDetails. */
+    public static final MediaStreamingStatusDetails INITIAL_WEB_SOCKET_CONNECTION_FAILED =
+            fromString("initialWebSocketConnectionFailed");
+
+    /**
+     * Creates or finds a MediaStreamingStatusDetails from its string representation.
+     *
+     * @param name a name to look for.
+     * @return the corresponding MediaStreamingStatusDetails.
+     */
+    @JsonCreator
+    public static MediaStreamingStatusDetails fromString(String name) {
+        return fromString(name, MediaStreamingStatusDetails.class);
+    }
+
+    /** @return known MediaStreamingStatusDetails values. */
+    public static Collection<MediaStreamingStatusDetails> values() {
+        return values(MediaStreamingStatusDetails.class);
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStopped.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStopped.java
new file mode 100644
index 000000000000..4a8e53891eb9
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingStopped.java
@@ -0,0 +1,52 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingStopped model. */
+@Fluent
+public final class MediaStreamingStopped extends CallAutomationEventBase {
+    
+    /*
+     * Contains the resulting SIP code, sub-code and message.
+     */
+    @JsonProperty(value = "resultInformation", access = JsonProperty.Access.WRITE_ONLY)
+    private ResultInformation resultInformation;
+
+    /*
+     * Defines the result for audio streaming update with the current status
+     * and the details about the status
+     */
+    @JsonProperty(value = "mediaStreamingUpdate", access = JsonProperty.Access.WRITE_ONLY)
+    private MediaStreamingUpdate mediaStreamingUpdateResult;
+
+     /**
+     * Creates an instance of MediaStreamingStopped class.
+     */
+    public MediaStreamingStopped() {
+        resultInformation = null;
+        mediaStreamingUpdateResult = null;
+    }
+
+    /**
+     * Get the resultInformation property: Contains the resulting SIP code, sub-code and message.
+     *
+     * @return the resultInformation value.
+     */
+    public ResultInformation getResultInformation() {
+        return this.resultInformation;
+    }
+
+    /**
+     * Get the getMediaStreamingUpdateResult property: Defines the result for audio streaming update with the current status and
+     * the details about the status.
+     *
+     * @return the mediaStreamingUpdate value.
+     */
+    public MediaStreamingUpdate getMediaStreamingUpdateResult() {
+        return this.mediaStreamingUpdateResult;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingUpdate.java b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingUpdate.java
new file mode 100644
index 000000000000..b9e094f913f4
--- /dev/null
+++ b/sdk/communication/azure-communication-callautomation/src/main/java/com/azure/communication/callautomation/models/events/MediaStreamingUpdate.java
@@ -0,0 +1,90 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.communication.callautomation.models.events;
+
+import com.azure.core.annotation.Fluent;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** The MediaStreamingUpdate model. */
+@Fluent
+public final class MediaStreamingUpdate {
+    /*
+     * The contentType property.
+     */
+    @JsonProperty(value = "contentType")
+    private String contentType;
+
+    /*
+     * The mediaStreamingStatus property.
+     */
+    @JsonProperty(value = "mediaStreamingStatus")
+    private MediaStreamingStatus mediaStreamingStatus;
+
+    /*
+     * The mediaStreamingStatusDetails property.
+     */
+    @JsonProperty(value = "mediaStreamingStatusDetails")
+    private MediaStreamingStatusDetails mediaStreamingStatusDetails;
+
+    /**
+     * Get the contentType property: The contentType property.
+     *
+     * @return the contentType value.
+     */
+    public String getContentType() {
+        return this.contentType;
+    }
+
+    /**
+     * Set the contentType property: The contentType property.
+     *
+     * @param contentType the contentType value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setContentType(String contentType) {
+        this.contentType = contentType;
+        return this;
+    }
+
+    /**
+     * Get the mediaStreamingStatus property: The mediaStreamingStatus property.
+     *
+     * @return the mediaStreamingStatus value.
+     */
+    public MediaStreamingStatus getMediaStreamingStatus() {
+        return this.mediaStreamingStatus;
+    }
+
+    /**
+     * Set the mediaStreamingStatus property: The mediaStreamingStatus property.
+     *
+     * @param mediaStreamingStatus the mediaStreamingStatus value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setMediaStreamingStatus(MediaStreamingStatus mediaStreamingStatus) {
+        this.mediaStreamingStatus = mediaStreamingStatus;
+        return this;
+    }
+
+    /**
+     * Get the mediaStreamingStatusDetails property: The mediaStreamingStatusDetails property.
+     *
+     * @return the mediaStreamingStatusDetails value.
+     */
+    public MediaStreamingStatusDetails getMediaStreamingStatusDetails() {
+        return this.mediaStreamingStatusDetails;
+    }
+
+    /**
+     * Set the mediaStreamingStatusDetails property: The mediaStreamingStatusDetails property.
+     *
+     * @param mediaStreamingStatusDetails the mediaStreamingStatusDetails value to set.
+     * @return the MediaStreamingUpdate object itself.
+     */
+    public MediaStreamingUpdate setMediaStreamingStatusDetails(
+            MediaStreamingStatusDetails mediaStreamingStatusDetails) {
+        this.mediaStreamingStatusDetails = mediaStreamingStatusDetails;
+        return this;
+    }
+}
diff --git a/sdk/communication/azure-communication-callautomation/src/test/java/com/azure/communication/callautomation/CallAutomationEventParserAndProcessorUnitTests.java b/sdk/communication/azure-communication-callautomation/src/test/java/com/azure/communication/callautomation/CallAutomationEventParserAndProcessorUnitTests.java
index 3c23a7e0c411..c7c98545a802 100644
--- a/sdk/communication/azure-communication-callautomation/src/test/java/com/azure/communication/callautomation/CallAutomationEventParserAndProcessorUnitTests.java
+++ b/sdk/communication/azure-communication-callautomation/src/test/java/com/azure/communication/callautomation/CallAutomationEventParserAndProcessorUnitTests.java
@@ -49,6 +49,11 @@
 import com.azure.communication.callautomation.models.events.TranscriptionStatusDetails;
 import com.azure.communication.callautomation.models.events.TranscriptionStopped;
 import com.azure.communication.callautomation.models.events.TranscriptionUpdated;
+import com.azure.communication.callautomation.models.events.MediaStreamingStarted;
+import com.azure.communication.callautomation.models.events.MediaStreamingStopped;
+import com.azure.communication.callautomation.models.events.MediaStreamingFailed;
+import com.azure.communication.callautomation.models.events.MediaStreamingStatus;
+import com.azure.communication.callautomation.models.events.MediaStreamingStatusDetails;
 import org.junit.jupiter.api.Test;
 
 import java.util.List;
@@ -1426,4 +1431,101 @@ public void parseHoldFailedEvent() {
         assertEquals(400, holdFailed.getResultInformation().getCode());
         assertEquals(ReasonCode.Play.DOWNLOAD_FAILED, holdFailed.getReasonCode());
     }
+
+    @Test
+    public void parseMediaStreamingStartedEvent() {
+        String receivedEvent = "[{\n"
+            + "\"id\":\"d13c62c5-721e-44b9-a680-9866c33db7e7\",\n"
+            + "\"source\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"type\":\"Microsoft.Communication.MediaStreamingStarted\",\n"
+            + "\"data\":{\"eventSource\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"operationContext\":\"startMediaStreamingContext\",\n"
+            + "\"resultInformation\":{\"code\":200,\"subCode\":0,\"message\":\"Action completed successfully.\"},\n"
+            + "\"mediaStreamingUpdate\":{\"contentType\":\"Audio\",\n"
+            + "\"mediaStreamingStatus\":\"mediaStreamingStarted\",\n"
+            + "\"mediaStreamingStatusDetails\":\"subscriptionStarted\"},\n"
+            + "\"version\":\"2024-06-15-preview\",\n"
+            + "\"callConnectionId\":\"4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"serverCallId\":\"aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDEtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi9LTTQteUZBUmhVYXN3T1RqbklPSXZnP2k9MTAtMTI4LTk1LTUyJmU9NjM4NTAwMTgzOTYwNzY2MzQ0\",\n"
+            + "\"correlationId\":\"30f0ad34-d615-4bf3-8476-5630ae7fc3db\",\n"
+            + "\"publicEventType\":\"Microsoft.Communication.MediaStreamingStarted\"},\n"
+            + "\"time\":\"2024-05-02T11:20:42.9110236+00:00\",\n"
+            + "\"specversion\":\"1.0\",\n"
+            + "\"datacontenttype\":\"application/json\",\n"
+            + "\"subject\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\"}]";
+
+        MediaStreamingStarted event = (MediaStreamingStarted) CallAutomationEventParser.parseEvents(receivedEvent).get(0);
+        assertNotNull(event);
+        assertEquals("aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDEtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi9LTTQteUZBUmhVYXN3T1RqbklPSXZnP2k9MTAtMTI4LTk1LTUyJmU9NjM4NTAwMTgzOTYwNzY2MzQ0", event.getServerCallId());
+        assertEquals("4c1f5600-a9c6-4343-8979-b638a98de98f", event.getCallConnectionId());
+        assertEquals("30f0ad34-d615-4bf3-8476-5630ae7fc3db", event.getCorrelationId());
+        assertEquals("Action completed successfully.", event.getResultInformation().getMessage());
+
+        assertNotNull(event.getMediaStreamingUpdateResult());
+        assertEquals(MediaStreamingStatus.MEDIA_STREAMING_STARTED, event.getMediaStreamingUpdateResult().getMediaStreamingStatus());
+        assertEquals(MediaStreamingStatusDetails.SUBSCRIPTION_STARTED, event.getMediaStreamingUpdateResult().getMediaStreamingStatusDetails());
+    }
+
+    @Test
+    public void parseMediaStreamingStoppedEvent() {
+        String receivedEvent = "[{\n"
+            + "\"id\":\"41039554-9475-491a-875b-08d23c5d0e75\",\n"
+            + "\"source\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"type\":\"Microsoft.Communication.MediaStreamingStopped\",\n"
+            + "\"data\":{\"eventSource\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"operationContext\":\"startMediaStreamingContext\",\n"
+            + "\"resultInformation\":{\"code\":200,\"subCode\":0,\"message\":\"Action completed successfully.\"},\n"
+            + "\"mediaStreamingUpdate\":{\"contentType\":\"Audio\",\"mediaStreamingStatus\":\"mediaStreamingStopped\",\n"
+            + "\"mediaStreamingStatusDetails\":\"subscriptionStopped\"},\n"
+            + "\"version\":\"2024-06-15-preview\",\"callConnectionId\":\"4c1f5600-a9c6-4343-8979-b638a98de98f\",\n"
+            + "\"serverCallId\":\"aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDEtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi9LTTQteUZBUmhVYXN3T1RqbklPSXZnP2k9MTAtMTI4LTk1LTUyJmU9NjM4NTAwMTgzOTYwNzY2MzQ0\",\n"
+            + "\"correlationId\":\"30f0ad34-d615-4bf3-8476-5630ae7fc3db\",\n"
+            + "\"publicEventType\":\"Microsoft.Communication.MediaStreamingStopped\"},\n"
+            + "\"time\":\"2024-05-02T11:21:10.0261068+00:00\",\"specversion\":\"1.0\",\n"
+            + "\"datacontenttype\":\"application/json\",\n"
+            + "\"subject\":\"calling/callConnections/4c1f5600-a9c6-4343-8979-b638a98de98f\"}]";
+
+        MediaStreamingStopped event = (MediaStreamingStopped) CallAutomationEventParser.parseEvents(receivedEvent).get(0);
+        assertNotNull(event);
+        assertEquals("aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDEtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi9LTTQteUZBUmhVYXN3T1RqbklPSXZnP2k9MTAtMTI4LTk1LTUyJmU9NjM4NTAwMTgzOTYwNzY2MzQ0", event.getServerCallId());
+        assertEquals("4c1f5600-a9c6-4343-8979-b638a98de98f", event.getCallConnectionId());
+        assertEquals("30f0ad34-d615-4bf3-8476-5630ae7fc3db", event.getCorrelationId());
+        assertEquals("Action completed successfully.", event.getResultInformation().getMessage());
+
+        assertNotNull(event.getMediaStreamingUpdateResult());
+        assertEquals(MediaStreamingStatus.MEDIA_STREAMING_STOPPED, event.getMediaStreamingUpdateResult().getMediaStreamingStatus());
+        assertEquals(MediaStreamingStatusDetails.SUBSCRIPTION_STOPPED, event.getMediaStreamingUpdateResult().getMediaStreamingStatusDetails());
+    }
+    
+    @Test
+    public void parseMediaStreamingFailedEvent() {
+        String receivedEvent = "[{\n"
+            + "\"id\":\"a9bb7545-8f87-42aa-85d0-d7120dbe2414\",\n"
+            + "\"source\":\"calling/callConnections/761f5600-43ab-48a0-bbad-ecc5ad5b15bb\",\n"
+            + "\"type\":\"Microsoft.Communication.MediaStreamingFailed\",\n"
+            + "\"data\":{\"eventSource\":\"calling/callConnections/761f5600-43ab-48a0-bbad-ecc5ad5b15bb\",\n"
+            + "\"operationContext\":\"startMediaStreamingContext\",\n"
+            + "\"resultInformation\":{\"code\":500,\"subCode\":8603,\n"
+            + "\"message\":\"Action failed, not able to establish websocket connection.\"},\n"
+            + "\"mediaStreamingUpdate\":{\"contentType\":\"Audio\",\n"
+            + "\"mediaStreamingStatus\":\"mediaStreamingFailed\",\n"
+            + "\"mediaStreamingStatusDetails\":\"streamConnectionUnsuccessful\"},\n"
+            + "\"version\":\"2024-06-15-preview\",\"callConnectionId\":\"761f5600-43ab-48a0-bbad-ecc5ad5b15bb\",\n"
+            + "\"serverCallId\":\"aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDQtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi94MVdMX0p3NnlVaW1aOEkzVi1MN3hnP2k9MTAtMTI4LTg0LTE3MSZlPTYzODQ5NzU2ODQ3MzUxNzU3Mg==\",\n"
+            + "\"correlationId\":\"6032c474-201d-4ad1-8900-f92a595a6d94\",\n"
+            + "\"publicEventType\":\"Microsoft.Communication.MediaStreamingFailed\"},\n"
+            + "\"time\":\"2024-05-02T12:38:31.242039+00:00\",\"specversion\":\"1.0\",\"datacontenttype\":\"application/json\",\n"
+            + "\"subject\":\"calling/callConnections/761f5600-43ab-48a0-bbad-ecc5ad5b15bb\"}]";
+
+        MediaStreamingFailed event = (MediaStreamingFailed) CallAutomationEventParser.parseEvents(receivedEvent).get(0);
+        assertNotNull(event);
+        assertEquals("aHR0cHM6Ly9hcGkuZmxpZ2h0cHJveHkuc2t5cGUuY29tL2FwaS92Mi9jcC9jb252LW1hc28tMDQtcHJvZC1ha3MuY29udi5za3lwZS5jb20vY29udi94MVdMX0p3NnlVaW1aOEkzVi1MN3hnP2k9MTAtMTI4LTg0LTE3MSZlPTYzODQ5NzU2ODQ3MzUxNzU3Mg==", event.getServerCallId());
+        assertEquals("761f5600-43ab-48a0-bbad-ecc5ad5b15bb", event.getCallConnectionId());
+        assertEquals("6032c474-201d-4ad1-8900-f92a595a6d94", event.getCorrelationId());
+        assertEquals("Action failed, not able to establish websocket connection.", event.getResultInformation().getMessage());
+
+        assertNotNull(event.getMediaStreamingUpdateResult());
+        assertEquals(MediaStreamingStatus.MEDIA_STREAMING_FAILED, event.getMediaStreamingUpdateResult().getMediaStreamingStatus());
+        assertEquals(MediaStreamingStatusDetails.STREAM_CONNECTION_UNSUCCESSFUL, event.getMediaStreamingUpdateResult().getMediaStreamingStatusDetails());
+    }
 }
diff --git a/sdk/communication/azure-communication-callautomation/swagger/README.md b/sdk/communication/azure-communication-callautomation/swagger/README.md
index ef67ad58215d..ac049ef9e06c 100644
--- a/sdk/communication/azure-communication-callautomation/swagger/README.md
+++ b/sdk/communication/azure-communication-callautomation/swagger/README.md
@@ -28,7 +28,7 @@ autorest README.md --java --v4 --use=@autorest/java@4.0.20 --use=@autorest/model
 ``` yaml
 tag: package-2023-10-03-preview
 require:
-    - https://github.com/Azure/azure-rest-api-specs/blob/77d25dd8426c4ba1619d15582a8c9d9b2f6890e8/specification/communication/data-plane/CallAutomation/readme.md
+    - https://github.com/Azure/azure-rest-api-specs/blob/ebedc156cf07929f3f72e71e5323ecdfa402267d/specification/communication/data-plane/CallAutomation/readme.md
 java: true
 output-folder: ../
 license-header: MICROSOFT_MIT_SMALL
@@ -254,6 +254,9 @@ directive:
 - remove-model: TranscriptionStopped
 - remove-model: TranscriptionUpdated
 - remove-model: TranscriptionFailed
+- remove-model: MediaStreamingStarted
+- remove-model: MediaStreamingStopped
+- remove-model: MediaStreamingFailed
 
 
 ```