草庐IT

java - 在 Eclipse Luna 中安装新软件总是出现错误 No repository found containing : osgi. bundle,org.eclipse.net4j.jms.api?

我将STS(Spring工具套件)与EclipseLuna4.4一起使用,我注意到每次我尝试通过帮助->“安装新软件”我收到以下错误:Anerroroccurredwhilecollectingitemstobeinstalledsessioncontextwas:(profile=DefaultProfile,phase=org.eclipse.equinox.internal.p2.engine.phases.Collect,operand=,action=).Norepositoryfoundcontaining:osgi.bundle,org.eclipse.net4j.jms

Java JMS 消息传递

我有一个通过qpid消息发送消息到服务器和服务器接收消息的工作示例。这是发送到服务器的简单helloworld:http://pastebin.com/M7mSECJn这是接收请求并发送响应的服务器(当前客户端没有收到响应):http://pastebin.com/2mEeuzrV这是我的属性文件:http://pastebin.com/TLEFdpXG它们都工作得很好,我可以通过QpidJMX管理控制台看到qpid队列中的消息。这些例子是从https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example下载的(可

java - 注释一个bean @DependsOn 是否意味着依赖bean 将被实例化或初始化?

我正在使用Spring3.0.2。我有两个相对简单的bean定义。一个有一个@PostConstruct(bean'A'),它会触发一系列事件,@DependsOnbean(bean'B')需要为此做好准备。然而,似乎即使我声明bean'A'依赖于bean'B',在bean'B'完全初始化之前bean'A'的事件(生命周期方法)正在运行。通过@DependsOn声明一个bean是“依赖的”(或者就此而言,在bean定义中依赖)是否意味着依赖bean的生命周期方法将在依赖于所述bean的bean之前完成?bean“B”的生命周期方法会在bean“A”之前完成吗?更新BeanA是一个自定义

java - JMS 和 Spring 批处理

我们的项目是集成两个应用程序,使用每个应用程序的restapi,使用JMS(提供异步特性)和springbatch从JMS队列中读取批量数据并处理它,然后将其发布到接收应用程序。我是JMS和SpringBatch的新手。我有几个基本问​​题要问:采用哪种JMS模型-(PTP或Pub/Sub)能否从JMS队列中批量读取消息(使用JMSItemReader)。如果是,任何人都可以提供代码。我们希望在消息成功发布(即读取-处理-写入)到接收应用程序后确认消息为“已读”,而不是在JMSItemReader读取消息时。我们怎样才能做到这一点?高级设计图如下 最佳答案

java - 使用 Spring 4.2 注释和 ActiveMQ 对 @JmsListener 进行身份验证

尝试使用Spring4和ActiveMQ实现非XMLJMS监听器。我的问题是我的客户不断收到以下错误:SetupofJMSmessagelistenerinvokerfailedfordestination'topic.FromJndiProperties'[...]Cause:TheJMSconnectionhasfailed:ForcecloseduetoSecurityExceptiononconnect.Cause:Username[null]orpasswordisinvalid.所以到目的地的连接是用用户名和密码null建立的。我想我可能没有正确设置destinationR

java - 无法使用 JMS 应用程序从 IBM MQ 获得响应

我们使用IBMMQ以请求/回复方式与第三方通信。我们向他们发送请求,他们给我们答复。目前我们都有一个简单的基于Java的nativeIBMMQ应用程序。我们计划使用springjms重写我们的代码。但是当使用springjms时,我们在给定时间内没有得到任何响应。我们正在使用JMSTemplate发送或接收消息。我正在分享我的代码片段。我在这里做错了什么吗?我应该在这里设置任何其他属性吗?//RequestPart(wearesendingrequest)Stringrequest//thisistherequeststringbyte[]reqData=request.getByte

java - ActiveMQ 不从队列中取出消息

我最近将服务器从ActiveMQ从5.8升级到最新版本(5.11.1)。从那时起,我偶尔会注意到消息会在特定队列上堆积而不会被删除。我们的架构有一个生产者,一个消费者。我可以看到消费者仍然处于连接状态,但消息正在从生产者那里堆积起来。我的解决方案是通过Web控制台删除队列。之后,我立即看到消费者重新连接并再次开始处理消息。如果相关,在这种情况下,生产者在.NET上运行NMS,消费者在Java1.7上运行JMS。 最佳答案 当消费者连接到队列时,请从Web控制台检查队列中未提交的消息数。如果它大于零并且长时间没有变化,则意味着您的消费

java - 使用 HornetQ 强制消息顺序

我已经用HornetQ设置了一个jms服务器作为JMS提供者(队列)。我有一个应用程序作为生产者,另一个(不同的计算机)作为消费者。我知道JMS规范不保证传递顺序,但我正在寻找一种方法来做到这一点:完全按照发送的顺序接收消息,即使它是特定于提供商的。有什么想法吗? 最佳答案 显然这可以通过禁用消费者缓存来实现。这是通过更改hornetq-jms.xml来完成的:0 关于java-使用HornetQ强制消息顺序,我们在StackOverflow上找到一个类似的问题:

java - QueueBrowser 不返回所有消息

我列出了队列和来自每个队列的消息。以下是我的代码。但是,QueueBrowser无法正确检索消息。比方说,我有一个名为TestQueue的队列,其中有1000条消息。我第一次运行我的程序时它只显示200条消息。第二-400第三-600前-800第五-1000你能告诉我如何解决这个问题吗?ConnectionFactoryout=newActiveMQConnectionFactory("tcp://localhost:61616?jms.prefetchPolicy.all=10000");ActiveMQConnectionconnection=(ActiveMQConnection

java - 使用 Spring 的 CachingConnectionFactory 时关闭 session

Java文档here与SpringCachingConnectionFactory相关的评论:NOTE:ThisConnectionFactoryrequiresexplicitclosingofallSessionsobtainedfromitssharedConnection.ThisistheusualrecommendationfornativeJMSaccesscodeanyway.However,withthisConnectionFactory,itsuseismandatoryinordertoactuallyallowforSessionreuse.我不清楚如何在我的