jms-topic

    1热度

    1回答

    我们使用Websphere MQ8并考虑使用持久主题来实现发布和订阅模式。 我们使用的队列已经和Hermes JMS-Browser纠正错误的队列消息。 我知道您可以使用爱马仕订阅主题,但我认为您无法访问和修改已针对特定客户端保留的消息。 所以我想知道 - 当客户端无法使用特定客户端应用程序的持久消息时,如何处理问题,例如,因为邮件格式错误? 您是否必须删除此客户的未传送邮件?还是有一些工具可以做

    2热度

    1回答

    我是新增的hibernate搜索功能,我为我的应用程序使用hibernate搜索5.3。我有一个应该维护lucene索引的服务器集群,如果实体有变化,我试图把它放在一个jms队列中,让所有其他服务器从这里提取更新并重新索引它们的lucene索引。 我已经写了一个searchInterceptor,它会在每次事务之后拿起实体并将它们发送给一个主题。我已经扩展了FullTextIndexEventLi

    0热度

    1回答

    我们使用WebLogic服务器,使用主题中的JMS消息。我们有几个节点,工作在主动/主动订户模式下,没有除dB(Oracle)以外的共享状态。问题是,我们要求只有一个订阅者(第一个接收消息)需要在接收到来自Topic的消息时执行实际的业务逻辑。 什么是用户之间同步的最佳方法?有没有一些方法可以在WebLogic本身上处理这个问题,例如收集主题中的消息,作为单个订阅者并将其放入队列中 - 以便Web

    0热度

    2回答

    任何人都可以清楚地解释什么是JMS主题中的持久性和非持久性? 我有服务器和客户端模型,直到现在服务器将发送请求到客户端完成从服务器发送的请求,并且客户端接受请求并将响应发送回服务器。 我有一个场景,而不是服务器发起请求发送到我的客户端,我的客户端必须查看服务器的特定请求,并发送回服务器的回应。 我可以使用JMS主题来解决这个问题吗?如果有人明确解释,将不胜感激。提前致谢。

    0热度

    1回答

    我有一个Java富客户端应用程序,它在启动时在远程HornetQ JMS主题上注册一个持久订阅。 但是,如果服务器重新启动,则连接丢失,只能通过重新启动客户端应用程序来恢复。 这会导致混淆情况,其中未收到JMS消息,并且在客户端重新启动后立即收到大量消息。 恢复连接的简单方法是运行定时器来定期检查连接是否仍然有效,并尝试重新连接。 或者,服务器可以向客户端发送心跳信号,并且如果在一段时间后没有收到

    0热度

    2回答

    我有一个Spring DMLC形式的主题和相应的订阅者。我的问题与以下情况有关: 在主题上发布消息并且订阅者开始处理消息。如果在处理上一条消息时另一条消息到达此主题,则假设订阅者处于忙碌状态,或者处理上一条消息之后将处理此消息,新消息是否会丢失。 如果答案是第二条消息将在第一条消息之后被处理,那么后续问题是该行为是由代理处理还是处理该消息的订户。

    2热度

    1回答

    目前我已开始使用JMS主题与ActiveMQ。我有创建发布者和持久订阅者通过JAVA代码(下面提到),我也收到订阅方的消息。 Publisher.Java public static void createConnectionAndSendMessage(String ipAddress) { try { ActiveMQConnectionFact

    0热度

    1回答

    我有一个特定主题的发件人和收件人。我将发送者和接收者作为WAS 7.0上的servlet运行。 正在WAS上设置Topic和Topic Connection Factory。但我无法收到发送的消息。当我尝试使用Queue而不是Topic时,它工作正常。 下面是我使用的代码。 public class CommonServlet extends HttpServlet{ private

    1热度

    2回答

    有人能帮助我。这里是我的问题: 我尝试发送的对象与JMS(这部分作品),并与JMS接受它。 我的对象很简单。 3个字符串,3个int和一个布尔值。 这是没有问题的connexion或类似的东西。我收到这个东西,但好像我一个接一个地收到了所有东西。 这里是我的消息监听: MessageListener listner = new MessageListener() { public v

    0热度

    2回答

    我有一种情况,需要从主题读取(正在进行的)消息并将它们放在另一个队列中。我怀疑我是否需要jms Queue,或者我可以满足于内存java Queue。我将通过同一个jvm中的其​​他线程从队列中读取队列,并在从(内存)队列中读取消息并根据需要处理消息之后,将客户端确认消息传递给主题(将消息发送给远程IBM MQ)。因此,如果我的客户端崩溃,内存队列中存在的消息将会丢失,但仍然存在于主题上,并将重新