带Cxf和路由的Camel

Question

我在做一些关于Camel-CXf集成的研究，对下面的场景感到困惑。

所以我实现了一个Restendpoint

@Path("/authenticate")
public interface Sample {
@GET
@Path("/handshake")
@Produces(MediaType.TEXT_PLAIN)
public Response handshake();

@POST
@Path("/login")
@Consumes({MediaType.APPLICATION_JSON,MediaType.APPLICATION_XML})
@Produces(MediaType.APPLICATION_JSON)
public Response login(LoginRequest request) throws JsonGenerationException, JsonMappingException, IOException;
}

实现如下

public class SampleImpl implements Sample{

@Context
private HttpHeaders headers;

@Autowired
CamelContext context;

public Response handshake()
{
    System.out.println("HandShake Executed Successfully");
    return Response.status(Status.OK).entity("This is a Message after Routing").build();
}

public Response login(LoginRequest request) throws JsonGenerationException, JsonMappingException, IOException {
    System.out.println("The Rquest objecr is Received "+request);
    return Response.status(Status.OK).entity(mapper.writeValueAsString(request)).build();
}

}

路线

<camel:from uri="cxfrs:bean:SampleRestEndPoint?bindingStyle=SimpleConsumer"></camel:from>

将其路由到实现中。但是由于实现返回一个响应对象，我不知道如何绕过这个对象构建路由。

1. 一旦调用进入实现，我如何执行其他路由并发送回响应？在这种情况下，实现返回一个自定义对象。
2. 其他路由如何附加到 CXF 路由？
3. 我的 CXF 实现是否应该始终返回无效类型？如我所见，要访问 Exchange 对象骆驼，返回类型需要为 void
4. 我是否完全忽略了实现并执行“to”步骤并对其进行修改以换取所需的响应？

任何指示将不胜感激。

Answer 1

@GauthamHonnavara - 这是具有关联处理器的 JS Web 服务的实现，但它不会关联到endpoint的任何直接路由。另外，我的问题特定于 JAX-RS，您无法从 wsdl 生成服务类。

假设这个用例，您需要一个客户调用endpoint，然后再执行 5 个步骤，联系另一个 Web 服务等，然后发送回响应。上面的实现在 Web 服务实现 Bean 本身中发送回响应。

因此，为了避免这种情况，创建一个与生产者消费者等的简单接口，就像我的问题一样，然后使每个方法无效，如果你想注入交换(如果需要。)并使用以下配置

<!-- Created the CXF End Point For the  Calls to Come IN -->
<cxf:rsServer id="RestEndPoint" address="/rest"
    serviceClass="com.poc.camel.cxf.service.incoming.xxx"
    loggingFeatureEnabled="true" loggingSizeLimit="20">
    <cxf:providers>
        <bean class="org.codehaus.jackson.jaxrs.JacksonJsonProvider" >
            <!-- <constructor-arg ref="customObjectMapper" type="org.codehaus.jackson.map.ObjectMapper"/> -->
        </bean>
    </cxf:providers>
</cxf:rsServer>

诀窍是使用服务类标记。如果在那里提供了接口，那么它不需要 CXF 的具体实现。

希望这有帮助。让我知道

Answer 2

请查看以下线程。

Apache Camel和web服务

我已经成功地实现了使用Camel和Apache CXF的Web服务消费。如果你有疑问，我可以帮你。

谢谢，高森

Answer 3

伙计，看看这个 - http://bushorn.com/camel-cxf-geocoder-example/

虽然上面的例子不是REST，但是CXF和Camel route的用法是一样的。

我将执行以下强制性步骤：

>

避免bean/自定义类-尝试使用骆驼框架功能。

使用XML - Spring/Blueprint DSL