1 files changed, 3 insertions, 14 deletions
diff --git a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoder.kt b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoder.kt
index cdc70f82..60e7d70a 100644
--- a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoder.kt
+++ b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoder.kt
@@ -19,7 +19,6 @@
  */
 package org.onap.dcae.collectors.veshv.impl
 
-import com.google.protobuf.InvalidProtocolBufferException
 import io.netty.buffer.ByteBuf
 import org.onap.dcae.collectors.veshv.model.VesMessage
 import org.onap.dcae.collectors.veshv.utils.logging.Logger
@@ -31,18 +30,8 @@ import org.onap.ves.VesEventV5.VesEvent
  */
 internal class VesDecoder {
 
-    fun decode(bb: ByteBuf): VesMessage? =
-            try {
-                val decodedHeader = VesEvent.parseFrom(bb.nioBuffer()).commonEventHeader
-                VesMessage(decodedHeader, bb)
-            } catch (ex: InvalidProtocolBufferException) {
-                logger.warn { "Dropping incoming message. Invalid protocol buffer: ${ex.message}" }
-                logger.debug("Cause", ex)
-                null
-            }
-
-
-    companion object {
-        private val logger = Logger(VesDecoder::class)
+    fun decode(bb: ByteBuf): VesMessage {
+        val decodedHeader = VesEvent.parseFrom(bb.nioBuffer()).commonEventHeader
+        return VesMessage(decodedHeader, bb)
     }
 }