Update documentation (#50)

gojek · Oct 31, 2022 · a227b3b · a227b3b
1 parent 09892e0
commit a227b3b
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/docs/docs/MessageStreamAdapters.md b/docs/docs/MessageStreamAdapters.md
@@ -26,13 +26,17 @@ class MyCustomMessageAdapterFactory : MessageAdapter.Factory {
 
 private class MyCustomMessageAdapter<T> constructor() : MessageAdapter<T> {
 
-    override fun fromMessage(message: Message): T {
+    override fun fromMessage(topic: String, message: Message): T {
         // convert message to custom type
     }
 
-    override fun toMessage(data: T): Message {
+    override fun toMessage(topic: String, data: T): Message {
         // convert custom type to message
     }
+
+    override fun contentType(): String {
+        // content-type supported by this adapter.
+    }
 }
 ~~~