-
1 votesanswersviews
WSO2 ESB Publisher的AMQAuthenticationException
我正在尝试将WSO2 ESB（4.7.0）与WSO2 Message Broker（2.1.0）集成 . 这是我的用例： 通用HTTP客户端向部署在WSO2 ESB上的PassThrough代理发送REST请求 ESB代理有一个后果：将请求转发给真正的REST服务，然后，在结果中，它将响应发送到中介类（部署在WSO2 ESB中） mediator类生成一些东西，并在其中包含此方法，通过... -
2 votesanswersviews
Mule Quartz调度程序：处理多个消息
这个问题是在4个月前提出来的 . https://stackoverflow.com/posts/16241300/edit 任何人？ “我已经在mule流中编写了一个石英代码，每隔5分钟就会消耗队列中的所有消息 . <quartz:inbound-endpoint jobName="abc" cronExpression="0 0/1 * * * ?"... -
7 votesanswersviews
使用JMS 2.0的Spring 4 CachingConnectionFactory无法正确缓存 生产环境 者
我们刚刚升级到Spring 4和JMS 2.0 . 我们使用 CachingConnectionFactory 和 JmsTemplate 来发布消息，并注意到在发布到目标时，第一次尝试有效，然后进一步尝试发布到同一目标会导致以下异常： 引起：javax.jms.IllegalStateException： 生产环境 者已关闭 Spring 3.2和JMS 1.1一切正常，所以我做了一些挖掘，... -
2 votesanswersviews
Spring DefaultMessageListenerContainer，ActiveMQ和消息重新传递
如果我使用Spring的Spring来接收JMS消息，即使我将 sessionAcknowledgeMode 设置为2，也不会重新传送JMS消息 . 如果我的JavaBean的 onMessage() 中有 RuntimeException ，则在JMS提供程序（ActiveMQ）中未确认该消息，它在队列中保持挂起状态 . 但它永远不会重新传递，我认为这是因为Spring永远不会调用 sessio... -
0 votesanswersviews
ActiveMQ：缓慢处理消费者
关于ActiveMQ：我有一个场景，我有一个 生产环境 者向消费者发送小（大约10KB）文件 . 尽管文件很小，但消费者需要大约10秒钟来分析它们并将结果返回给 生产环境 者 . 我研究了很多，但我仍然无法找到以下问题的答案： 如何让代理（完全）将文件存储在队列中？ 我应该使用ObjectMessage（因为文件很小）还是blob消息？ 由于消费者处理速度慢，我应该降低prefetch... -
0 votesanswersviews
从tomee传递到spring时，activeMq redeliveryPolicy被忽略
我有一个简单的 spring 应用程序部署在tomee 1.7.1 with activeMq 5.10 . 我的问题是，我设定的重新交付政策似乎主要被忽略，主要是延迟交还 . 我的jms监听器我立即抛出异常来测试自动重试 . 我的activemq.xml是这样的： <beans xmlns="http://www.springframework.org/schema/beans&... -
0 votesanswersviews
消费者连接时ActiveMQ不排队消息
我有一个Mirth Connect的设置，使用默认设置（持久，1000预取）向ActiveMQ队列发送消息 . 此队列有一个JMS使用者，并且必须按顺序同步处理消息 . 当消费者未连接时，消息从Mirth快速流入ActiveMQ的待处理消息 . 这很好并且需要......当消费者连接时，它会尽快开始处理消息 . 问题在于，如果消费者已连接，并且消息以比消费者处理它们更快的速度到达，则消息将在Mir... -
2 votesanswersviews
使用消息驱动的通道适配器和服务激活器时的事务处理
我正在开发一个POC，它执行以下操作 使用消息驱动的通道适配器来接收事务中的消息 调用Service Activator，它使用处理程序将从适配器收到的消息插入到DB，并将消息发送到出站通道 . 现在，如果消息的数据库插入失败，我希望将JMS消息返回到队列，以便以后可以重新尝试 . 使用我的以下配置它似乎无法工作 . （即，即使插入数据库时出现故障，消息也会从队列中删除 . 任何指针或... -
0 votesanswersviews
spring集成消息驱动通道适配器
我正在使用消息驱动通道适配器从weblogic JMS队列接收xml消息作为字符串，然后将此消息传递给spring集成通道以存储到数据库中，转换为不同的xml然后将转换后的xml发送到另一个远程weblogic JMS队列 . 我的疑问是，我设置了concurrent-consumers =“30”，max-concurrent-consumers =“100”，idle-consumer-lim... -
7 votesanswersviews
DefaultMessageListenerContainer没有缩放
我有一个DefaultMessageListenerContainer，（在我看来）没有扩展 . Container被定义为侦听队列，其中包含100条消息 . 我希望，Container可以达到任何长度，消息将尽可能快地消耗（通过观察maxConcurrentConsumers配置） . 所以我认为，有7个并发的消费者 . （在容器启动时由2个concurrentConsumers开始）一些日... -
1 votesanswersviews
JMS-MDB使用concurrentConsumers进行缩放
我们在我们的应用程序中使用JMS队列，随着负载增加，队列现在有点慢，我们希望使用DefaultMessageListenerContainer的concurrentConsumers选项来扩展MDB侦听器 . 我们设置的值是5，但是侦听器仍然没有创建任何新线程来执行此操作 . 它仍然是顺序的 . 我读到应该修改Prefetch选项，但我没有在Websphere中找到任何选项来设置此值 . 我们正在... -
1 votesanswersviews
DefaultJmsListenerContainerFactory和并行连接未关闭
我使用Spring 4.x的DefaultJmsListenerContainerFactory来连接到ActiveMQ队列，使用@JmsListener处理来自该队列的消息，然后将消息推送到同一ActiveMQ代理上的主题 . 我正在为使用者/监听器和 生产环境 者使用单个缓存连接工厂，并且我将缓存使用者设置为false，这样我就可以缓存 生产环境 者，而不是消费者 . 我还将并发性设置为1-3... -
1 votesanswersviews
Apache Camel同步多个消费者
由于持久性，我有两个运行相同Web应用程序的tomcat服务器实例 . 这些Web应用程序使用Apache-camel lib使用ActiveMQ的一些队列/主题 . 我的问题是如何同步这两个消费者，以便只有一个消费者可以获得特定的消息 . 我的意思是ActiveMQ在每个节点上发送不同的消息 . -
2 votesanswersviews
Camel JMS对象消息有效内容在使用Websphere MQ时从对象转换为字节消息
我正在使用apache camel（Fuse 2.10.x），用肥皂覆盖http和肥皂而不是jms . JMS消息从Object消息转换为Byte消息格式，这会导致读取消息时出现问题 .我在JBOSS 5.0 GA环境中为websphere MQ使用JNDI连接 . <tx-connection-factory> <jndi-name>MQConnFactory... -
0 votesanswersviews
ActiveMQ消费者消失了
我们正在使用ActiveMQ 5.10代理进行以下配置 JVM堆48G，其中70％分配给memoryUsage 70G存储和1G温度 我们使用Apache camel 2.10.2路由来消耗队列中的消息 . 收到消息后，我们使用spring的jmstemplate使用 asyncSend 创建~4k个较小的消息/接收消息并将它们发布到另一个队列 . 我们为使用pooledconnect... -
1 votesanswersviews
JBoss AS 7上的HttpTunnelingServlet
试图在当前的JBoss版本（AS 7.1.1 . ）上运行JMS Servlet Transport Example，我在Channel.connect（）上获得"java.net.ConnectException: connection refused" .如果在HttpTunnelingServlet中我用InetSocketAddress替换LocalAddress，连接... -
0 votesanswersviews
Spring ActiveMQ JMS - TopicSession不支持队列
我有以下代码配置为使用Spring框架和ActiveMQ作为代理发送JMS消息 . 但是当我尝试将消息发送到目标队列时，我得到了以下异常 . 事情是，如果我更改“jmsTemplate " connectionFactory to " amqConnectionFactory”ActiveMQ连接工厂，它可以工作（没有例外） . 但是，这不会破坏使用Spring缓存连接的目的吗... -
2 votesanswersviews
什么是基于EJB3的应用程序的最佳通信模式？
我正在启动一个需要高度可扩展的Java EE项目 . 到目前为止，这个概念是： 几个Message Driven Beans，负责架构的不同部分 每个MDB都注入了会话Bean，处理业务逻辑 几个实体Bean，提供对持久层的访问通过JMS消息通过请求/回复概念在架构的不同部分之间进行 通信： MDB接收包含活动请求的消息 使用其会话bean来执行必要的业务逻辑 将msg... -
1 votesanswersviews
JMS Message正在从Hibernate获取过时的数据
我有一个托管实体，它附加了一个EntityListener . PostUpdate和PostPersist上的EntityListener将实体添加到JMS队列以进行更多处理 . 所以这是场景，我有一个会话bean，它更新实体并合并更改，然后在监听器上触发PostUpdate . 但是当MDB开始使用JMS消息时，它将实体从EntityManager中获取，但它获得的实体是该对象的旧值 . 这... -
3 votesanswersviews
消费者选择的JMS单消息确认
考虑使用JMS队列的以下场景：我们有一个带有队列Q的JMS代理B和使用会话S1创建的MessageConsumer C1 . C1通过onMessage（）方法调用（异步）接收消息M1，M2，M3，并启动线程T1，T2，T3，以便并行处理M1，M2，M3（分别） . 我们不知道完成T1，T2，T3的任何时间需要多少时间 . 在某个时间点T2是完成执行的第一个线程：是否有可能以这样的方式向代理B确... -
1 votesanswersviews
JMS：在一个线程上通过MessageConsumer.receive（）读取是否可以，然后从另一个线程调用Session.commit（）？
JMS会话的规范警告说，当SessionListener实例注册到Session时，Session对象/实例只能用于创建它们的线程 . 但是，当使用MessageConsumer对象（仅限）时，它没有说明线程不安全，或者更准确地说是"thread-bound" . http://docs.oracle.com/javaee/1.3/api/javax/jms/Session.h... -
4 votesanswersviews
使用setRollbackOnly的JMS和MDB
我有一个java类，它消耗来自队列的消息，向一些URL发送HTTP调用 . 我已经在google上进行了一些搜索，也在stackoverflow上进行了搜索（如果我错过任何提及该问题的消息来源，我真的很抱歉）但是找不到有关setRollbackOnly调用的详细信息 . 我的问题是......如果我回滚，从队列中消耗的消息将阻塞队列的其余部分并将循环直到它成功处理或者它将在当前队列的末尾重新排队？... -
2 votesanswersviews
使用XA的JMS会话和JPA事务
我正在将WebSphere 8.5与EJB 3.1和JMS Generic提供程序一起使用 . 我需要使用无状态会话bean作为 生产环境 者在队列中编写消息 . EJB使用_708094注释，因为我需要在队列上发送消息之前执行一些"DB insert"并使用这些消息读取 生产环境 者写入的记录 . 问题是如果我定义了一个JDBC非XA数据源，那么 生产环境 者会将消息写入队... -
1 votesanswersviews
Spring tomee JTA交易
我一直在努力构建一个非常简单的应用程序，该应用程序使用spring，hibernate和JMS进行部署 . 我相信我的所有配置都是正确的（有mysql xa数据源和xa活动的mq连接工厂）但事情并没有像我期望的那样工作 . 目前我有一个简单的服务，使用注入的实体管理器写入，然后在一个注释为事务性（spring注释）的方法中推送到JMS，但我的消息监听器在 Spring 天提交事务之前传递这些消息 ... -
1 votesanswersviews
使用JBOSS在Spring中重新传递消息
我正在使用Spring SimpleMessageListenerConatiner，其中确认模式为2（客户端确认），而Queue是Solace . 当我从单元测试中抛出运行时异常时，意味着独立的spring配置，消息重新发送没有任何问题，但是当我在JBOSS中部署我的应用程序时，相同的代码不起作用 . 公共类MyListener实现MessageListener {public void onM... -
1 votesanswersviews
保护JMS消息驱动通道适配器
我正在使用消息驱动通道适配器来读取MQ队列中的消息，这在开发中一直运行良好 . 现在，为了准备第一个 生产环境 版本，我必须改为读取安全队列 . 我需要做什么？ 我想我需要确保将以下内容设置为系统属性，但具有什么值？ javax.net.ssl.trustStore javax.net.ssl.trustStorePassword javax.net.ssl.keyStore javax.net.... -
2 votesanswersviews
Weblogic EJB连接到外部Tibco EMS JMS队列
我正在尝试将Weblogic（10.3）MDB连接到Tibco EMS JMS队列 . 我使用简单的Java / Spring JNDI连接从队列中读取，因此我知道外部JNDI查找名称是有效的 . 我的WL外国服务器详情： JNDI Initial Context Factory: com.tibco.tibjms.naming.TibjmsInitialContextFactory JNDI C... -
1 votesanswersviews
创建JMSFactoryFactory实例时出现JMS异常
我正在尝试使用没有JNDI查找的MQ创建JMS连接，因此我实例化 JmsFactoryFactory 对象 . 下面是我的代码，我将所有jar文件添加到classpath但是我收到JMSException而没有任何明确的异常消息 . import javax.jms.JMSException; import com.ibm.msg.client.jms.JmsFactoryFactory;... -
2 votesanswersviews
JMS主题上下文查找问题
我试图在Websphere Application Server中使用JNDI查找JMS TopicConnectionFactory . 我已经在服务器中正确完成了jndi设置 . 我已在服务器中部署了我的应用程序 . 我为Sender / Reciever / Listener设计了3个java类 . 然后在服务器中部署WAR之后，我首先尝试将Receiver Code作为独立的Java应用程... -
0 votesanswersviews
如何在WebLogic 12c中使用远程JMS提供程序
我正在阅读关于与远程JMS提供程序集成的this FAQ by Oracle . 远程JMS提供程序是指由不同域中的另一个WebLogic群集托管的JMS服务器 . 常见问题是旧的，并没有详细说明如何实际配置远程JMS连接 . 以下是常见问题解答 问：与远程JMS提供商 Build 通信需要哪些信息？答：您将需要以下信息来设置与远程JMS提供程序的通信：目标类型 - 远程JMS目标是队列还是主题...