diff --git a/src/main/kotlin/com/mparticle/kits/RoktKit.kt b/src/main/kotlin/com/mparticle/kits/RoktKit.kt index 81d5566..9815e7b 100644 --- a/src/main/kotlin/com/mparticle/kits/RoktKit.kt +++ b/src/main/kotlin/com/mparticle/kits/RoktKit.kt @@ -57,6 +57,7 @@ class RoktKit : CommerceListener, IdentityListener, RoktListener, + KitIntegration.BatchListener, Rokt.RoktCallback { private var applicationContext: Context? = null private var mpRoktEventCallback: MpRoktEventCallback? = null @@ -135,6 +136,18 @@ class RoktKit : override fun logEvent(commerceEvent: CommerceEvent): List = emptyList() + /* + * Overrides for BatchListener + */ + override fun logBatch(jsonObject: org.json.JSONObject): List { + try { + Rokt.receiveMParticleBatch(jsonObject.toString()) + } catch (e: Exception) { + Logger.warning("RoktKit: Failed to forward batch to Rokt: ${e.message}") + } + return emptyList() + } + /* * Overrides for IdentityListener */