Updated library & main.yaml

.github/workflows/main.yml

@@ -17,9 +17,15 @@ jobs:
       - name: Checkout repository
         uses: actions/checkout@v2
 
-
+      - name: Cache CommonCode Gradle dependencies
+        id: cache-gradle
+        uses: actions/cache@v2
+        with:
+          path: ~/.gradle/caches
+          key: ${{ runner.os }}-gradle-${{ hashFiles('CommonCode/gradle/wrapper/gradle-wrapper.properties') }}
 
       - name: Build CommonCode
+        if: steps.cache-gradle.outputs.cache-hit != 'true'
         run: |
           cd CommonCode 
           chmod +x ./gradlew
@@ -44,6 +50,14 @@ jobs:
             echo "::set-output name=changed::false"
           fi
 
+      - name: Cache CommonCode Gradle dependencies
+        id: cache-gradle
+        uses: actions/cache@v2
+        with:
+          path: ~/.gradle/caches
+          key: ${{ runner.os }}-gradle-${{ hashFiles('CommonCode/gradle/wrapper/gradle-wrapper.properties') }}
+
+
       - name: Build Encode module
         id: build-encode
         run: |
@@ -97,6 +111,13 @@ jobs:
             echo "::set-output name=changed::false"
           fi
 
+      - name: Cache CommonCode Gradle dependencies
+        id: cache-gradle
+        uses: actions/cache@v2
+        with:
+          path: ~/.gradle/caches
+          key: ${{ runner.os }}-gradle-${{ hashFiles('CommonCode/gradle/wrapper/gradle-wrapper.properties') }}
+
       - name: Build Reader module
         id: build-reader
         run: |

Reader/build.gradle.kts

@@ -23,7 +23,7 @@ repositories {
 }
 
 dependencies {
-    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha39")
+    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha41")
     implementation("no.iktdev:exfl:0.0.4-SNAPSHOT")
 
     implementation("com.github.pgreze:kotlin-process:1.3.1")

Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedDeserializers.kt

@@ -27,6 +27,7 @@ class EncodedDeserializers {
 
     val mediaStreams = object : IMessageDataDeserialization<MediaStreams> {
         override fun deserialize(incomingMessage: Message): MediaStreams? {
+            return try {
                 if (incomingMessage.status.statusType != StatusType.SUCCESS) {
                     return null
                 }
@@ -52,6 +53,10 @@ class EncodedDeserializers {
                 }
 
                 return MediaStreams(rstreams)
+            } catch (e: Exception) {
+                e.printStackTrace()
+                null
+            }
         }
 
     }