我想阻止rabbitmq中的消费者在点击endpoint /prepare-for-shutdown时从spring云流绑定创建队列。>spring-cloud-starter-stream-rabbit</artifactId> cloud:SubscribableChann
浏览 86提问于2020-04-23得票数 0
我有一个启用了Spring cloud stream的Spring引导应用程序。此项目包含API端点和生产者/消费者流。在我们的例子中，RabbitMQ是绑定器。我们已经启用了Spring安全性，但它适用于API端点。
我需要知道如何对来自RabbitMQ的流请求实施安全性。因为与此相关的用户上下文和其他服务都不会将其请求发布到
浏览 2提问于2021-05-18得票数 0
我正在将遗留的spring应用程序切换到spring启动。mq-test.topic.aa.mq-test
我对春云流的特
浏览 0提问于2019-05-30得票数 1
回答已采纳
我有一个rabbitmq exchange test-exchange，它是使用路由关键字test- routing -key绑定到队列test-queue的直接交换。我正尝试使用spring云流将消息发布到此交换，但消息未到达队列<dependency>
浏览 13提问于2019-08-16得票数 1
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
rabbitmq:
addresses: amqp://guest:guest@localhost:5672 当我启动应用程序时，它会记录它已连接到rabbitmq，并在控制台中打印出用但是，我没有看到rabbitmq中<e
浏览 32提问于2020-11-24得票数 1
回答已采纳
我想使用我自己的RabbitMQ实例作为Spring Cloud数据流的中间件代理。 问题是，我们有一个关于交换和队列创建的前缀和后缀策略，它必须到位。可以强制Spring Cloud数据流添加这个前缀和后缀吗？示例： RABBITMQ_QUEUE_PREFIX="TEAM1"
RABBITMQ_QUEUE_SUFFIX="IN&qu
浏览 39提问于2021-06-22得票数 0
的后续问题。 我们能够在本地成功构建Spring Integration应用程序和SCDF流。我们可以向rabbitMQ请求队列发送一个http请求，该请求队列被绑定到SCDF stream rabbit源。我们还可以从绑定到stream兔接收器的rabbitMQ响应队列接收返回的响应。我们已经将SCDF流部署到绑定了内部rabbitMQ
浏览 6提问于2021-04-08得票数 0
回答已采纳
我的数据流如下所示: RabbitMQ源文件: CustomProcessor \ RabbitMQ Sink
spring.cloud</
浏览 4提问于2019-05-20得票数 0
回答已采纳
1回答
我试图使用StreamBridge SpringBoot和RabbitMQ作为代理来创建动态的n个队列--我以前用这种方法创建了队列spring.cloud.stream.bindings.sender-in-0.destination=sampleQueuespring.
浏览 5提问于2022-11-10得票数 0
我的问题是当使用者在rabbitmq服务器可用之前启动，我可以看到消费者重新启动直到连接可用为止。然而，DLX和DLQ之间创建的绑定并不相同。如果在使用者启动时可以使用rabbitmq : DLQ是用路由键'worker.request.queue.name‘绑定到DLX的，而当使用者在某些重试之后启动时，则'worker.request.dlq.name'Ifrabbitmq是不可用的: DLQ仅用ro
浏览 5提问于2022-01-10得票数 1
回答已采纳
1回答
使用Spring的现有队列
、、、、
我正在尝试使用AMQP编写一个Java应用程序来与RabbitMQ服务器对话。我必须使用现有的队列和交换，并且没有权利自己声明它们(我也不想)。问题是，我无法阻止Spring集成试图在RabbitMQ中声明队列，这将返回一个错误。下面是我的application.properties的相关部分：
spring.cloud.stream.bindings.input.group=********************.instana
浏览 0提问于2018-10-16得票数 1
回答已采纳
使用spring云流，您可以通过指定“默认”属性来避免每个单独通道的冗余属性。例如，如果有两个通道绑定到同一个目的地/交换，则可以：spring.cloud.stream.bindings.myCh
浏览 0提问于2018-04-12得票数 1
1回答
针对大数据的微服务之间的通信
、、、、
我正在构建一个spring的基于云的微服务ML管道。我有一个数据摄取服务，它(当前)从SQL获取数据，这些数据需要由预测服务使用。一般的共识是写入应该使用基于异步消息的通信，使用kafka/rabbitmq。我是否应该使用API网关来调用启动管道的摄取？
浏览 0提问于2017-06-07得票数 1
我很简单地需要将Stream应用程序部署到我们的内部云铸造实例中。该流有一个消息的，定义如下，用于在PC上本地运行它：
stream create myMessageStream --definition "rabbit --rabbit.queues=cloud-stream-source--rabbit.requeue=true --spring.rabbitmq.host=localhost --spring.rabbitmq.port
浏览 1提问于2016-11-07得票数 0
回答已采纳
1回答
春云流与RabbitMQ的连接
、、、、
有一个简单的Spring项目，我试图连接到RabbitMQ，它说它的，但它不起作用。我在密码里做错什么了吗？Application.propertiesspring.rabbitmq.port=5672spring.rabbitmq.password=gu
浏览 1提问于2020-04-18得票数 0
回答已采纳
我正在寻找一种通过Spring cloud stream将一个RabbitMQ交换绑定到另一个交换的方法。我知道可以通过设置producer.requiredGroups属性将队列绑定到交换： spring.cloud.stream.bindings.foo.producer.requiredGroups=queueA queueB 我可以使用哪个属性来创建交换到交换绑定？
浏览 32提问于2019-04-11得票数 1
回答已采纳
我有一个运行在服务器上的RabbitMQ消息代理，我正在尝试使用配置一个生产者和一个消费者。我的生产者每秒钟都在队列中创建消息，而我的使用者以相同的速度读取它们。但是，如果我停止了我的使用者，而生产者一直在推消息，当我再次重新启动我的使用者时，它将无法检索在它被关闭的那一段时间内创建的消息，只会收集从启动时产生的消息。当队列启动时，如何<
浏览 0提问于2020-10-16得票数 0
回答已采纳
是否可以通过从某个隐式绑定到默认RabbitMQ交换的特定队列消费？正如我在BindingService.bindConsumer(...)中的调试中所看到的，如果我将bindingTargets字符串数组指定为空字符串(yaml中的‘)，则destination字符串数组是空的，因此不会发生绑定使用者(binder.bindConsumer(...))。我可能的解决办法是指定一些随机目的地，并将标志queueNam
浏览 1提问于2018-05-15得票数 3
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
