Integration test via message broker

There are two programs that communicate using a message broker and I want to cover some of the interactions between them using integration tests.

So, I want to write an integration test that will use JUnit before it wants to run an external program in the phase, and it needs to be cleaned up in the after phase.

Is there a good way to do this, or am I just going the wrong way?