首页 文章
  • 1 votes
     answers
     views

    在Camel / Netty中发送UDP并在NIO中接收额外的字节

    我有两个应用程序,一个使用带有Netty组件的Camel发送UDP消息,另一个使用DatagramChannel在Java NIO中接收UDP消息 . 在接收数据时,我在消息前面添加了额外的29个字节 . Netty Camel打印出传出的字节,它看起来很好,但是当我在另一端消息进入时我会执行packet.getData(),它在前面有额外的东西(并且它总是相同的字节) . Camel或Nett...
  • 0 votes
     answers
     views

    Camel Netty没有从文件发送到UDP

    我可以成功读取文件并使用Camel Netty通过UDP发送内容,但前提是我在通过UDP发送之前修改处理器中的消息内容 . 我有一个简单的类来演示,它有两个驼峰路线: 从'inbox'目录(测试文件I 'm using is small - less than 50 bytes), write it to ' outbox'目录中读取文件,并通过UDP发送 从UDP读取并简单处理消息(在此...
  • 0 votes
     answers
     views

    Apache camel netty(udp服务器)无法跟上udp流量

    我使用apache netty模块接收udp数据包 . 在负载下,它似乎不接受所有发送的udp数据包 . 我通过运行虚拟udp服务器(非驼峰,只计算接收到的数据包的数量)测试它,并从localhost每秒发送1000个数据包,这个虚拟udp服务器接受并计算全部 . 但是从localhost每秒发送1000个数据包到我的camel udp端口,我可以看到一些(1-5%)从未出现过 . 我应该使用什么...
  • 2 votes
     answers
     views

    Camel xpath toLowerCase并包含

    我们正在申请骆驼 . 我需要处理一些xml消息(获取值\比较状态) . 为了解决这个问题,有一堆使用纯java编写的自定义处理器,但我被要求使用camel功能来改变它 . 代码示例: .choice() .when().xpath("/Response/Header/Status = 'OK' ")...... 这工作正常 . 现在我需要将提示与其他提示进行比较,为此...
  • 1 votes
     answers
     views

    骆驼中的正则表达式匹配器

    我试图想出一个骆驼路线,只有当匹配给定的正则表达式时,才会将消息发送到jms队列 . 我的路线是这样的: <route id="testRoute"> <from uri="jms:queue:Q.Order1" /> <choice> <when> ...
  • 1 votes
     answers
     views

    XPath / XQuery:如何在使用时检索所有数组而不是第一个元素

    我想从XML文档中提取一些信息,如下所示: <howto> <element>One</element> <element>Two</element> <element>Three</element> <howto> 我希望,使用xpah或xquery,一步提取三个元素,而不仅仅是我使用 ...
  • 1 votes
     answers
     views

    apache camel split()vs. split(body())

    我在使用拆分组件时遇到问题 . 我想将一个大的xml文件拆分为多个小文件 . 在小文件中,我想将25个元素组合在一起 . 我的第一个意图是使用以下内容: from(direct:start) .split().tokenizeXML("SomeElement", 25) ... 但后来我得到了这个错误: SaxParseException: Cannot find the d...
  • 2 votes
     answers
     views

    使用Apache Camel将请求的主机保留到 endpoints

    我在REST API之前使用Apache Camel就像一个智能HTTP代理 . 我有一个配置文件,其中包含要配置的路由,它运行良好 . 为避免复杂性,我将通过以下方式总结代码: camelContext.addRoutes(new RouteBuilder(){ @Override public void configure() throws Ex...
  • 2 votes
     answers
     views

    如何使用Camel RabbitMQ组件创建自动删除队列

    我想使用路由密钥为“”的自动删除匿名队列,使用Camel的RabbitMQ组件绑定到持久交换 . 当我像这样设置 endpoints 时(为了可读性而重新格式化): rabbitmq://localhost:6672/br.processor? autoAck=true& autoDelete=false& bridgeEndpoint=true& ...
  • 0 votes
     answers
     views

    当使用Apache Camel开发运行jar时,如何在路由标记中修复SAXParseException?

    Collegues,我有Camel上下文文件: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.or...
  • 0 votes
     answers
     views

    java.lang.NoClassDefFoundError:org / aspectj / lang / annotation /周围当karaf和spring aspectj

    我开发了驼峰osgi捆绑,它使用spring style camel配置和aspectj aop功能 . 当我将它部署到karaf 3.0.1中时,它会给出java.lang.NoClassDefFoundError:org / aspectj / lang / annotation / Around异常 . 我的pom.xml中有以下依赖项 <dependency> <gr...
  • 3 votes
     answers
     views

    Apache Camel Producer消费者术语dillemas

    以下是关于Camel in Action书中给出的 生产环境 者和消费者的定义 . The consumer could be receiving the message from an external service, polling for the message on some system, or even creating the message itself. This messag...
  • 1 votes
     answers
     views

    Camel Split和Aggregate失败,因为消息转发到多个并发消费者

    我有一个简单的camel路由,它接受一个项目列表,将它们分开,将每个元素发送到一个mq节点进行处理,然后通过聚合器将它们连接在一起 . 非常接近组合消息处理器:http://camel.apache.org/composed-message-processor.html 但我们注意到,拆分后,驼峰会创建多个并发消费者?还是交换?由于消息被发送给多个消费者,因此他们永远不会完成 . 清单:1,2,3...
  • 2 votes
     answers
     views

    无法将osgi服务bean暴露为类而不是接口

    我想将spring bean从一个bundle上下文导出到另一个 . 当这个bean没有像MongoClient这样的接口时,就会出现问题 . 第一个捆绑上下文注册Mongoclient,但当我想将它暴露给另一个时,我得到:“在注册表中找不到来自参考包的mongo类型:com.mongodb.Mongo”的bean . 有没有办法按类在OSGi注册表中定义bean,而不是接口? 异常来自参考包: ...
  • 7 votes
     answers
     views

    多个Activemq远程代理的Spring配置

    如何在spring上下文中配置多个远程activemq代理(不同的IP地址)?以下是1个远程代理的配置 . 我使用camel创建路由,从多个远程代理中的不同队列生成和使用消息 . 根据以下路由,系统如何知道每个队列属于哪个远程代理? 列出项目 从( “直接:启动”)来 . ( “ActiveMQ的:队列:outgoingRequests”) 列出项目 from(“activemq:queu...
  • 0 votes
     answers
     views

    访问akka-camel actor下的Camel / Jetty实例

    我有一个基本的Jetty实例使用带akka和scala的akka-camel库 . 例如: class RestActor extends Actor with Consumer { def endpointUri = "jetty:https://0.0.0.0:443/" def receive = { case msg: CamelMess...
  • 0 votes
     answers
     views

    spring-boot-starter-web和spring-boot-starter-data-elasticsearch白标错误页面

    我正在尝试使用spring-boot-starter-web和spring-boot-starter-data-elasticsearch,当我尝试呈现静态Swagger html页面时,我有以下内容: Whitelabel Error Page 此应用程序没有/ error的显式映射,因此您将此视为回退 . Sun Nov 02 17:44:17 GMT 2014 出现意外错误(type = ...
  • 1 votes
     answers
     views

    Apache 骆驼 Kafka 异常处理

    如何处理连接拒绝异常同时将 camel 交换中的消息推送到 Kafka 结束 point.Kafka 可能会关闭或者它将在此过程中关闭..请帮我如何处理这种类型的场景我试过 onException 块它不工作
  • 0 votes
     answers
     views

    与xslt聚合

    我试图从数据库中获取数据后聚合消息 . 似乎很难解释,我将首先绘制一个流程 . [ORIGINAL_DOCUMENT] --> SPLIT[GET SOME IDs from ORIGINAL_DOCUMENT] --> [GET DATA FROM DATABASE USING MYBATIS] --> [ENRICH ORIGINAL_DOCUMENT BY GOT DATA...
  • 0 votes
     answers
     views

    以编程方式获取Apache Camel组件的操作,参数,选项说明

    有没有办法使用Java代码获取任何Apache Camel组件“元数据”,例如选项列表和其他参数及其类型?我认为某个自动帮助构建器被提到可能在没有使用反射的情况下用于此任务 . 还寻求一种用Java代码获得所有类型(包括数据格式和语言)的注册组件的方法 . 谢谢
  • 1 votes
     answers
     views

    如何在spring application.properites中注入包含$ {...}的字符串

    如何在spring application.properites中注入包含$ 的字符串 我想在spring的applicaiton.properties文件中提供以下键值对,并希望spring在没有解析它的情况下忽略占位符 . output.folder=${date:now:yyyy-MM-dd}/success/${header.CamelFileName} 但是加载spring时试图提供占...
  • 2 votes
     answers
     views

    分裂,丰富和重新组合

    除了其他信息(思考地址,客户详细信息等)之外,我还有一条载有XML(订单)的消息,其中包含多个同质节点(想想产品列表) . 我必须使用其他外部服务提供的详细信息来丰富每个“产品”,并使用丰富的“产品”返回相同的完整XML“订单”消息 . 我想出了这一系列步骤: 使用xpath拆分原始XML以分隔消息(同时保留原始消息) 使用其他数据丰富拆分消息 通过替换旧元素将富集的部分放回原始消息中...
  • 6 votes
     answers
     views

    JMSExpiration与TimeToLive

    我正在尝试在Blueprint XML Camel路由中设置消息过期 . 我想要设置为到期的值保存在消息正文中(protobuf) . 这是我的代码: - <setHeader headerName="AMQ_SCHEDULED_DELAY"> <method bean="NotificationScheduler" method=...
  • 3 votes
     answers
     views

    Camel Aggregator EIP提高了速度

    我正在使用Apache Camel和aggretaor EIP开发一条路线 . 该路由通过jms从数据库中消耗数据,聚合它并将它们发送到Web服务 . 聚合器将数据保存在oracle数据库中 . 众所周知,聚合器的同步块是该路径中的boddle neck . 我已经尝试使用多个桶(correltionExpression = threadName),但它并没有像想要的那样提高速度...... 我每...
  • 0 votes
     answers
     views

    如何使用apache camel充实JDBC

    Apache Camel 2.12.1 我有这样的路线设置: public void configure() throws Exception { from("direct:start") .process(new AuthorizationHeaderProcessor(configureCred...
  • 2 votes
     answers
     views

    如何在拆分器AggregateStrategy上获取原始消息

    在我的路线中,我使用Splitter在单个消息中拆分位置 . 单个Message包含一些数据 . 分割后我想将所有消息合并为一个 . 但是当我这样做时,我只获得所有位置,而不是边界XML . 我的XML: <order> <firstname>Max</firstname> <lastname>Mustermann</lastn...
  • 0 votes
     answers
     views

    如何将多个修改过的消息发送到camel中的一个 endpoints ?

    在我的应用程序中,我根据给定的数据结构查询某些标识号的服务 . 对于每个返回的标识号,我想基于具有标识号的查询数据向同一收件人发送邮件消息: from("direct:querySource") .enrich("direct:executeQueryIds", new IdWithDataAggregator()) // here I stuck - wa...
  • 1 votes
     answers
     views

    如何拆分消息对其中一个进行额外处理并将其聚合回来

    我需要根据一些配置文件配置一些camel路由 . 所有已配置的路由都需要将消息拆分为一个或两个子消息,然后对第一个消息执行一些JMS集成工作,然后将JMS应答与可选的第二个消息聚合在一起 . 在简化的图片中,它将如下所示: message -- > split --> message 1 --> JMS request/reply --> aggregate -->...
  • 0 votes
     answers
     views

    如何让Camel内容加载程序从REST调用处理Exchange?

    我正在构建一个将订单路由到订单管理系统的示例实现 . 入站路由是具有两个标识符的交换,一个用于客户ID,一个用于目录项ID . 然后我将入站交换的主体转换为我的Order域对象 . 我的目标是调用内容丰富模式,一次聚合来自客户的数据,一次聚合来自目录项的数据 . 我的路线是: @Override public void configure() { // Start by buil...
  • 1 votes
     answers
     views

    在驼峰中设置REST响应体

    以下是我尝试在Camel中设置的流程: GET / product / foo - > MULTICAST [HTTP URI 1,HTTP URI 2,HTTP URI 3] - > AGGREGATE - >将聚合值返回给HTTP响应正文 我用这种方式设置了路由,但是在原始GET的响应中我没有得到任何数据 . 如何获取聚合器返回的值? @Override pub...

热门问题