val amqpConf: AmqpProtocolBuilder = amqp
  .connectionFactory(
  rabbitmq
  .host(RABBIT_COMMON_HOST)
  .port(RABBIT_PORT)
  .username(RABBIT_USERNAME)
  .password(RABBIT_PASSWORD)
  .vhost("/")
  )
  .useNonPersistentDeliveryMode

  val scn: ScenarioBuilder = scenario("load test")
    .exec(
    amqp("publish to exchange").publish
    .directExchange("exc.some.hx", "")
    .textMessage("Hello message")
    .priority(0)
    .property("prop1", "UPDATE")
    .property("prop2", "Person")
    )

  setUp(
  scn.inject(rampUsersPerSec(1) to 5 during (60 seconds), constantUsersPerSec(5) during (5 minutes))
  ).protocols(amqpConf)
  .maxDuration(10 minutes)