聚合后完成Exchange
是指将多个交易所的订单簿和交易数据汇聚在一起，形成一个统一的交易平台。这种方式可以提供更广泛的交易品种和更深入的市场流动性，为交易者提供更好的交易体验。
聚合后完成Exchange的优势包括：
- 多样化的交易品种：通过聚合多个交易所的订单簿，交易者可以同时访问不同交易所的各种交易品种，包括股票、期货、外汇、数字货币等，提供更多的投资机会。
- 增加市场流动性：聚合后的交易平台可以将多个交易所的订单簿合并，提供更深入的市场流动性，使交易更容易成交，减少滑点和成本。
- 提供更好的交易体验：通过聚合后完成Exchange，交易者可以在一个平台上进行多个交易所的交易，无需切换不同的交易界面，提高交易效率和便利性。
- 提供更好的价格发现：聚合后完成Exchange可以将多个交易所的价格进行比较和整合，为交易者提供更好的价格发现机会，获取更有竞争力的交易价格。
聚合后完成Exchange的应用场景包括：
- 个人投资者：个人投资者可以通过聚合后完成Exchange在一个平台上进行多个交易所的交易，方便快捷地进行多样化投资。
- 机构投资者：机构投资者可以通过聚合后完成Exchange提高交易效率和便利性，同时获取更好的价格发现机会，优化交易策略。
- 交易所：交易所可以通过聚合后完成Exchange吸引更多的交易者和交易量，提升市场竞争力。
腾讯云相关产品和产品介绍链接地址：
腾讯云提供了一系列云计算相关产品，包括云服务器、云数据库、云存储、人工智能等。以下是一些相关产品和介绍链接地址：
- 云服务器（ECS）：提供弹性计算能力，支持多种操作系统和应用场景。详情请参考：https://cloud.tencent.com/product/cvm
- 云数据库（CDB）：提供高性能、可扩展的数据库服务，支持多种数据库引擎。详情请参考：https://cloud.tencent.com/product/cdb
- 云存储（COS）：提供安全可靠的对象存储服务，适用于各种场景的数据存储和处理。详情请参考：https://cloud.tencent.com/product/cos
- 人工智能（AI）：提供丰富的人工智能服务，包括语音识别、图像识别、自然语言处理等。详情请参考：https://cloud.tencent.com/product/ai
相关·内容
Camel (3.11-3.12.0-快照) Java 16。
在这个例子中，有两条消息是由计时器发送的。第二条消息在第一条消息尚未完成时开始处理。我希望消息是一个接一个地直接处理的。
@Override
public void configure() throws Exception {
from("timer:cTimer?period=1&repeatCount=2")
.process(e -> {
final Integer oldBody = tim
浏览 0提问于2021-08-25得票数 0
回答已采纳
目的是在达到聚合最后一个索引后，从EDI850Processor中清除类级别属性。但是当我们到达拆分的最后一个索引时，没有可用的属性来准确地查找。
.split().jsonpath("$['ALL']").streaming().aggregate(AggregationStrategies.groupedExchange())
.constant("true")
.completionSize(20)
.completionTimeout(500)
.bean(EDI850Proc
浏览 8提问于2019-11-06得票数 0
1回答
问题:
首先，我有一个笼子的列表，在那里我分别检索这些笼子的位置。
下面的消费者已经一个接一个地得到了保持架，处理器提取了这个位置。
from("direct:cages-to-positions")
.process(new CageToPositionProcessor())
.aggregate(body(), new PositionsAggregation())
.completionTimeout(1000)
浏览 0提问于2018-04-18得票数 1
回答已采纳
1回答
本质上-如何用基于文件的输入来使用Camel的聚合器？
默认情况下，当使用文件组件的输入创建的Exchange完成其路由时，该文件将被移动到$inputLocation/.camel/。
但是，在使用聚合器时，Exchange通过聚合步骤之后，它将继续完成聚合步骤之外的路由的其余部分(可能有也可能没有)。这意味着Exchange完成了路由，如果使用了文件使用者，则会导致文件被移动到$inputLocation/.camel/。
稍后，聚合器将完成，当聚合文件引用完成时，聚合文件引用将无效，因为当常规Exchange完成路由时，文件被移动到磁盘上。
下面描述了一个简单的路线，显示了这个问题。引用
浏览 21提问于2022-08-05得票数 1
回答已采纳
1回答
我们在Camel中定义了一条路由，并必须找出是否在处理器中抛出异常。当我们只有一个处理器时，Camel会在sendBody()方法中重新抛出异常。如果存在前面的拆分/聚合，则不会引发异常。因此，下面示例的结果是
before throwing Exception
after sendBody
如果我省略了从.split到.completionSize(1)的所有内容，输出是
before throwing Exception
Exception thrown
有什么想法，如何找出，如果出现异常后，分裂？
private static final String DIRECT_START =
浏览 8提问于2016-02-11得票数 2
回答已采纳
1回答
我刚开始和阿帕奇骆驼合作。你能帮我搬一下文件吗？我有这样的路线：
from("file:data?noop=true?move={{package.success}}&moveFailed={{package.failed}}")
.split(ExpressionBuilder.beanExpression(new InvoiceIteratorFactory(), "createIterator"))
.streaming()
.process(new V
浏览 5提问于2014-05-14得票数 0
回答已采纳
首先，有一个类似的未回答的问题
我们有一些消费者路由(ftp，file，smb)从远程系统读取文件。简化为使用直接路由进行测试，但与批处理消费者的行为类似：
from("direct:"+routeId).id(routeId)
.setProperty(AGGREGATION_PROPERTY, constant(routeId))
.log(String.format("Sending (${body}) to %s", "direct:start1"))
.to("direct:aggregate");
在转换之后，一
浏览 2提问于2015-02-05得票数 4
回答已采纳
我在mongodb中有以下模型：
{
sport: 'Football',
site: 'Bet365',
data: [
{
_id: '1',
rating: 98.12,
bets: [
{
exchange: 'Smarkets',
odds1: 3.2,
odd
浏览 0提问于2021-10-02得票数 2
1回答
如何不受限制地聚合交易所
、、、
我们有目前的情况。我使用Apache，为小交换拆分大文件(使用拆分器，参见下面)并验证它们。然后，我需要聚合消息，但我使用聚合器，它需要设置复杂大小或其他。我可以在不设置限制的情况下从当前文档中增加所有的交换吗？
我的路线：
from("file:data?noop=true?move={{package.success}}&moveFailed={{package.failed}}")
.transacted()
.split(ExpressionBuilder.beanExpression(new I
浏览 3提问于2014-05-12得票数 0
回答已采纳
我试图通过使用apache将来自web服务的两个响应合并起来。在下面的代码中，我连接了两个响应。
public Exchange aggregate(Exchange exchange1, Exchange exchange2) {
if (exchange1 == null) {
return exchange2;
} else {
String body1 = exchange1.getIn().getBody(String.class);
String body2 = exchange
浏览 2提问于2017-05-10得票数 0
1回答
我已经配置了一种从交换中提取一些数据并对其进行聚合的路径；以下是简单的总结：
@Component
@RequiredArgsConstructor
public class FingerprintHistoryRouteBuilder extends RouteBuilder {
private final FingerprintHistoryService fingerprintHistoryService;
@Override
public void configure() throws Exception {
from("seda:h
浏览 4提问于2022-10-12得票数 0
回答已采纳
我正在使用设置了maxMessagesPerPoll=5的SQS FIFO队列中的消息。
目前我单独处理每条消息，这完全是对资源的浪费。在我的例子中，因为我们使用的是FIFO队列，并且这5个消息都与同一个对象相关，所以我可以将它们一起处理。
我认为这可以通过使用aggregate模式来完成，但我无法获得任何结果。
我的消费路线看起来像这样：
from("aws-sqs://my-queue?maxMessagesPerPoll=5&messageGroupIdStrategy=usePropertyValue")
.process(exchange ->
浏览 4提问于2018-05-02得票数 2
在聚合策略中，我们试图将多个响应体组合在一起，我们得到了“编码”吗？使用exchange.getIn().getBody()读取主体时返回的值。在这里，我设置了多个URL，这些URL将被击中，以便使用recipientList检索数据：
.recipientList(header("DynamicCommaSeparatedURLs"))
.aggregationStrategy(new EmployeeResponseAggregationStrategy()).parallelProcessing(true);
在聚合代码中，我需要将所有响应和返回合并的响应体组合起来：
p
浏览 11提问于2020-09-17得票数 2
我有两个param的camel rest端点，当我发送请求时它激活了第一个路由(“直接:amq”)，在这里我从activeMq获得消息。
这里的标头是可以的，但是这个路由激活了另一个路由(“直接:post”)，其中的标头丢失了。
我希望从第一个路由到第二个路由获取urlToPost头。
rest("/getFromActiveMq").produces("application/json")
.get()
.param()
.name("urlToPost")
.type(RestParamType.query)
浏览 1提问于2019-03-28得票数 2
回答已采纳
嗨，我有以下场景:我有一个客户端，它可以询问多个服务器的答案。根据输入的不同，只有一个服务器可以回答。只有服务器知道他们的答案。我尝试过在Apache中使用requestReply模式，但是我有一个小问题。
public void configure() // server1
{
from("activemq:topic:topicName").choice().when(header("cc").endsWith(5)).process(new Processor() {
@Override
public void pr
浏览 2提问于2013-08-05得票数 0
回答已采纳
1回答
我在输入文件夹中有一堆相关的PDF和XML文件：
1.PDF - 1.XML
2.PDF - 2.XML
3.PDF - 3.XML
etc.
PDF文件是扫描的文档，相关的XML文件包含与PDF文件相关的索引信息。
我使用Apache来轮询XML和PDF文件的文件夹，一旦有了发布对，我就会将它们发布到输出文件夹中。理想情况下，我希望最后发布XML文件。
下面的代码似乎正确地选择了这对代码，但是当我再次尝试拆分文件时，我会收到一条错误消息。
@Grab('org.apache.camel:camel-core:2.13.0')
@Grab('org.slf4j:slf4
浏览 6提问于2014-10-20得票数 1
如何在聚合策略中添加camel交换体。
public class MyAggregationStrategy implements AggregationStrategy {
public Exchange aggregate(Exchange newExchange, Exchange originalExchange) {
//I want to append body of newExchange to originalExchange.
// Currently I'm copying properties with following a
浏览 1提问于2017-04-25得票数 2
//扩展CamelTestSupport
@Produce
private ProducerTemplate template;
@EndpointInject(uri = "mock:out")
private MockEndpoint mock;
@Test
public void testSplitAggregateConvertOrder(){
List<InOrder> inOrderList = new ArrayList<InOrder>();
InOrder inOrder1 = new InOrder();
浏览 0提问于2016-06-02得票数 1
1回答
我有一个骆驼路由，它使用一个http服务，该服务返回一个json，其中包含我需要通过Id关联的几个元素。我不知道响应中有多少个Id相同的元素，所以，如何在聚合中设置完成，以便将所有这些元素关联起来？
这是我的路线：
from("direct:getInfo")
.id("getInfo")
.setHeader("accept", constant("application/json"))
.setHeader("authorization", constant("xy
浏览 0提问于2018-06-12得票数 0
回答已采纳
我们在Camel中定义了一个具有拆分和聚合功能的路由，但是不能在聚合器之后将异常传播回split。即使遇到异常，也会导致分割运行
下面是不起作用的代码
from("direct:MyRoute")
.routeId("MyRouteID")
.split().tokenize("\n", 1)
.streaming().stopOnException()
.choice()
.when(simple("${property.CamelSplitIndex} >
浏览 1提问于2017-01-20得票数 2
我使用Angular v1.2.14并使用验证来制作此表单。
<form role="form" name="exchangeForm" ng-submit="submitExchange(exchange)" novalidate>
<div class="form-group">
<input type="text" class="form-control input-lg" placeholder="Wat is j
浏览 1提问于2014-04-04得票数 2
从使用camel的春季引导中，我想知道是否有可能在骆驼路线完成后(在我的示例中的最后一条路径)获得来自骆驼路由的响应。它开始像这样使用ProducerTemplate：
@Component
public class CamelSender {
@Produce(uri = "direct:start")
private ProducerTemplate template;
public void callRoute(List<String> list) throws ExecutionException, InterruptedException {
浏览 2提问于2016-09-15得票数 0
回答已采纳
我实际上想要一个flush，或者一个completionSize，但是对于聚合器中的所有聚合器。就像一个全局completionSize。
基本上，我希望确保批处理中的每条消息都是聚合的，然后在读取最后一条消息时，立即完成该聚合器中的所有聚合。
e.g. 1000 messages arrive (the length is not known beforehand)
aggregate on correlation id into bins
A 300
B 400
C 300 (size of the bins is not k
浏览 0提问于2013-02-25得票数 2
回答已采纳
1回答
我们最近将单个服务器exchange 2007组织迁移到托管的exchange平台，每个人在新平台上都工作得很好。
我的问题真的很简单。
我应该完成从exchange组织所在的服务器上正确卸载exchange组织的过程，还是应该直接关闭服务器。目前，尽管所有的交换服务都已停止，但机器仍在运行。
我读到卸载exchange组织不会删除添加到AD中的对象/属性，因此删除组织是否有任何好处，而不是仅仅关闭服务器。如果我不卸载，AD会有什么问题吗?如果我卸载了，有什么需要注意的吗？
浏览 1提问于2013-06-03得票数 0
回答已采纳
1回答
我有一个类似的CSV：
County City Area Street
county1 city1 area1 street1
county1 city1 area2 street2
county1 city1 area3 street7
county1 city2 area2 street2
county1 city2 area6 street1
county2 city1 area3 street3
county2 city1 area3 street2
...
在CSV解析过程中，我需要聚合相同的县/城市来创建这样的最终结构：
county1/city1: [ [area1, st
浏览 1提问于2014-08-17得票数 0
回答已采纳
在我的骆驼路由中，我使用队列中的消息；每条消息都包含标题"pad“(路径)和一个文件前缀。例如：
message1: pad="/some/dir"，file="AAA“message2: message2/message2/dir，file="BRD”
在每条消息中，我希望创建一个文件: message1: /some/dir/AAA.tar (包含所有文件/message2/dir/AAA*) message2: /another/dir/BRD.tar (包含/some/dir/brd.tar中的所有文件)
目录和文件名是在另一个路由中收集的。
到
浏览 1提问于2018-02-01得票数 0
回答已采纳
1回答
我正在尝试接收来自rest调用的xml消息，然后调用db，将每一行映射到一个对象，然后返回完整的编组对象作为rest响应。
但是，我的db查询结果甚至在最后一个进程执行之前就作为rest响应返回了。您能告诉我，如果我做了什么错误，导致dB查询被返回吗？
还请告知我的解决方案是否正确，因为真正的数据库查询将有大约25000行，我担心我的web服务超时。
路由：
from("jetty://http://localhost:8888/...")
.log("Message Received")
浏览 4提问于2019-08-27得票数 0
我正在尝试使用Camel的带有自定义AggregationStrategy的丰富弹性公网I
from("direct:xyz")
.setHeader("...","")
.enrich("http://localhost:myservice", new AggregationStrategy() {
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
.....
}
});
HT
浏览 8提问于2016-09-13得票数 1
我有一个文件的路由和多个进程，我想要实现的是，如果我放置一个文件，在输出文件创建后，我想在onCompeltion()中重命名所创建的文件，onCompeltion()中的code.But onCompletion代码被触发，因为我想要在一个特定的routes.Please文件进程的末尾执行，帮助我实现这一点。我也尝试了这个链接，我想重命名这个文件在onCompletion中，每个文件进程都完成了
路由器：
@Component
public class MyRouter extends RouteBuilder {
@Override
pub
浏览 0提问于2018-03-05得票数 0
我使用Camel JMS组件进行请求-应答，以便与MQ进行通信。对于我的一些请求，我可以接收n消息作为回复。我如何聚合这些回复消息？
我想用聚合策略来使用聚合器模式，但是不能使用它，因为我不确定可以回复的消息数量。
社区能帮我理解什么是正确的方法吗？我做了一些谷歌搜索，但找不到有用的东西。下面是我的示例路线代码
from("direct:"+routeName).routeId(routeName)
.setHeader("JMSCorrelationID", constant(UUID.randomUUID().
浏览 8提问于2020-06-22得票数 2
2回答
我正在编写一个工具来解析一些非常大的文件，并且我正在使用Camel实现它。我以前用过骆驼做其他的东西，而且它对我很有好处。
我正在对在streaming模式下处理文件的概念做一个初步的证明，因为如果我试图运行一个没有它的文件太大，我就会得到一个java.lang.OutOfMemoryError。
以下是我的路由配置：
@Override
public void configure() throws Exception {
from("file:" + from)
.split(body().tokenize("\n")).str
浏览 7提问于2015-12-08得票数 0
回答已采纳
我已将Exchange 2010标准试用版安装到Exchange 2003环境中。现在，对于许可，我已经为Exchange2010Enterprise提供了一个完全独立的ISO下载，批量许可。我更愿意为已安装的Exchange 2010输入一个产品密钥，而不是整个卸载/重新安装过程。
卷许可的Exchange2010DVD --可能是某个特定的XML文件--可能有什么地方--我可能在哪里找到滑流的产品密钥？或者，setup.com是否有一些选项可以在现有安装中添加滑流产品密钥？
浏览 0提问于2013-02-18得票数 1
回答已采纳
据微软称，Exchange 2013 (最高CU)与2019年的域控制器级别不兼容。至少如果我正确地阅读了这个矩阵：
https://docs.microsoft.com/en-us/Exchange/plan-and-deploy/supportability-matrix?redirectedfrom=MSDN&view=exchserver-2019
如果我构建了一个2019服务器并将其提升到域控制器，那么目前使用的是一个2012R2域。这会立即引发问题，还是只在域/林功能级别提高时才会引发问题？
我不会立即提高域/林功能级别。如果这样做可行，我将在2012R2域/森林功能域和2
浏览 0提问于2022-07-18得票数 2
回答已采纳
1回答
带休息路线的骆驼聚集
、、、
我有一个Camel应用程序，我试图根据来自不同响应(REST服务)的一些输出进行一些聚合。
这就是我到目前为止(骆驼路线)的情况：
@Component
public final class AggregationRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
rest("/aggregation")
.get()
.to("direct:retrieve");
from("dire
浏览 2提问于2016-06-28得票数 1
1回答
我有以下路线：
<route id="my-aggregator">
<from uri="direct:aggregator" />
<aggregate strategyRef="myAggregationStrategy" completionSize="3">
<correlationExpression>
<simple>${header.id}</simple>
</c
浏览 1提问于2013-12-19得票数 0
回答已采纳
我需要一些关于邮箱迁移的帮助和建议。我有一个Active域，所有新的Exchange 2016都是在这里安装和配置的。域名是mydomain.com，这对于公共端也是一样的(我猜拆分-DNS，它被称为)。
现在，我在Windows2003上有一个非常老的邮件服务器，它使用的是MailEnable 7.5，它不是在任何Active Directory域中，在过去4年中一直使用它。旧服务器上的电子邮件域也是mydomain.com，对于这个旧的和新的Exchange 2016，邮件服务器都是mail.mydomain.com。
Exchange也配置了IMAP、POP、基于Web的邮件，可能还有M
浏览 0提问于2016-07-19得票数 0
回答已采纳
1回答
我在路线1中设置了骆驼交换的属性。我试图在分割器内更新第二条路线中的相同属性。但是在拆分器的第二次迭代中，我得到的是我在路由1中设置的原始值，而不是新更新的值。下面是我正在尝试的样本。
<route handleFault="true" streamCache="true" id="route1">
<from uri="cxfrs://bean://test?synchronous=true"/>
<bean ref="testBean" method="se
浏览 1提问于2016-11-18得票数 0
回答已采纳
我希望在apache中将多个xml对象转换为csv对象。但我只能转换单个对象。参考下面的代码和附加的代码，我尝试了一些sI有xml文件的方法，如
<company>
<employee>
<empId>1</empId>
<empName>peter</empName>
<sal>56000</sal>
</employee>
<employee>
<empId>2</empId>
<empName>
浏览 0提问于2018-08-16得票数 1
我们使用拆分器来迭代压缩文件中的文件，同时，我们还使用了一个自定义聚合器，它为我们提供了一个正文列表--主压缩文件中的两个文件的列表。现在，在拆分之后，我想提取在聚集器结果上发生的聚集块处理期间设置的头。但是，聚合器的输出似乎丢失了，并且在拆分块之后我没有得到任何东西。
我确信我没有得到这方面的基本知识。如果有人能帮上忙我会很感激的。
<route id="main-route">
<split streaming="true">
<ref>zipSplitter</ref>
浏览 3提问于2015-08-28得票数 2
1回答
服务器2003活动目录上的Exchange 2007。我的主域(MyMainDomain.com)控制器还托管dns和dhcp。
我有一个二级域名(MySecondDomain.net)，我的Exchange允许电子邮件。它不是物理域，只是被exchange和setup接受为Active Directory用户的主smtp和传出地址。它的MX记录指向MyMainDomain.com的公共交换地址。
我使用了MySecondDomain.net，并将邮箱移动到托管的exchange 2010环境中。MX记录现在指向这个新的交换系统，当我在MyMainDomain.com环境之外发送和发送电子邮件
浏览 0提问于2011-01-09得票数 0
回答已采纳
如何在Apache中使用pollEnrich和Bean？
我试着使用它，但得到额外的“您不能从bean端点消费”在本例中，我调用rest，但是客户端提供了jar文件，所以我需要调用bean并获得更多信息。
from("quartz2://tsTimer?cron=" + cron + "&trigger.timeZone=" + timezone)
.bean(tradingService)
.process(new Processor() {
@Override
publi
浏览 1提问于2019-02-11得票数 1
回答已采纳
我使用CAMEL聚合来自两个来源的响应，一个是xml，另一个是json。最初，我已经将这些响应存根，并从文件中获取它们。目标是聚合来自两个来源的响应。
我的聚合器路由如下所示
from("direct:fetchProfile")
.multicast(new ProfileAggregationStrategy()).stopOnException()
.enrich("direct:xmlProfile")
.enrich("direct:jsonProfile")
.end();
我的"dir
浏览 0提问于2014-09-21得票数 0
我正在编写一个组件(端点)，它将接收Camel Exchange，如下所示：
from("file|activemq|whatever").to(myEndpoint);
接收到后，我希望它将交换传递给一组子例程，这些子程序可能异步工作，并最终确定它们已经完成，可能在Exchange的Out消息中组成一个响应。所有这些都可能发生在Camel上下文之外，我只使用Exchange对象。
然后，我的子程序应该调用一些东西，告诉Camel它应该传回响应，按照源组件和中间组件的要求执行其他操作(例如，如果它是file:/，那么重命名一个文件)，并考虑这个Exchange完成的路由方式。
浏览 0提问于2018-02-18得票数 1
回答已采纳
2回答
我有一个多播到2个地方的路由。如果在调用1个place时发生异常，我将无法保留聚合结果。在onException的处理器内部，我在聚合期间创建的映射不在那里。我使用的是camel 2.25。
onException(RuntimeException.class)
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
Map<String, String> results = excha
浏览 13提问于2020-02-22得票数 0
1回答
我需要收集和处理由另一个组织生成的文件集。为了简单起见，假设集合由两个文件组成，一个摘要文件和一个名为: SUM20150701.dat和DTL20150701.dat的详细文件，这两个文件将构成日期20150701的集合。问题是，集合需要按顺序处理，来自外部组织的文件传输很容易出错，因此文件可能会丢失。如果发生这种情况，这组文件应该保持不变，以及找到的任何以下集合。例如，在mule进程开始时，源文件夹中可能包含以下内容: SUM20150701.dat、SUM20150703.dat、DTL20150703.dat。也就是说，20150701的数据集是不完整的，而20150703是完整的。我
浏览 3提问于2015-07-15得票数 1
回答已采纳
我有一个日志过滤器，用于记录调试和日志分析所需的基本请求信息。但正如您所看到的，文本有效负载真的很难阅读。
我不想每次都将这个文本有效负载复制粘贴到文本编辑器中。有没有办法让堆栈驱动程序在可折叠的json中打印出来呢？
更多信息：- GKE pod
@Component
class LogFilter : WebFilter {
private val logger = LoggerFactory.getLogger(LogFilter::class.java)
override fun filter(exchange: ServerWebExchange, ch
浏览 0提问于2019-04-26得票数 0
3回答
我试图为pollEnrich模拟端点，但没有成功。使用adviceWith进行嘲弄对于.to("")和.enrich("")很好，但是对于pollEnrich，我遇到了错误：
org.apache.http.conn.HttpHostConnectException:连接本地主机:8983
我不明白为什么adviceWith不适合pollEnrich --这是用于嘲弄的代码：
public class PollEnricherRefTest extends CamelTestSupport {
public class SampleMockRoute
浏览 5提问于2020-02-20得票数 0
在Spring Boot with MVC中，可以通过控制器方法中的注入Principal获取有关Keycloak用户领域和定义的属性的信息，该方法的类型为KeycloakAuthenticationToken，它提供了这些信息。
但在具有依赖关系的Spring Cloud Gateway中
implementation 'org.springframework.cloud:spring-cloud-security'
implementation 'org.springframework.boot:spring-boot-starter-oauth2-
浏览 75提问于2020-05-22得票数 0
回答已采纳
在使用GroupedExchangeAggregationStrategy聚合交换之后，我需要将它们分开(以发出单独的处理时间度量)到原始交换中。
我尝试使用以下方法进行拆分，但是得到的拆分交换封装了原始交换，并将其放在Message主体中。
在没有包装器交换的情况下，可以将GroupedExchangeAggregationStrategy聚合交换拆分为原始交换吗？我需要使用原始的exchange属性，并希望使用SpEL表达式。
.aggregate(constant(true), myGroupedExchangeAggregationStrategy)
.completionIn
浏览 0提问于2019-04-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
