Merge pull request #268 from laserg/issue-267

Provide ability to publish and consume binary data directly

Author: viartemev

src/main/kotlin/com/viartemev/thewhiterabbit/channel/TxChannel.kt

@@ -34,7 +34,7 @@ open class TxChannel internal constructor(private val channel: Channel) : Channe
 
         fun publish(message: OutboundMessage) {
             message.apply {
-                this@TxChannel.channel.basicPublish(exchange, routingKey, properties, msg.toByteArray())
+                this@TxChannel.channel.basicPublish(exchange, routingKey, properties, msg)
             }
         }
 

src/main/kotlin/com/viartemev/thewhiterabbit/publisher/ConfirmPublisher.kt

@@ -35,7 +35,7 @@ class ConfirmPublisher internal constructor(private val channel: Channel) {
             continuations[messageSequenceNumber] = continuation
             continuation.invokeOnCancellation { continuations.remove(messageSequenceNumber) }
             cancelOnIOException(continuation) {
-                message.run { channel.basicPublish(exchange, routingKey, properties, msg.toByteArray()) }
+                message.run { channel.basicPublish(exchange, routingKey, properties, msg) }
             }
         }
     }

src/main/kotlin/com/viartemev/thewhiterabbit/publisher/OutboundMessage.kt

@@ -6,5 +6,34 @@ data class OutboundMessage(
     val exchange: String,
     val routingKey: String,
     val properties: BasicProperties,
-    val msg: String
-)
+    val msg: ByteArray
+) {
+    constructor(
+        exchange: String,
+        routingKey: String,
+        properties: BasicProperties,
+        msg: String
+    ) : this(exchange, routingKey, properties, msg.toByteArray())
+
+    override fun equals(other: Any?): Boolean {
+        if (this === other) return true
+        if (javaClass != other?.javaClass) return false
+
+        other as OutboundMessage
+
+        if (exchange != other.exchange) return false
+        if (routingKey != other.routingKey) return false
+        if (properties != other.properties) return false
+        if (!msg.contentEquals(other.msg)) return false
+
+        return true
+    }
+
+    override fun hashCode(): Int {
+        var result = exchange.hashCode()
+        result = 31 * result + routingKey.hashCode()
+        result = 31 * result + properties.hashCode()
+        result = 31 * result + msg.contentHashCode()
+        return result
+    }
+}