- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有几个关于 splitter
的基本问题SI 中的元素。
我知道要形成自定义的拆分器逻辑,我们需要扩展AbstractMessageSplitter
并覆盖 splitMessage
方法。
然后在 output-channel
上显示此拆分消息集合。的 splitter
(假设没有在传入消息上配置回复 channel )。output-channel
的 splitter
然后可以变成input-channel
对于另一个 si 组件。让我们假设组件是一个简单的 service-activator
.
该手册说集合的“每个”消息将由呈现此集合的下游配置处理。所以在我们的例子中,service-activator
将处理“每个”消息。
1) 我的查询是“ who ”精确迭代集合并在 service-activator 的输入 channel 上呈现来自集合的“ each ”消息?
2) 让我们假设这里涉及所有直接 channel 。现在如果output-channel
的 service-activato
r 配置为 nullChannel
,一旦成功处理了第一条消息,它还会显示来自集合的“下一个”消息吗?
3) 假设我们没有 aggregator
涉及到这里。另外让我们假设所有涉及的方法都有非空返回。
将返回给将“ 集合 ”消息呈现给拆分器的 output-channel
的调用者线程的内容?它会取回服务激活器返回的返回类型集合吗?或者它会从集合中返回最后处理的消息?
我希望我的查询足够详细,以使它们得到澄清。
非常感谢回复。
此致
最佳答案
是的。你问得很好!
1) AbstractMessageProducingHandler
:
protected void sendOutputs(Object result, Message<?> requestMessage) {
if (result instanceof Iterable<?> && shouldSplitOutput((Iterable<?>) result)) {
for (Object o : (Iterable<?>) result) {
this.produceOutput(o, requestMessage);
}
}
else if (result != null) {
this.produceOutput(result, requestMessage);
}
}
output-channel
.
DirectChannel
上, 下一条消息直到上一条消息完成才会发送。实际上,它的工作方式与原始 Java 中的工作方式相同:
for (Object o : collection) {
}
sync
如果当前消息处理失败,则不会发送下一个。因为
Exception
.与原始 Java 完全一样:-)。
split(Collection<?>, Future<?>);
--->>
for (Object o : collection) {
process(Object, Future<?>)
}
splitter
中完成的。甚至在每个 EIP 组件中都更好。实际上所有这些都只在
中有效推模式。即使它对回复做了一些事情,它实际上也只是推送到
replyChannel
.
Future<?>
的回复。 - 在我们的例子中发送回复到
replyChannel
.是的,所有其他人都可以这样做,但回复将被忽略。见
TemporaryReplyChannel
源代码。
async
,例如
ExecutorChannel
作为
output-channel
在
<splitter>
没有预测回复中哪个消息是有罪的。因此,为了让您最满意地发送 Thread,您应该围绕这些拆分的消息找出一些足够的算法。甚至还有
<aggregator>
.
关于null - Spring 集成 - 究竟是谁 "iterates"来自拆分器的拆分消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33248979/
我正在尝试表达以下内容: 给定一个矩阵和两个索引增量,返回矩阵中所有数字的四倍体:沿行,列或对角线的四倍体。 use std::iter::Iterator; use std::iter::Peeka
假设我们有以下类组成角色 Iterable : class Word-Char does Iterable { has @.words; method !pairize($item)
我编写了一个 ADT 排序二叉树,其功能如下: public Iterator getInorderIterator(){ return new InorderIterator(); } 有效
在包装(内部)迭代器时,通常必须将 __iter__ 方法重新路由到底层可迭代对象。考虑以下示例: class FancyNewClass(collections.Iterable): def
尽管如此,我遍历了以下 NSSet , NSMutableArray , NSFastEnumeration文档,我找不到下面提到的场景的令人满意的来源: 此处,NSMutableArray、NSAr
我发现在 Python 中 collections.Iterable 和 typing.Iterable 都可以用于类型注释和检查对象是否可迭代,即 >isinstance(obj, collecti
我想拆分实现 Iterator 的对象的输出分为两个实现 Iterator 的对象和 Iterator .由于其中一个输出的迭代次数可能比另一个多,因此我需要缓冲 Iterator 的输出。 (因为我
我正在尝试用 Rust 编写一个简单的迭代器: #[derive(Debug)] pub struct StackVec { storage: &'a mut [T], len: us
什么意思: Separator.Iterator.Element == Self.Iterator.Element.Iterator.Element 在this (Swift 标准库)swift 实例
调用 anIterable.iterator() 会返回新的迭代器还是现有的迭代器?它依赖于 Iterable 的实现吗? 更具体地说,以下代码是否按预期工作(即内部循环将从头开始迭代)? for (
我正在尝试转换 &str 的矢量对成一个 HashMap使用以下代码片段: use std::collections::HashMap; fn main() { let pairs = vec!(
这将使安全地迭代同一元素两次成为可能,或者为在项目类型中迭代的全局事物保持某种状态。 类似于: trait IterShort where Self: Borrow, { type I
我在 String 的字符上使用迭代器: pub fn is_yelling(message: &str) -> bool { let letters = message.chars().fi
这将使安全地迭代同一元素两次成为可能,或者为在项目类型中迭代的全局事物保持某种状态。 类似于: trait IterShort where Self: Borrow, { type I
要在 Rust 中实现迭代器,我们只需要实现 next 方法,如 in the documentation 所解释的那样.但是,Iterator 特征 has many more methods .
我正在为多个结构实现 Iterator 特性并遇到了一些问题。为什么为 Rows 实现 Iterator 显示错误?这是一个链接:link to playground 基本上为什么这不起作用? str
我将集合转储到磁盘上。当请求时,应该检索这些集合(没问题)和 iterator应该为它构建返回对检索到的值的引用。 iterator之后被丢弃了,我不再需要收藏了。我也希望它被删除。 到目前为止我尝试
我正在尝试为实现特征的结构实现默认迭代器。我的特征称为 DataRow,代表一行表格单元格,如下所示: pub trait DataRow { // Gets a cell by index
Rust 中是否有提供 iter() 的 Trait方法?我只找到了特征 IntoIterator ,供应into_iter() . 这里要明确一点:我不想要 Iterator特性,提供 next()
我想在迭代器上定义一个 .unique() 方法,使我能够在没有重复的情况下进行迭代。 use std::collections::HashSet; struct UniqueState {
我是一名优秀的程序员,十分优秀!