Include bytesMessage in PublishDslBuilderMessage.java

[hjklapp]

Sending byte messages to Rabbitmq/amqp is possible in scala, but missing from the java wrapper.

Please include bytesMessage in PublishDslBuilderMessage.java, wrapping ru.tinkoff.gatling.amqp.request.PublishDslBuilderMessage.bytesMessage.

[tibi-billie]

That would be great, I am missing this as I am trying to send a serialized protobuf message.
Until this is added, is there some workaround maybe I could use?
Thanks a lot!

[hjklapp]

As a workaround I used the underlying DSL, something like this

  private val sendMessage: ScenarioBuilder = scenario("Send message")
    .exec { session -> session.set("message", byteMessage) }
    .exec(
        PublishDslBuilder(
            ru.tinkoff.gatling.amqp.Predef.amqp(toStringExpression("Send message"))
              .publish(Predef.configuration())
              .topicExchange(
                  toStringExpression(EXCHANGE),
                  toStringExpression(ROUTING_KEY))
              .bytesMessage(toBytesExpression("#{message}"))).priority(0)
    )