consumer

2热度

1回答

检测到重复的基于HTTP的FlexSessions，一般是由于远程主机禁用会话cookie

场景描述： 我的程序是Flex + Java的+ BlazeDS的+ ActiveMQ的实现，它由Flex消费者订阅从ActiveMQ的JMS消息，目前我在 提供了两个tomcat服务器，它们都包含我的程序，而ActiveMQ是在另一个服务器上，现在我在同一种浏览器中打开两个应用程序，比如IE或Chrome等 ，无论如何，url就像http：// localhost： /HelloWord/ind

flex session jms blazeds consumer 2013-01-10

---

1热度

1回答

C＃.Net 2.0 .NET 4.5 TPL生产者消费者逻辑的线程池等效

在我的应用程序中，我有一组预定义的动作。我想指定特定数量的线程来执行这些操作。由于某些操作可能比其他操作花费更长时间，并且可能正在等待响应，所以当线程完成时，我希望它返回队列并开始下一个操作。所以，作为十个线程之一释放，它会得到一个新的动作，等等，直到队列为空，然后继续。在继续之前，我需要等待所有的动作完成。 所以我做了一些使用TPL的研究和测试，它在记忆之前工作得很好，“哦，废话，我仅限于.Ne

c# multithreading task-parallel-library threadpool consumer 2013-01-11

---

0热度

3回答

消息消费者实现

我猜消息的消费者应该始终倾听，或者应该设置批处理来经常检查和使用消息。 当我们做基本的例子时，我们使用独立的java程序继续运行。我们如何在任何应用服务器（如JBoss）的真实世界Web应用程序中实现它们？比方说，我们使用Spring MVC，Hibernate和JBoss。它通常如何实现/设置它，以便它继续运行并使用消息？ （生产者可以是任何网页时，按一下按钮或诸如此类的东西） 可能是非常基本的

spring jboss jms implementation consumer 2013-03-08

---

0热度

1回答

僵局生产者消费者

I have following classes : package com.akshu.multithreading; public class ThreadResource { static int a; static boolean Value =false; public synchronized int getA() {

java consumer producer 2013-03-17

---

1热度

1回答

akka骆驼消费者的autoAck是什么意思？

autoAck在akka骆驼消费者返回布尔值true或false。 如果autoAck = true，当消息进入消费者的邮箱但消费者处理消息之前，消费者该怎么做？

akka consumer 2013-02-04

---

0热度

1回答

在处理消息或处理完消息之前做了akka骆驼消费者出队消息吗？

class MyConsumer1 extends Consumer { def endpointUri = "some protocol string" def receive = { case msg: CamelMessage ⇒ // processing msg } } MyConsumer1是骆驼消费者的一般形式。 问题： msg in

message akka consumer 2013-02-04

---

0热度

1回答

定期阿卡演员和骆驼消费者演员之间有什么区别？

一个常规的Akka actor与一个邮箱和dispather（线程池）相关联，可以通过配置或编程设置。你可以通过路径查找普通演员。 正规演员先出队邮件形式邮箱先处理邮件等 我可以对骆驼消费者演员做同样的事吗？ 正规演员和骆驼消费者演员之间有什么区别？

akka actor consumer 2013-02-05

---

1热度

2回答

单文件阅读器/多用户模型：多线程程序的好主意？

我有一个简单的任务，很容易并行。基本上，必须在（大，几个Gb）输入文件的每一行上重复执行相同的操作。虽然我已经做了一个多线程版本，但我注意到我的I/O是瓶颈。我决定构建一个实用程序类，它涉及一个简单的“文件读取器”线程，它可以直接向前读取并尽可能快地读入循环缓冲区。然后，多个消费者可以打电话给这个班级并获得他们的“下一行”。给定n个线程，每个线程我的起始行是文件中的第i行，并且通过添加n找到该线程

multithreading io consumer producer 2013-02-05

---

0热度

1回答

生产者线程卡住但未阻塞

根据JConsole堆栈跟踪，我有一个生产者 - 消费者线程集，但生产者陷入不是.put()的一行代码中。 class Producer implements Runnable { private final BlockingQueue<CopyOnWriteArrayList<Creature>> queue; private World myWorld; Pro

java multithreading consumer producer 2013-02-17

---

0热度

1回答

控制HornetQ中消息的消费速度

我们想要控制消费者在HornetQ中消费消息的速度。 的问题是，当我们使用ServerLocator.setConsumerMaxRate（int）方法，我们得到总是每秒1个消息，而不管我们传递值的。 当我们不调用这个方法，是消费速度快（远远超过每秒1次）。 我们的代码： TransportConfiguration connectorConfig = new TransportConfigur

hornetq consumer 2013-04-09

---