问题标签 [producer]

我有 2 个使用 Hazelcast 的节点。

节点 A是生产者，它将项目放入队列

节点 B是一个消费者，它从队列中消费或汇集项目。我将 ItemListener 添加到节点 B 中，因此当一个项目添加到队列中时，消费者会注意到并开始消费。

如果一切正常，则没有什么问题，但是.. 有时消费者已关闭，而生产者仍在工作并将项目放入队列。当我再次启动消费者时，它只是在生产者添加项目时消费。所以.. 待处理的项目怎么样。

我正在使用 Hazelcast 3.3。

有没有解决这个问题的方法..？

谢谢。

我有一个生产者如下：

也是一个消费者：

}

我现在的问题是：

1. 我现在只有一个名为“queuName”的队列，还是有两个名为“color1”和“color2”的队列？
2. 我不想立即使用这些消息。所以我想要的是为每个队列“color1”和“color2”设置一个延迟。我怎样才能做到这一点？

使用rest easy，想管理我的entitymanager。在WEB-INF 中有persistence.xml 资源和beans.xml。想在以下位置使用实体管理器：

我的制片人是：

但我的实体经理为空。有人可以帮忙吗？

我的休息代码是：

和 UserDao 是：

我的 pom 是：

在 EntityDao 中，我的具有 @Inject 的 EntityManager 为空，并且生产者不工作。谢天谢地。

ActiveMQ 文档指出 Session 和 MessageProducer 对象不是线程安全的。如果我有一组可以产生持久消息的线程，那么如何在知道特定发送操作是否成功的情况下正确地将它们发送到 ActiveMQ？

1. 每个工作线程都有一个单独的 Session/MessageProducer。
2. 创建显式的生产者线程集并通过 BlockingQueue 将消息传递给它们（如何确定发送是否成功？）。
3. 对于前面的案例，使用 Future<> 来获得 ActiveMQ 中持久消息的成功状态。
4. 只需将每个 MessageProducer.sendMessage() 调用包装在同步块中。

或者，对于这种情况，也许有任何最佳实践。谢谢。

我正在编写一个程序，其中可变数量的代理对象同时运行多个串行方法并将它们的返回值存储在队列属性中。每个 Agent 都有一个 Worker（Process 的子类）作为属性，并为其提供作业以通过 cmd_queue 串行运行。Agent 从 res_queue 中的 Worker 获取结果。这些当前是 Manager().Queue() 实例和原因： TypeError: Pickling an AuthenticationString object is disallowed for security reasons 但是，如果我使用常规 Queue.Queue，Worker 会获得 Agent 的 cmd_queue 的副本，并且看不到 Agent 添加到其中的内容（它总是空的）。

我可以使用此问题中引用的解决方案来腌制实例方法：Can't pickle <type 'instancemethod'> when using python's multiprocessing Pool.map()

我的问题是，我怎样才能让这个代码使用多处理来工作，或者有没有更好、更被接受的方法来让这个模式工作？这是一个更大框架的一小部分，所以我希望它尽可能地对 OO 友好。

编辑：这是在 python 2.7 中。

您好，我有以下问题，当我加载没有@inject private Gson gson 的类时，它运行正常，但是当我把它放入它时会抛出异常。

调用 gson 的类。

创作者：

调用调用 Gson 的 bean 的类

例外

我已经实现了一个 JMS 生产者和消费者，它们部署在两个不同的主机中，都在一个 DMZ 中。 在这里，我阅读了如何为生产者定义自定义主机和端口。但我不明白我必须把那条线放在哪里。

这是我的代码：

谁能帮我？

我正在尝试通过 http 将我的 java 客户端应用程序连接到 ActiveMQ，但不断收到错误消息：（底部的完整错误）

还有就是连接到ActiveMQ，因为服务端也报错了：（底部完全报错）

是否存在库或 jar 问题？

这个连接有效我连接的原因：tcp://localhost:61616

活动MQ.xml

我的 Java 客户端程序中的 jndi.properties：

Java 客户端

这适用于 tcp://localhost:61616 但不适用于http://localhost:8080

任何人都可以帮助我启动并运行这件事吗？

客户端错误：

服务器活动 MQ：

我有一个带有订单的数据库，每个订单都有一个截止日期和一个创建日期。我想将最多 4 个订单拉入路由并同时处理它们。每个订单可能需要 10-20 分钟来处理。但我想尽可能多地保持所有线程运行，没有任何停机时间。

这是我现在拥有的：

DAO 函数按创建日期返回最旧的订单，该getNextOrder订单已超过到期日。立即尝试传入订单。

现在，问题是由于计时器的原因，传入的订单在 JMS 路由中堆积，当getNextOrder返回一个更旧的订单时，它在队列中远远落后。

有什么想法可以构建这些路线，以便为最旧的 4 个订单轮询数据库并同时执行这些订单吗？对 DAO 的更改是可以接受的。

有没有一种多线程生产者？

提前感谢您的建议！

想象一下有一个 SessionFactory 的生产者（例如）：

不，我有第二个生产者，它产生一些其他对象，比如说一个 DatabaseObject，并且需要一个对 SessionFactory 的引用：

不，我可以像这样使用我的数据库对象：

到目前为止，一切都很好。所以让我们假设这些东西是在一个框架中实现的，并且将被多个应用程序使用。

现在一个应用程序决定要使用另一个 SessionFactory，所以它实现了自己的生产者和限定符：

但是现在，据我所知，我不能将 DatabaseObject 与限定符一起使用，因为 - 当然 - 限定符只是在 SessionFactory 的生产者处使用。所以这行不通：

因此，应用程序将不得不重新实现 DatabaseObject 生产者，具有完全相同的代码，或者扩展基本生产者并仅添加限定符：

从我的角度来看，这会以某种方式产生样板代码，如果你有很多生产者，这会很有趣。

有没有办法在不需要重新实现生产者的情况下实现这一点？所以基本上生产者方法被注入了关于它产生的对象上的限定符的 SessionFactory？

谢谢！