Create a RabbitMQ Connection

RMQUtils.kt

import com.rabbitmq.client.Connection
import com.rabbitmq.client.ConnectionFactory

/**
 * Create a RabbitMQ Connection.
 *
 * @param host the host
 * @param port the port
 * @param username the username (can be null)
 * @param password the username (can be null)
 *
 * return a new channel
 */
fun buildConnection(host: String, port: Int, username: String?, password: String?): Connection {

  val factory = ConnectionFactory()

  factory.host = host
  factory.port = port

  if (username != null && password != null) {
    factory.username = username
    factory.password = password
  }

  factory.isAutomaticRecoveryEnabled = true // isn't automatic recovery enabled by default?
  factory.requestedHeartbeat = 1800 // http://www.rabbitmq.com/heartbeats.html

  return factory.newConnection()
}