Làm thế nào để kiểm tra Spring Integration

Question

Tôi mới vào Spring Integration. Tôi có ActiveMQ với câu trả lời là 'responseQ'. Vì vậy, khi một tin nhắn đến 'responseQ' -> painResponseChannel -> transformer -> processResponseChannel -> beanProcessing. Tôi có thiết lập sau:

<jms:message-driven-channel-adapter extract-payload="true" 
            channel="painResponseChannel" 
            connection-factory="connectionFactory" 
            destination-name="responseQ"/> 

    <integration:channel id="painResponseChannel" /> 

    <integration-xml:unmarshalling-transformer 
     id="defaultUnmarshaller" 
     input-channel="painResponseChannel" 
     output-channel="processResponseChannel" 
     unmarshaller="marshaller"/> 

    <integration:channel id="processResponseChannel" /> 

    <integration:service-activator 
     input-channel="processResponseChannel" 
     ref="processResponseActivator"/> 

    <bean id="processResponseActivator" class="com.messaging.processor.PainResponseProcessor"/> 


    <bean id="marshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller"> 
     <property name="classesToBeBound"> 
     <list> 
      <value>com.domain.pain.Document</value> 
     </list> 
     </property> 
    </bean> 

Vì vậy, câu hỏi của tôi là TÔI CÓ THỂ THỬ NGHIỆM KẾT THÚC NÀY END? Làm thế nào tôi có thể khẳng định đầu ra của máy biến áp hoặc khẳng định whats trên kênh? Tôi đã thử nhưng thất bại ... Hy vọng ai đó có thể giúp đỡ.

Xin cảm ơn trước. GM

Tôi đã thử nghiệm như thế này: Trong ngữ cảnh thử nghiệm của tôi đã tạo bộ chuyển đổi kênh đi, khởi tạo việc đặt thông báo trên activeMQ bằng cách sử dụng kênh testJmsQueue. Và cũng đã tạo một BRIDGE cho processResponseChannel -> testChannel. Tôi đã mong đợi phương thức receive() trả lại cho tôi một cái gì đó. Nhưng tôi nghĩ vấn đề là nó quá nhanh và vào thời điểm nó nhận được phương thức receive() mà đường ống đã kết thúc.

Các thử bối cảnh trông như thế này:

<integration:bridge input-channel="processResponseChannel" output-channel="testChannel"/> 

<jms:outbound-channel-adapter id="jmsOut" destination-name="responseQ" channel="testJmsQueue"/> 

<integration:channel id="testJmsQueue"/> 

<integration:channel id="testChannel"> 
    <integration:queue/> 
</integration:channel> 

và sau đó trong các thử nghiệm đơn vị tôi có điều này:

@ContextConfiguration(locations = "classpath*:PainResponseTest-context.xml") 
@RunWith(SpringJUnit4ClassRunner.class) 
public class PainResponseTest { 

private String painResponseXML; 

@Autowired 
MessageChannel testJmsQueue; 
@Autowired 
QueueChannel testChannel; 

@Before 
public void setup() throws Exception { 

    ClassPathResource cpr = new ClassPathResource("painResponse.xml"); 
    InputStream is = cpr.getInputStream(); 
    StringWriter writer = new StringWriter(); 
    IOUtils.copy(is, writer, "UTF-8"); 
    painResponseXML = writer.toString(); 
} 

@Test 
@SuppressWarnings("unchecked") 
public void shouldDoSomething() throws InterruptedException { 

    testJmsQueue.send(MessageBuilder.withPayload(painResponseXML).build()); 

    Message<String> reply = (Message<String>) testChannel.receive(0); 
    Assert.assertNotNull("reply should not be null", reply); 
    String out = reply.getPayload(); 
    System.out.println(out); 
} 

}

==================== TEST OUTPUT ===================== 
java.lang.AssertionError: reply should not be null 

Bắt bài trả lời là null.

Answer 1

Để kiểm tra đầu cuối, bạn có thể thực hiện các thao tác sau; - sử dụng ActiveMQ trong một cấu hình nhúng để gửi tin nhắn JMS - tiêm một channelinterceptor trên processResponseChannel - cho phép mức độ DEBUG - Xuân Tích hợp cho các bản ghi rất tốt và hữu ích truy tìm các thông điệp vào và ra khỏi các kênh truyền hình và chất hoạt dịch vụ