jms

1热度

1回答

JNDI：无法实例化类：org.jboss.naming.remote.client.InitialContextFactory

板上已经有类似的问题，但解决方案代码建议不适用于我。我想通过使用Java消息服务和Wildfly 10应用服务器来实现一个简单的聊天程序（jms pub/sub）。我在eclipse中配置并启动了服务器（status：Started，Synchronized）。当我编译我的PROGRAMM只由一类，出现此错误消息： javax.naming.NoInitialContextException: C

1热度

1回答

springxd流使用HDFS数据集来保存avro数据无法更新kerberos票据

我创建了一个springxd流====>源JMS队列 - >转换 - 自定义Java处理器（XML到AVRO） - >接收器 - HDFS -Dataset。流工作正常，但24小时后，因为它的连续连接，它无法更新kerberos身份验证票并停止写入HDFS。我们正在重新启动这个流部署的容器，但仍然面临问题并丢失消息，因为它们甚至不会发送到redis错误队列。我需要帮助 - 如果我们能够续约流K

0热度

1回答

不同的JMS提供

方法1：第三方消息提供者我使用WebSphere Application Server 8.5.5，我通过如link1和link2提到创建我JMS provider配置的队列（在classpath中：我使用了fscontext jar和require所需的ibm jms jars和）。 QueueConnectionFactory与我的jms提供商。在应用程序中，我使用jms将meesag

2热度

1回答

如何在Wildfly 10中配置JMS？在子系统下找不到JMS菜单

目前我正在编写一个运行在Wildfly 10上的JMS示例应用程序。但是我看不到我们可以在子系统中创建JMS队列的菜单Wildfly 10管理控制台中的管理控制台。请帮助我找到Wildfly 10管理控制台中的JMS菜单。我做上面的东西，但我有一些例外，同时启动wildfly 10 server.Below是例外： Failed to process phase INSTALL of subde

0热度

2回答

如何解决新的activemq-artemis安装阻止问题？

我一直负责评估JMS客户端的activemq-artemis。我有RabbmitMQ经验，但没有任何与activemq-artemis/JMS。我在我的本地机器上安装了artemis，按照说明创建了一个新代理，并将其设置为Windows服务。 Windows服务启动和停止就好了。我没有更改broker.xml文件。对于我的第一个测试，我试图从一个独立的java程序执行一个JMS队列产生/消耗。

0热度

1回答

如何确保如果消息未从JMS队列中消耗，它应该在一定时间后被删除？

我想要消息从JMS队列中删除，如果它们没有在一定的时间限制内被使用。在创建队列时应该配置什么属性或设置？我已经尝试过期，但即使在到期时间后，我也可以看到队列中的消息

0热度

1回答

JMS TopicBrowser导入

我正在尝试使用TopicBrowser（文档here和here）来查看持久订阅者的消息，但我找不到在我的代码中导入它的正确方法。我是Java的新手，所以我可能会在文档中丢失一些东西。

0热度

1回答

不同类型的MOM（面向消息的中间件）的

我是新来的妈妈的世界，开始学习不同类型的消息框架的，有人能请解释一下我下面？ JMS VS主动MQ VS兔MQ 春AMQP VS Spring集成春AMQP与兔MQ VS Spring集成与兔MQ 感谢，

0热度

1回答

MDB新主题呼吁的onMessage而前一个线程没有完成

在JBOSS EAP6我有一个长期运行的MDB线程监听JMS队列。它收到一个带有应该处理的工作数据库密钥的文本消息（循环）。在其执行过程我注意到，新线程产生新的MDB实例，从而导致不一致。我想阻止，在一个有计划的方式或在配置方式改变内部消除服务表现。因此，例如在onMessage中检查工作正在进行中。我无法更改数据库模型。由于我在一个单一的虚拟机我在使用存储在DB关键一组静态的边缘（最后）运行

0热度

1回答

以编程方式配置Apache ActiveMQ

我使用Apache ActiveMQ对大量消息进行排队，然后在一天结束时将它们出列。不过，我对ActiveMQ的运作方式感到困惑。在我的PC上，我没有安装ActiveMQ作为服务，也没有在某处安装服务器。我刚才包括“ActiveMQ的 - 全5.14.5.jar”作为我的项目Maven的依赖，我使用下面的代码至今： public static void main(String[] args) th