草庐IT

ActiveMQ

全部标签

java - 如何将 Spring Boot JMS 从 ActiveMQ 迁移到 Oracle Advanced Queuing

我正在研究SpringBoot和JMS示例,是的,我对此很陌生由于我们使用Oracle,我想将SpringBoot和JMS示例从ActiveMQ迁移到OracleAdvancedQueueing。但是,我真的找不到这方面的信息。据我所知,我需要为Oracle版本替换下面的代码,但我没有找到如何替换的方法。@BeanpublicJmsListenerContainerFactorymyFactory(ConnectionFactoryconnectionFactory,DefaultJmsListenerContainerFactoryConfigurerconfigurer){Defa

java - 在 ActiveMQ 中查看消息时,可序列化类不可用于代理 : java. lang.ClassNotFoundException

我想查看已在ActiveMQ队列中排队的消息内容。我打开了web-console.(http://localhost:8161/admin/queues.jsp)并点击了队列消息的message-id。它在“消息详细信息”窗口中给我以下错误,而不是提供消息内容。"javax.jms.JMSException:Failedtobuildbodyfromcontent.Serializableclassnotavailabletobroker.Reason:java.lang.ClassNotFoundException:"此异常的原因是什么?我需要做什么来摆脱它?

java - 我需要一个使用 ssl 的 java stomp 客户端库

我正在尝试几个用于java的stomp库(gozirra、stompj、activemq)。所有这些库的文档都很差,比如只有一个例子,我有一个严重的问题:我需要SSL支持。存在stomp+ssl协议(protocol)并受activemq支持,但我找不到支持它的Java客户端。 最佳答案 我找到了thisforumdiscussion关于Android上的JMS,它引用了theexperimentalStompAPI包含在ActiveMQ5.2及更高版本中(下面复制的示例)还提到了RESTAPI可能更适合移动设备,允许纯粹在代理处维

java - 为什么消息又来到了 onMessage() 函数?

我正在使用ActiveMQ发送消息。所以当我发送消息时,消息来接收消息。成功插入后,它会被确认。但是我在确认后有代码,它可以抛出NullPointerException。因此,为了有意产生该异常,我抛出了NullPointerException。所以当它这样做时:消息没有dequeued,同样的消息再次到达onMessage函数。我的代码是:publicvoidonMessage(Messagemessage){Stringmsg=null;try{msg=receiveMessage(message);//Othercodetoinsertmessageindbmessage.ack

java - 我在哪里可以手动配置 ActiveMQ 主机名?

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。这个问题似乎不是关于aspecificprogrammingproblem,asoftwarealgorithm,orsoftwaretoolsprimarilyusedbyprogrammers的.如果您认为这个问题是关于anotherStackExchangesite的主题,您可以发表评论,说明问题可能在哪里得到解答。关闭去年。社区在去年审查了是否重新打开这个问题并让它关闭:原始关闭原因未解决Improvethisquestion我是第一次尝试设置ApacheActiveMQ我发现我的服务器名称中

java - ActiveMQ 和嵌入式代理

编辑:改写问题:我想使用ActiveMQ作为我的服务器和客户端应用程序之间的信使服务。我正在尝试在服务器中设置一个嵌入式代理(即不是一个单独的进程)来处理生成的消息供我的客户使用。这个队列是持久化的。代理初始化如下:BrokerServicebroker=newBrokerService();KahaPersistenceAdapteradaptor=newKahaPersistenceAdapter();adaptor.setDirectory(newFile("activemq"));broker.setPersistenceAdapter(adaptor);broker.setU

java - ActiveMQ KahaDB 总是锁定和等待

我正在尝试在一个相对简单的工作队列用例中使用ActiveMQ。我有一个队列,有一个简单的生产者和消费者。我的问题是我做错了什么不断使数据库锁定?这是我不断收到的消息:14/04/0518:14:13INFOstore.SharedFileLocker:Databaseactivemq-data\localhost\KahaDB\lockislocked...waiting10secondsforthedatabasetobeunlocked.Reason:java.io.IOException:File'activemq-data\localhost\KahaDB\lock'could

java - ActiveMQ Broker Factory 找不到用于故障转移的工厂类

尝试使用BrokerFactory创建ActiveMQ代理时出现此错误:java.io.IOException:Couldnotloadfailoverfactory:java.io.IOException:Couldnotfindfactoryclassforresource:META-INF/services/org/apache/activemq/broker/failoveratorg.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)atorg.apache.activemq.b

java - Camel ActiveMQ 性能调优

情况目前,我们在ActiveMQ库之上使用一些自定义代码来进行JMS消息传递。我一直在考虑切换到Camel,以便于使用、维护和可靠性。问题使用我目前的配置,Camel的ActiveMQ实现比我们的旧实现要慢得多,无论是在发送和接收每条消息的延迟方面,还是在发送和接收大量消息所花费的时间方面。我试过调整一些配置(例如最大连接数),但无济于事。测试方法我有两个应用程序,一个使用我们的旧实现,一个使用Camel实现。每个应用程序将JMS消息发送到本地ActiveMQ服务器上的一个主题,并且还监听关于该主题的消息。这用于测试两个场景:-在循环中向主题发送100,000条消息,并查看从开始发送到

java - 使用 Spring Boot 配置 ActiveMQ

我使用ActiveMQ作为SpringBoot的嵌入式。Broker似乎是通过ActiveMQConnectionFactory创建的。我了解配置代理的方法是在使用代理的查询中设置参数。如此处所述:http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html我想设置一些关于DLQ的功能,所以在destinationPolicy属性中,但是属性类型不是简单类型而是复杂类型,请问如何写查询参数来禁用DLQ? 最佳答案 补充@Petter和@Apri