JavaPhoenixClient is a Kotlin implementation of the phoenix.js client used to manage Phoenix channels.
fun connectToChatRoom() {
// Create the Socket
val params = hashMapOf("token" to "abc123")
val socket = PhxSocket("http://localhost:4000/socket/websocket", multipleParams
// Listen to events on the Socket
socket.logger = { Log.d("TAG", it) }
socket.onOpen { Log.d("TAG", "Socket Opened") }
socket.onClose { Log.d("TAG", "Socket Closed") }
socket.onError { Log.d(it, "TAG", "Socket Error") }
socket.connect()
// Join channels and listen to events
val chatroom = socket.channel("chatroom:general")
chatroom.on("new_message") {
// `it` is a PhxMessage object
val payload = it.payload
}
chatroom.join()
.receive("ok") { /* Joined the chatroom */ }
.receive("error") { /* failed to join the chatroom */ }
}JavaPhoenixClient is hosted on JCenter. You'll need to make sure you declare jcenter() as one of your repositories
repositories {
jcenter()
}
and then add the library. See releases for the latest version
dependencies {
implementation 'com.github.dsrees:JavaPhoenixClient:0.1.1'
}
Please submit in issue if you have any problems!
This library is built to mirror the phoenix.js and SwiftPhoenixClient libraries.