Is it possible to create an IBM MQ broker in spring boot 3?

[sw-tracker]

We would like to create an embedded IBM MQ broker in our mock, so we can test our MQ code. We know that we could also do this with test containers, but embedded tends to be faster. Does your library support this?

• Spring boot 3.
• Java version: 17.

[ibmmqmet]

This package doesn't provide any mock objects. Most people use a real queue manager for testing - a permanently-running container in the test infrastructure would be fast to connect to. So many object depend on other objects (like you can't get a Destination without having a Connection) that faking it is likely to be more trouble than it's worth.

[sw-tracker]

I ended up creating a testcontainer, however, if I create a docker container manually and then connect my application to it, it works. If I create the broker as a testcontainer, I get the following error:

Caused by: com.ibm.mq.MQException: JMSCMQ0001: IBM MQ call failed with compcode '2' ('MQCC_FAILED') reason '2035' ('MQRC_NOT_AUTHORIZED').

Test Container:

@Configuration
class ImbMqTestContainerConfig {

  @Bean
  fun ibmMqTestContainer(): GenericContainer<*> {
    val hostPort = 1414
    val containerExposedPort = 1414
    val portBinding =
        PortBinding(Ports.Binding.bindPort(hostPort), ExposedPort(containerExposedPort))

    val dockerfile =
        ImageFromDockerfile()
            .withFileFromClasspath("Dockerfile", "mq/Dockerfile")
            .withFileFromClasspath("20-config.mqsc", "mq/20-config.mqsc")

    return GenericContainer(dockerfile)
        .withExposedPorts(containerExposedPort)
        .withCreateContainerCmdModifier { cmd ->
          cmd.withHostConfig(HostConfig().withPortBindings(portBinding))
        }
        .withEnv("LICENSE", "accept")
        .withEnv("MQ_QMGR_NAME", "QM1")
  }
}

Listener:

@Service
class MqConsumer : SessionAwareMessageListener<ObjectMessage> {

    @JmsListener(destination = "MY.QUEUE")
    override fun onMessage(message: ObjectMessage, session: Session) {
        println("Received JMS Message <$message>")
    }
}

Configuration:

ibm:
  mq:
    queueManager: QM1
    connName: localhost(1414)
    channel: DEV.ADMIN.SVRCONN
    user: admin
    password: passw0rd

As mentioned above:

• If I start a docker container like this docker run --env LICENSE=accept --publish 1414:1414 --publish 9443:9443 --env MQ_QMGR_NAME=QM1 ibmcom/mq:9.2.0.0-r1 and dont create the test container, then my application can connect to the broker successfully.
• If I start the test container, and create the listener in a separate spring boot application, the application can connect to the test container broker successfully.
• If I have the test container and the listener in the same application, then I get MQRC_NOT_AUTHORIZED error. Maybe I need to delay the JMS configuration? Any ideas on how to make this work?

[sw-tracker]

Sorry my bad, the listener should have been configured like this:

    @JmsListener(destination = "MY.QUEUE")
    fun onMessage(message: String) {
        println("Received JMS Message <$message>")
    }