问题标签 [eip]

似乎 ResequencingProcessor 类（以及相关文档，例如 sample_703）尚未在 WSO2 ESB 4.8M1 中实现；

根据https://issues.apache.org/jira/browse/SYNAPSE-893，它应该与 Synapse v3 一起交付；此外，在“EIP with WSO2 ESB”中已经提到了重排序模式。

是否有可能同时获得补丁以获得此功能？哪个版本的 WSO2 ESB 将实现 synapse 3.x ？

问候

多姆

对不起，如果这是一个愚蠢的问题，但我找不到任何明确的答案。我设置了一个带有私有子网和公共子网的 VPC。私有子网有一个 NAT'd 实例来路由互联网流量。公共子网配置为离开 IGW。

-我创建了一个堡垒主机来登录 SSH
-我在私有子网上创建了测试实例并从堡垒主机连接。由于到 NAT 实例的路由和端口 80/443 被允许和 ICMP，我可以 ping 和访问 Internet 上的文件。
-我在没有 EIP 的公共子网上创建实例。既然它有通往 IGW 的路线，我不应该有互联网访问吗？我创建了一个测试安全组以允许来自所有来源的所有流量，但我仍然无法 ping 或获取 http 链接。

我有一个用骆驼 2.10.6 编写的应用程序，它使用 EIP aggregator。它接收 2 个文件作为输入：一个以 . 结尾，-information另一个以-report. 我必须（分别）处理这两个文件，并且在处理后我必须将（即aggregate）两者结合在一起。

为了实现这一点，我正在使用 EIP aggregator。我已经使用 spring DSL 定义了路由。我没有相关表达式。也就是说，我的表达式是常量true。

我想关联属于一起的文件，即具有相同前缀的文件（前缀是(resp. )之前 的字符串。我相信这也可以通过在标题中设置一些 ID 来实现。-information.report

我的问题是我不知道该怎么做。到目前为止，我所有的尝试都产生了org.apache.camel.CamelExchangeException: Invalid correlation key.

有什么提示吗？

提前致谢。

我的路线（简化）如下所示：

我有一个重载（分配外部网络调用）集成流，它在进入主服务激活器之前使用 PriorityQueue。我想添加执行程序通道以改善系统负载，但我没有看到直接的方法来组合这些通道。

我需要创建 2 个额外的组件来完成这项工作，但是有没有办法将几个 Spring 集成通道组合在一起，而不添加新组件？

Apache Camel 的新手，只是想知道......如果我正在构建一个图像处理应用程序，该应用程序在非常大的图像文件上执行一些长时间运行的图像处理作业，那么 Apache Camel“处理器”是否是该代码的“最佳位置”？处理过程最多可能需要 15 分钟。

http://camel.apache.org/processor.html

干杯！

几天来我一直在研究 Camel 和 EIP，但有几件事我并不真正了解（还 :)）。例如，假设我有 5 个应用程序，它们使用多种技术（REST WS、JMS、数据库等）相互交换数据。- 我应该把我的骆驼路线放在哪里？- 我是否应该更改每个应用程序的代码并在其上声明特定的路由？- 我应该创建一个新的 Web 应用程序（或 OSGi 包）并使其作为中央提供程序来处理路由吗？我的意思是，将其他应用程序的代码更改为指向此应用程序中定义的 Camel 端点？- 使用 Camel 意味着更改集成集中每个现有应用程序的代码？我的意思是，骆驼在现实世界的场景中是如何工作的？它更像是一个拦截东西的中央网络应用程序，处理它然后发送到其他地方？它是我的应用程序内部的东西（与业务规则位于同一位置）然后池/拦截/侦听并处理它吗？我知道这些都是愚蠢的问题，但我昨天想着他们睡不着觉。任何帮助将非常感激 ：）

我目前有一些无法解释的寄存器问题，我无法猜测我正在将寄存器从一个寄存器不正确地移动到另一个寄存器。

我试图获得EDXinto a的值，test.myEDX它通常总是将错误的值EDXinto test.myEDX，但该EDX值的一部分似乎是正确的，这对于我假设的某种高/低位问题非常奇怪。

让我解释一下我想要做什么。
首先，我挂钩内存中包含一些任意汇编代码的位置。

我通过在该位置放置一个硬件断点来挂钩它，然后我可以及时看到该位置的所有寄存器值。
现在我做了一个简单的程序，每次 cpu 进入断点位置时，我都会将EDX值放入 C++ 中的结构中。
据我所知，EDX当我将寄存器放入结构中时，没有任何东西应该修改寄存器，除非将值放入结构中修改了EDX我测试的情况并非如此，我通过将第EDX一个移入EAX然后传递EAX到应该有的结构中进行测试相同的值EDX，但它仍然可能是错误的EAX将数据放入结构时也使用？那时我没有进一步测试所有寄存器以找出未使用的寄存器，怀疑这甚至是问题所在。

另一件要考虑的事情是实际执行任何操作，例如将EDX我必须在 C++ 中进行的当前EIP输入到我的裸函数中的结构中，我从以前做这些事情中知道裸函数根本不会修改任何寄存器，他们只是用作将 EIP 上的当前 asm 代码扩展为更大的 asm 代码的一种方式，而没有 C++ 在进入子例程时会添加的任何垃圾。

当我完成转储到 struct时，我还使用PUSHADandPUSHFD恢复以前设置的寄存器值EDXPUSH/POPPOPFDPOPAD

我几乎不知道任何 ASM，但通过查看许多示例，我从未见过寄存器像这样移动。（显然，复制一个寄存器没有任何意义，但即使是同一个寄存器也移动到两个不同的地址，一个接一个，我没有看到那个）。

但实际上我看到了这样的事情（我认为这是我的问题，为什么它不起作用），（不是，我仍然不知道我做错了什么）

除了现在丢失之外，我没有看到任何区别EAX，但我仍然认为我必须将同一寄存器的每次多次移动重新路由到多个位置，方法是在实际移动到原始位置之前一遍又一遍地移动它，愚蠢但就是这样我认为你必须这样做我仍然认为这是完成这项工作的正确方法。
无论哪种方式，这仍然没有帮助我，我仍然得到错误的价值观。

我认为这些选项的AL BL寄存器要么搞砸了，EDX要么搞砸了，我真的说不出来，我把这段代码粘贴到 OllyDBG 中，似乎没有任何修改TEST的谜团为什么是错误的，也许地址更新它的值太慢了？因为它基于与 CPU 速度不同步的 RAM 速度（当然都是愚蠢的理论）。JEEDXEDX

无论如何，我可以在这里解释的所有内容都是代码。

编辑：好的，我还没有解释我是如何测试这段代码的。

我不打算解释我是如何做硬件断点的，我不希望这种方法在互联网上公开，出于我自己未来的安全原因。
但它通过调用另一个与系统驱动程序通信的 DLL 来工作。

但这应该解释我如何测试它。

我在这个 DLL 注入的不同线程中运行。

我正在尝试在 2 个 ec2 节点上设置弹性搜索。我已经安装了插件，并且我的配置具有以下内容：

他们只会发现我是否同时指定了这个，并为每个人分配了一个 EIP。为什么需要分配 EIP？前段时间我有一个 NAT 实例，我不需要配置中的 EIP 和云：等。

我正在尝试实现一个 Camel 组件/处理器，它接受一个输入并产生多个输出消息，类似于拆分器。与 Splitter 一样，输出应该发送到路由中的下一个处理器/端点。

我查看了 Splitter 和 MulticastProcessor 类，希望可以重用它们或使用类似的逻辑。据我了解，这个想法是为每个输出创建一个新的 Exchange 并发出它们。为此，我需要提供要写入输出的端点。如果我在处理器类中动态创建端点，则此方法有效；我的要求是将输出发送到路由中配置的端点。也就是在下面的路径中，mycomponent 需要写入（多次）到 file:output。

在 Splitter 的情况下，它由可以访问输出处理器/端点的 SplitDefinition 类实例化。

a) 从处理器内部是否可以访问配置的输出处理器/端点？

b）如果不是，我应该为我的处理器编写一个 ProcessorDefinition 类吗？对此的任何指示都会有所帮助。

Petter 在下面建议的两个解决方案是，

a) 注入 Producer 模板 b) 将 Splitter 组件与方法调用一起使用，而不是编写新组件。

我正在研究 Camel 中的一种机制，该机制将从可以为真或假的标志中选择消息的端点。这是一种节流机制，在我的上游通道被淹没的情况下，它会将消息重新路由到批量摄取端点（发送到 HDFS）。

最终，我的路线如下所示：

我的 ThrottleHelper 类的 buildEndpoint 方法如下所示：

目前，我在类上有一个名为 checkStatus(); 的方法；设置 shouldThrottle （静态变量）。checkStatus() 每分钟在 Camel 石英计时器上运行一次。

我注意到一些奇怪的行为，我想我可能在滥用这种模式。通过对 Camel 模式实现的进一步搜索，看起来 buildEndpoint() 将在返回的每个端点被消息遍历后被调用。这是真的？或者我可以期望路径在进入“direct:throttle”或“direct:regular”后终止？

从我在网上收集的信息来看，我的方法真的应该像这样吗？

谢谢！