如何在spring集成中模拟连接工厂

Question

<jee:jndi-lookup id="narconFactory" jndi-name="LBARQCF" resource-ref="false"/>

@RunWith(SpringRunner.class)
@SpringBootTest
public class MQControllerTest {

//step 2
@Autowired
private MockMvc mvc;

@MockBean
private MQController mqController;

protected static final ConnectionFactory amqFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");

public static final CachingConnectionFactory connectionFactory = new CachingConnectionFactory(amqFactory);

@BeforeClass
public static void startUp() throws Exception {
    connectionFactory.setCacheConsumers(false);
    connectionFactory.createConnection().close();
}

@AfterClass
public static void shutDown() {
    connectionFactory.resetConnection();
}

@Autowired
private JmsTemplate mockJmsTemplate;

@Autowired
private SourcePollingChannelAdapter startJms;


@Before
public void setup() throws JMSException{
    Mockito.reset(this.mockJmsTemplate);
}   

@Test
public void test_tbm_vrijeDagenCorrectie() throws Exception {

    String expectedResponse ="";
    //using bddmockito
    given(mqController.tmVDCorrect(any(String.class))).willReturn(expectedResponse);

    this.startJms.start();

    mvc.perform(get("/tm/vdc/{dgn}","2016-01-16"))
               .andExpect(status().isOk());

}

    <util:constant id="narconFactory" static-field="n.d.poc.MQControllerTest.connectionFactory"/>
     <util:constant id="vanconFactory" static-field="n.d.poc.MQControllerTest.connectionFactory"/> 

<罢工> 错误：

没有类型为'org.springframework.test.web.servlet.mockMVC'的合格bean可用：至少需要1个符合autowire候选的bean。依赖项注释：{@org.springframework.beans.factory.annotation.autowire(required=true)}位于org.springframework.beans.factory.support.defaultListableBeanFactory.raisenomatchingBeanFound(DefaultListableBeanFactory.java:1474)~[spring-beans-4.3.5.release.jar:4.3.5.release]

<罢工> 我不知道我的错误是什么 编辑2：

github https://github.com/kswat/lrIntegrationUnit中的示例代码

Answer 1

我建议考虑使用ActiveMQ及其嵌入式模式，而不是mocking。通过这种方式，您将获得完整的JMS，并且不会处理低级资源来进行模拟。

在Spring Integration中，我们有以下测试目的：

/**
 * Keeps an ActiveMQ {@link VMTransport} open for the duration of
 * all tests (avoids cycling the transport each time the last
 * connection is closed).
 * @author Gary Russell
 * @since 3.0
 *
 */
public abstract class ActiveMQMultiContextTests {

    protected static final ConnectionFactory amqFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");

    protected static final CachingConnectionFactory connectionFactory = new CachingConnectionFactory(
            amqFactory);

    @BeforeClass
    public static void startUp() throws Exception {
        connectionFactory.setCacheConsumers(false);
        connectionFactory.createConnection().close();
    }

    @AfterClass
    public static void shutDown() {
        connectionFactory.resetConnection();
    }

}

ConnectionFactory静态属性确实可以用作bean：

<util:constant id="narconFactory"
               static-field="ActiveMQMultiContextTests.connectionFactory"/>