我正在从Camel2迁移到Camel3,我渴望使用这里描述的endpointDSL,但是在迁移endpoint时遇到了一个问题。
我曾经有一条路由写到RabbitMQ队列,如下所示:
.toD("rabbitmq:$vhost?connectionFactory=#customConnectionFactory&queue=$responseQueueName&autoDelete=false&routingKey=$responseQueueName&bridgeEndpoint=true")
.toD(
rabbitmq(vhost)
.connectionFactory(connectionFactory)
.queue(responseQueueName)
.autoDelete(false)
.routingKey(responseQueueName)
.bridgeEndpoint(true)
原来问题出在用tod
指定的输出endpoint上,将其切换到常规to
就解决了问题。
我是阿帕奇骆驼队的新手。我试图将一个交换从java方法发送到一个路由,但它给了我“由:org.apache.camel.component.direct.DirectConsumerNotAvailableException:endpoint上没有可用的消费者”错误。我想知道这个错误到底是什么,我们什么时候得到这个?
我正在构建一个路由slip bean,除了动态路由之外,我还想向收件人列表的endpoint发送一个参数。 我希望使用类似“direct:test?param=value”的东西,其中param和value在路由单POJO中设置 根据我对直接组件的理解,一个单一的“直接:测试”endpoint将接收所有路由交换,但是我需要一种从路由条中读取参数发送的方法 如何将此参数用于接收交换的endpoint
当用户同意接受推送通知时,需要向Amazon SNS注册endpoint。拥有我需要发送给SNS的注册id。当我手动输入时,我可以向我的设备发送推送通知。 只需在用户同意接受推送通知时使用发布或获取请求,使用 Amazon API 向 SNS 注册终端节点即可。现在,我收到签名不匹配,试图调用创建平台endpoint。 http://docs . AWS . Amazon . com/SNS/la
或者我应该为每个汽车品牌提供一个单独的endpoint,它有一个具有该汽车品牌所需的确切属性的主体。 因此,在第一种方法中,我有一个endpoint,它有一个string参数,我希望它是一个具有所有必要值的JSON 而在第二种方法中,在第二种场景中,每种汽车品牌都有一个endpoint,每个endpoint都有一个类型dto对象,表示它需要的所有值。
使用endpointDSL然后用ProducerTemplate引用endpoint的正确方法是什么?当创建路由并使用endpointDSL时,Camel似乎是在为endpoint创建不同的uri。我的EndpointRouteBuilder类: