[FIXED] Tracing input & output of message channels of Spring Integration

Issue

I have build a small application using Spring Integration. I have also written some jUnit for more service and other classes. I have used XML configuration for the channel and en-point configuration, I am wondering if I can test the input and output of a perticular channel. Is there a way we can test the input and output of the channels?..

Update

I am trying to the below flow. How shall i proceed?

<int:channel id="getPresciption" />
<int:channel id="respPrescription" />
<int:channel id="storePrcedureChannell" />

<int-http:inbound-gateway
    request-channel="getPresciption" reply-channel="respPrescription"
    supported-methods="GET" path="/getAllPresciption">

    <int-http:request-mapping
        consumes="application/json" produces="application/json" />
</int-http:inbound-gateway>

<int:service-activator
    ref="prescriptionServiceActivator" method="buildPrescription"
    input-channel="getPresciption" output-channel="storePrcedureChannell" />

<int:service-activator
    ref="prescriptionServiceActivator" method="storePrescription"
    input-channel="storePrcedureChannell"></int:service-activator>

SO how can i write the Test contex?

Let below are the methods which are called by channel flow.

public Message<List<Prescription>> buildPrescription() {
  //Do some processing
}

public Message<List<Prescription>> storePrescription(Message<List<Prescription>> msg) {

  //Do something and return the List.
}

Solution

First of all you can take a look into the Spring Integration Testing Framework: https://docs.spring.io/spring-integration/reference/html/testing.html#test-context

And then use a MockIntegration.mockMessageHandler() together with the MockIntegrationContext.substituteMessageHandlerFor() to replace a real handler in the endpoint and verify incoming data from the channel.

If that is still hard for you, you always can inject those channels into your test class and add to them a ChannelInterceptor and verify messages in its preSend() implementation.

Answered By - Artem Bilan
Answer Checked By - Gilberto Lyons (JavaFixing Admin)