当前位置：源码 > Java源码 >

Java源码示例：com.consol.citrus.dsl.endpoint.CitrusEndpoints

示例1

@Bean
public JmsEndpoint jmsInboundEndpoint() {
    return CitrusEndpoints
            .jms()
            .asynchronous()
            .destination("jms.inbound.queue")
            .build();
}

示例2

@Bean
public JmsEndpoint jmsOutboundEndpoint() {
    return CitrusEndpoints
            .jms()
            .asynchronous()
            .destination("jms.outbound.queue")
            .build();
}

示例3

@Bean("httpClient")
public HttpClient client() {
    return CitrusEndpoints
            .http()
            .client()
            .requestUrl("http://localhost:8080/foo")
            .build();
}

示例4

@Bean(name = "jmsSyncEndpoint")
public JmsSyncEndpoint jmsEndpoint() {
    return CitrusEndpoints
            .jms()
            .synchronous()
            .destination("jms.inbound.sync.queue")
            .build();
}

示例5

@Bean
public JmsEndpoint sampleEndpoint() {
    return CitrusEndpoints
            .jms()
            .asynchronous()
            .destination("jms.inbound.queue")
            .build();
}

示例6

@Bean
public HttpClient httpClient() {
    return CitrusEndpoints
            .http()
            .client()
            .requestUrl("http://localhost:8080/foo")
            .build();
}

示例7

/**
 * Citrus JMS endpoint
 * do a sync request/reply over JMS on the queue named order.status with a timeout of 10 seconds
 */
@Bean
public JmsEndpoint statusEndpoint() {
    return CitrusEndpoints.jms().synchronous()
        .connectionFactory(jmsConnectionFactory())
        .destination("order.status")
        .timeout(10000L)
        .build();
}

示例8

/**
 * Citrus Http client
 * do a sync request/reply over HTTP on localhost:8080/order with a GET call and timeout for 60 seconds
 */
@Bean
public HttpClient statusHttpClient() {
    return CitrusEndpoints.http()
            .client()
            .requestUrl("http://localhost:8080/order")
            .requestMethod(HttpMethod.GET)
            .contentType("text/xml")
            .timeout(60000L)
            .build();
}

示例9

@Bean
public JmsSyncEndpoint simulatorEndpoint() {
    return CitrusEndpoints.jms()
            .synchronous()
            .connectionFactory(connectionFactory())
            .destination("Citrus.Simulator.Inbound")
            .timeout(10000L)
            .build();
}

示例10

@Bean
public HttpClient simulatorHttpClientEndpoint() {
    return CitrusEndpoints.http()
            .client()
            .timeout(defaultTimeout)
            .requestUrl(String.format("https://localhost:%s/", port))
            .requestFactory(sslRequestFactory())
            .build();
}

示例11

@Bean
public WebServiceClient simulatorClient() {
    return CitrusEndpoints.soap().client()
            .defaultUri(String.format("http://localhost:%s/services/ws/simulator", 8080))
            .interceptor(loggingClientInterceptor())
            .messageFactory(messageFactory())
            .faultStrategy(ErrorHandlingStrategy.PROPAGATE)
            .build();
}

示例12

@Bean
public WebServiceClient simulatorClient() {
    return CitrusEndpoints.soap().client()
            .defaultUri(String.format("http://localhost:%s/services/ws/HelloService/v1", 8080))
            .interceptor(loggingClientInterceptor())
            .messageFactory(messageFactory())
            .build();
}

示例13

@Bean
public JmsEndpoint simulatorJmsStatusEndpoint() {
    return CitrusEndpoints.jms()
            .asynchronous()
            .destination(statusDestinationName)
            .connectionFactory(connectionFactory())
            .build();
}

示例14

@Bean
public JmsEndpoint simulatorInboundEndpoint() {
    return CitrusEndpoints.jms()
            .asynchronous()
            .connectionFactory(connectionFactory())
            .destination("Fax.Inbound")
            .build();
}

示例15

@Bean
public JmsEndpoint simulatorStatusEndpoint() {
    return CitrusEndpoints.jms()
            .asynchronous()
            .connectionFactory(connectionFactory())
            .destination("Fax.Status")
            .build();
}

示例16

@Bean
public HttpClient simulatorRestEndpoint() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s", 8080))
            .contentType(MediaType.APPLICATION_JSON_VALUE)
            .build();
}

示例17

@Bean
public WebServiceServer testSoapServer() {
    return CitrusEndpoints.soap().server()
            .autoStart(true)
            .port(8090)
            .timeout(5000L)
            .build();
}

示例18

@Bean
public HttpClient simulatorRestEndpoint() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s", 8080))
            .contentType(MediaType.APPLICATION_JSON_VALUE)
            .build();
}

示例19

@Bean
public MailClient simulatorMailClient() {
    return CitrusEndpoints.mail().client()
            .host("localhost")
            .port(2222)
            .build();
}

示例20

@Bean
public JmsSyncEndpoint simulatorEndpoint() {
    return CitrusEndpoints.jms()
            .synchronous()
            .connectionFactory(connectionFactory())
            .destination("Citrus.Simulator.Inbound")
            .timeout(10000L)
            .build();
}

示例21

@Bean
public HttpClient petstoreClient() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s/petstore/v2", 8080))
            .build();
}

示例22

@Bean
public HttpClient simulatorUiClient() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s", 8080))
            .build();
}

示例23

@Bean
public HttpClient simulatorClient() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s/services/rest/simulator", 8080))
            .build();
}

示例24

@Bean
public HttpClient simulatorClient() {
    return CitrusEndpoints.http().client()
            .requestUrl(String.format("http://localhost:%s/services/rest/simulator", 8080))
            .build();
}

Java源码示例：com.consol.citrus.dsl.endpoint.CitrusEndpoints

微信关注