问题标签 [spring-messaging]

如何向一个 Spring-messaging @MessageMapping 注释方法发送消息？我有下一个代码：

我正在尝试发送一条消息：

其中 org.springframework.messaging.simp.SimpMessagingTemplate 类型的消息传递模板默认创建 Spring。

但不要工作。消息的类型为 org.springframework.messaging.Message

我正在使用 Spring 4.x 的 DefaultJmsListenerContainerFactory 连接到 ActiveMQ 队列，使用 @JmsListener 处理来自该队列的消息，然后将消息推送到同一 ActiveMQ 代理上的主题。

我为消费者/侦听器和生产者使用单个缓存连接工厂，并将缓存消费者设置为 false，以便我可以缓存生产者，但不能缓存消费者。我还将并发设置为 1-3，我希望在应用程序启动时队列中至少有 1 个消费者，并且随着消息的增加，消费者的数量将达到 3。消息减少了，我预计消费者的数量也会下降到 1。但是，如果我查看线程（defaultmessagelistenercontainer-2/3），它们处于等待状态，并且不会关闭。当负载下降时，预期的消费者数量也将关闭，这不是预期的行为吗？请看下面我的配置，

ApplicationContext.java

应用程序属性

我试图让我的 Spring 4 JMS 应用程序在处理大量消息后动态缩减。我目前有 1-3 个并发消费者，并且我能够看到成功扩展到最大消费者，但是一旦消费者被创建，它们就不会消失。他们在那里处于等待状态。我想知道是否有设置或配置使消费者能够在负载消退后关闭。有人知道吗？

谢谢，

胡安

我正在计划一项“消费者感知”服务，该服务仅在该主题至少有一个消费者时才会处理某种类型的信息。使用 spring，我能够创建以下代码来监控消费者何时连接或断开主题：

如果事件发生在我注册到该主题之后，那将非常有效。但是在我注册这个监听器之前，我可能已经在一个主题中有一个消费者。

有没有办法强制activeMQ发送一个主题的所有咨询消息或类似的东西？

我有一个函数返回某种字符串字符串不是静态的而是动态的

我正在使用 spring 消息标签来更改语言

当我传递静态字符串时，它工作正常

但我想存储 var 的动态值，现在我正在使用 var 'error_msg'

它在jsp页面上给出了一个例外

我有一个接受订阅请求的 Spring Websocket Stomp 应用程序。

在应用程序中，我有一个 SUBSCRIBE 处理程序，即

我用来验证订阅。

我会检查onApplicationEvent中的某些内容并将 STOMP ERROR 消息从该函数发送回客户端。

我找到了这个食谱How to send ERROR message to STOMP clients with Spring WebSocket? 但我需要了解如何获取 outboundChannel。

我还尝试了以下代码：

我尝试将主题作为一些订阅主题和 /queue/error 主题。但是我没有看到消息传播到客户端。

在客户端，我使用：

我的目标是在我发送 STOMP ERROR 时调用函数（错误）。

请告诉我如何准确地发送正确的 STOMP ERROR，例如通过获取 Outboundchannel。

假设我在 Spring XD 中有一个自定义模块（我正在使用 Spring XD + Spring Integration + hibernate）。该模块基本上从数据库中获取一些东西（假设我使用休眠实体存储它，所以我使用一个名为“DataFromDB”的对象）。DataFromDB 是一个列表，然后我从列表中获取每个元素，我想使用以下方式发送它：

• 问题是每次我必须发送一条消息时，我都必须返回一条消息。
• 所以我想遍历 DataFromDB 列表并将每个元素作为消息发送。

有没有办法发送多条消息？

编辑：

我只是根据试图复制场景的评论创建了一个小例子。这就是我所拥有的：

我的变压器类：

我的xml配置：

我的测试课：

输出是：

结果：GenericMessage [payload=[GenericMessage [payload=foo, headers={timestamp=1475072951345, id=7b6c79a2-db85-563e-c238-262a31141456}], GenericMessage [payload=bar, headers={timestamp=1475072951345, id=31c8ef0e -3513-b95e-3a25-4fd3550f2fea}]]，标头={timestamp=1475072951347，id=f90d94c4-e323-70ed-62ee-4b8bce64814d，测试=测试}]

我正在使用 Spring Integration 4.2.2.RELEASE。

我正在使用 SQS spring-boot:spring-cloud，我想外部化参数，根据活动配置文件检索值

有没有办法解决这个问题？

就像是

在我的 Spring Boot 应用程序中，我试图实现基于 WebSockets 的通知功能。

我提供了以下配置：

并尝试使用SimpMessagingTemplate以便将消息从服​​务器端发送到特定的客户端（用户）。

现在我不明白一些事情：

1. %user%方法的参数 应该使用什么值simpMessagingTemplate.convertAndSendToUser？

2. 我在方法 中/notifications注册的端点和方法的参数 之间有什么关联以及如何正确使用它？WebSocketConfig.registerStompEndpointsdestinationsimpMessagingTemplate.convertAndSendToUser

3. 如何防止用户在客户端阅读其他人的消息？

我想扩展 DefaultSubscriptionRegistry 的默认行为。如何配置 SimpleBrokerMessageHandler 以在 XML 中设置自定义 SubscriptionRegistry？