问题标签 [jmstemplate]

我是使用队列的新手。我能够成功地发布消息并同步接收它们但是，我现在正在尝试异步。

sqs 提供的参考链接建议使用 jmsclient 包装器。如果您已经有一个集成到 jms 客户端的代码，该链接还提到使用它。

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html#samples

但是我重新开始，我参考了这个例子来同步发送和接收消息。

https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonSimpleQueueService/SimpleQueueServiceSample.java

我可以使用相同的代码但使用消息侦听器来实现它吗？任何代码示例将不胜感激。

i am using Spring JmsTemplate for sending/pushing message to ActiveMQ queue. i know after listener start processing that message and any exception occur,that message will be considered as a poison pill and moved to default DLQ of acive mq.

is that same possible (i.e. that message will move to default Dead Letter Queue ) while sending/pushing that message to Queue if there is any connection error or any other error occured while sending?

for example -

public void push(){

jmsTemplate.send(test.Queue, "This message is from client"); //if any exception occur here,i want this message to be placed in DLQ }

please suggest is it possible?

我正在使用带有以下弹簧配置的 jmsTemplate [使用“*****”隐藏结构]。

我想在此配置中配置 useAsyncSend=true 以便 jmsTemplate 不会等待来自代理的 ack。我不确定如何使用 JNDI 来做这件事 - 有人可以帮忙看看如何最好地做到这一点吗？

对于某些上下文，我正在使用符合 jsr 的实现在 Spring 批处理中执行 JMS 读取器和写入器。我正在使用 Spring 批处理提供的 JMSReader 和 JMS 编写器类，但我将它们包装在我自己的阅读器和编写器中。由于我使用的是 JSR 方法，因此我没有可用的典型应用程序上下文。这些类是通过作业规范或根据 jsr 规范通过 batch.xml 初始化的。

我遇到的问题是我有一个独立的批处理应用程序，当我定义一个 JMS 读取器和/或 jms 编写器时，它为活动 mq 创建一个连接工厂并将其设置为 spring 的 JMSTemplate 类的目标工厂，完成后的应用程序处理未正确关闭。为 IBM MQ 使用连接工厂的替代方法可以正常工作。

让我提供一些我已经完成的代码。

这是我创建连接工厂的地方。我做了几行注释的更改，试图让那些在应用程序运行时还活着的线程死掉。

这是我创建 JMSTemplate 对象的地方

最后是 JMSReader 的 open 方法，作者几乎相同

我看到的线程似乎与连接以及一些不活动的监视线程有关。由于它们保持活跃，它可以防止独立应用程序关闭。

有谁知道我如何配置连接工厂或 jms 模板以阻止这种情况发生，或者在阅读器完成后可能对其进行管理以使其正确关闭。

我已将 JmsTemplate 与 Jboss 6.2 和 HornetQ 集成，一切正常。

我已经添加了

之后，我每秒连续收到以下消息

我该如何阻止这个？

我正在使用 ActiveMQ 提供的用于浏览队列的 UNIX 命令，并且我正在尝试浏览特定的队列，并指定一个 JMS 选择器。这就是我想要做的：

通过 JMSMessageID 选择不起作用。

然后，我想通过 JMSText 进行一些过滤，匹配任何字符串。这里的问题是消息是 XML，也许我需要处理特殊字符。

有人做过这样的过滤吗？有匹配任何字符串的消息？

我们有一个 Java 类，它监听数据库 (Oracle) 队列表并在该队列中有记录时对其进行处理。它在 UAT 和开发环境中正常工作。在生产中部署时，有时它无法从队列中读取记录。当插入记录时，它无法检测到它并且记录保留在队列中。这种情况很少发生，但确实会发生。如果我要统计一下，在一天排队的 30 条记录中，大约有 8 条没有成功。我们需要重新启动整个应用程序才能读取记录。

这是我班级的代码片段..

奇怪的是，我们无法从日志中找到任何异常痕迹。

任何人都可以帮忙吗？顺便说一下，我们将 receiveTimeout 设置为 10 秒

我正在尝试在 rdd.foreach 方法中使用 Spring JMSTemplate 类，但我收到 Task Not Serializable 错误。当我尝试使用静态变量时，它在本地但在集群中工作，我得到空指针异常。

示例代码：

错误日志：

有没有人遇到过同样的问题？

我正在尝试与 Tibco EMS 建立 SSL 通信。TCP 通信成功，我能够发布消息。我用 JMS 模板配置它。以下是我与 Tibco 通信的属性。

这是在 Spring 中完成的 JMS 模板设置的代码。

我已阅读此链接并检查密钥是否存在于指定路径中具有 .pem 密钥和证书的服务器计算机中。ssl_server_identity = machineName.crt.pem ssl_server_key = machineName.key.pem

这是我在尝试发布 EM 消息时遇到的错误。

Weblogic 是服务器。我应该在 weblogic 中为 SSL 通信设置任何内容吗？

请建议我是否需要在 weblogic 服务器中添加其他参数以建立通信。另外，这里是我在 POM 中使用的 tibco 依赖项。

这是我在 Spring Boot 中的 Hornetq 配置。

这是我的制片人

这是我的消费者

这是我的配置文件

我想减慢@JMSlistener 的消费过程，我不想让JMS 监听器一直排队等待任何帮助，谢谢！