[ECO-5338] Fixed liveobject test dependency

1. Fixed liveobject channel options while initializing test channel
2. Fixed utils as per review comments
3. Fixed adapter NotNull annotation for send method

Author: sacOO7

lib/src/main/java/io/ably/lib/objects/Adapter.java

@@ -25,7 +25,7 @@ public void setChannelSerial(@NotNull String channelName, @NotNull String channe
     }
 
     @Override
-    public void send(ProtocolMessage msg, CompletionListener listener) throws AblyException {
+    public void send(@NotNull ProtocolMessage msg, @NotNull CompletionListener listener) throws AblyException {
         // Always queue LiveObjects messages to ensure reliable state synchronization and proper acknowledgment
         ably.connection.connectionManager.send(msg, true, listener);
     }

lib/src/main/java/io/ably/lib/objects/LiveObjectsAdapter.java

@@ -15,7 +15,7 @@ public interface LiveObjectsAdapter {
      * @param listener a listener to be notified of the success or failure of the send operation.
      * @throws AblyException if an error occurs during the send operation.
      */
-    void send(ProtocolMessage msg, CompletionListener listener) throws AblyException;
+    void send(@NotNull ProtocolMessage msg, @NotNull CompletionListener listener) throws AblyException;
 
     /**
      * Sets the channel serial for a specific channel.

live-objects/src/test/kotlin/io/ably/lib/objects/integration/setup/IntegrationTest.kt

@@ -2,6 +2,8 @@ package io.ably.lib.objects.integration.setup
 
 import io.ably.lib.realtime.AblyRealtime
 import io.ably.lib.realtime.Channel
+import io.ably.lib.types.ChannelMode
+import io.ably.lib.types.ChannelOptions
 import kotlinx.coroutines.runBlocking
 import org.junit.After
 import org.junit.AfterClass
@@ -40,7 +42,10 @@ abstract class IntegrationTest {
         useBinaryProtocol = testParams == "msgpack_protocol"
       }. apply { ensureConnected() }
     }
-    return client.channels.get(channelName).apply {
+    val channelOpts = ChannelOptions().apply {
+      modes = arrayOf(ChannelMode.object_publish, ChannelMode.object_subscribe)
+    }
+    return client.channels.get(channelName, channelOpts).apply {
       attach()
       ensureAttached()
     }

live-objects/src/test/kotlin/io/ably/lib/objects/unit/TestHelpers.kt

@@ -3,29 +3,35 @@ package io.ably.lib.objects.unit
 import io.ably.lib.realtime.AblyRealtime
 import io.ably.lib.realtime.Channel
 import io.ably.lib.realtime.ChannelState
+import io.ably.lib.types.ChannelMode
+import io.ably.lib.types.ChannelOptions
 import io.ably.lib.types.ClientOptions
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.spyk
 
-internal fun getMockRealtimeChannel(channelName: String, clientId: String = "client1"): Channel {
-  val client = AblyRealtime(ClientOptions().apply {
-    autoConnect = false
-    key = "keyName:Value"
-    this.clientId = clientId
-  })
-  val channel = client.channels.get(channelName)
-  return spyk(channel) {
-    every { attach() } answers {
+internal fun getMockRealtimeChannel(
+  channelName: String,
+  clientId: String = "client1",
+  channelModes: Array<ChannelMode> = arrayOf(ChannelMode.object_publish, ChannelMode.object_subscribe)): Channel {
+    val client = AblyRealtime(ClientOptions().apply {
+      autoConnect = false
+      key = "keyName:Value"
+      this.clientId = clientId
+    })
+    val channelOpts = ChannelOptions().apply { modes = channelModes }
+    val channel = client.channels.get(channelName, channelOpts)
+    return spyk(channel) {
+      every { attach() } answers {
+        state = ChannelState.attached
+      }
+      every { detach() } answers {
+        state = ChannelState.detached
+      }
+      every { subscribe(any<String>(), any()) } returns mockk(relaxUnitFun = true)
+      every { subscribe(any<Array<String>>(), any()) } returns mockk(relaxUnitFun = true)
+      every { subscribe(any()) } returns mockk(relaxUnitFun = true)
+    }.apply {
       state = ChannelState.attached
     }
-    every { detach() } answers {
-      state = ChannelState.detached
-    }
-    every { subscribe(any<String>(), any()) } returns mockk(relaxUnitFun = true)
-    every { subscribe(any<Array<String>>(), any()) } returns mockk(relaxUnitFun = true)
-    every { subscribe(any()) } returns mockk(relaxUnitFun = true)
-  }.apply {
-    state = ChannelState.attached
-  }
 }