message-queue

Android: Quitting the Looper?

I have a thread I use to periodically update the data in my Activity. I create the thread and start a looper for using a handler with postDelay(). In onDestroy() for my activity, I call removeCallbacks() on my handler. Should I then call handler.getLooper().quit()? Or not worry about it and let the OS deal with it? Or would it just run ...

MSG::time is later than timeGetTime

After noticing some timing descrepencies with events in my code, I boiled the problem all the way down to my Windows Message Loop. Basically, unless I'm doing something strange, I'm experiencing this behaviour:- MSG message; while (PeekMessage(&message, _applicationWindow.Handle, 0, 0, PM_REMOVE)) { int timestamp = timeGetTime(); ...

Where is all_queue_subscribers dictionary view on oracle 9i?

11g and 10g both have the all_queue_subscribers (and user_, dba_) dictionary tables for listing the subscribers to queues, but this doesn't exist on 9i. Does the same concept of queue subscribers exist on 9i databases, and where can I get this information from? ...

Message queue 'number of messages' is always 0.

I am trying to send messages to MSMQ on Windows 7 using C#. The code is as below: using(var q = new MessageQueue(".\Private$\hellomsmq")) { q.Send(new Message()); } But when I refresh in Computer Management the 'number of messages' (Message Queuing/Private Queues/hellomsmq) stays at 0. I did not get any exceptions/errors while per...

Should I move this task to a message queue?

I'm a big fan of using message queue systems(like Apache ActiveMQ) for the tasks which are rather slow and do not require instant feedback in User Interface. The question is: Should I use it for other tasks(which are pretty fast) and do not require instant feedback in User Interface? Or does it in involve another level of complexity wi...

How do I detect a connection break using MessageQueue

My application written in C# makes use of the MessageQueue class in .NET for communicating messages with another remote application and the MessageQueue should always be "connected" (heartbeat present) with the remote messageQueue under all circumstances. If it is not "connected", then it signals that something is wrong and my applicatio...

Android 2.1: Muliple Handlers in a Single Activity

Hi, I've more than one Handlers in an Activity. I create all the handlers in the onCreate() of the main activity. My understanding is the handleMessage() method of each handler will never be called at the same time because all messages are put in the same queue (the Activity thread MessageQueue). Therefore, they will be executed in the...

message queue : selection and sizing

Hi, I have 20 messages/s, each 1 - 1.5 Mbytes. I need High Availability (2 to 4 servers min). I need low latencey (high daily volume -> full RAM prefered). I need persistent poisoned messages queue. Only few clients (about 16), locally. I can have 12-16G bytes RAM per server (brooker). Which JMS message queue / messaging would you re...

unix message queue

Is there an ipc option to get the last message in message queue but not removing it? I want this to allow many clients reading same messages from the same server.. Edit: Server and clients are on the same machine! Thanks ...

Email queue service for .NET

We're building an app that sends email using our clients' servers. The servers have different settings in regards to how many emails can be sent per connection/per second/etc. Can someone recommend a component for this so we don't have to build our own? I came across MailBee Message Queue (http://www.afterlogic.com/products/message-...

Message Broker Queues and MessageType

What's the standard wisdom and considerations for dividing up a message queue? Assuming relatively small number of messages (< 1000/day), does it make sense to combine multiple message types into a single queue and have consumers use selectors to filter them? Or, should a single queue only handle a single message type? A couple of pos...

msgsnd: Invalid argument

I receive msgsnd: Invalid argument error while using my program. Another thing i noted is that error do not occur if the file size is medium while it occurs when file size is slightly more. Is is due to memory overflow? If yes then what is the solution. Regards, Bhavin. ...

How can we save Java Message Queues for reference?

How can we keep track of every message that gets into our Java Message Queue? We need to save the message for later reference. We already log it into an application log (log4j) but we need to query them later. ...

How to design a scalable twitter like service?

Does anyone have any information on the architecture of twitter? A few specific items I'm especially interested in: I know that they use message queues. But what exactly do they use queues for? Do they "duplicate" tweets? If so, how? For example, say a user has 10,000 followers and he makes a tweet "hello world". Does twitter store "...

NService bus message not coming in sequence (i.e as it is sent).

Hi , We are using NService bus for our messaging framework.Sometime the message is not coming as par the sequence of sending .Sometimes last message is coming first and than later first message. Please help me out Thanks ...

Best Work Queue service for distributed clusters

Hi there. I require a simple work queue type system for asynchronous task management. I have looked at both beanstalkd and gearman. However, both these seem to assume that the client and the queue server are on the same network, and therefore that there will always be a reliable network between them. I need one that can support the c...

C# COM Messaging system design

Hi all, I can use some help for a designing my COMport connection classes. I have a device with a microcontroller (which I programmed) connected to my comport. Whenever I send a message to it, it should send an acknowledge. So whenever I send something over the comport, it should wait for an acknowledge before continuing. Ofcourse, I ...

Triggering PHP from ActiveMQ

Background: Our current system involves two services (one written in Java, the other in PHP) that communicate with each other using HTTP callbacks. We would like to migrate from HTTP callbacks to a message-based architecture using ActiveMQ (or another, if necessary). We'll probably use STOMP to communicate between them. Eventually, the P...

Message queue proxy in Python + Twisted

Hi, I want to implement a lightweight Message Queue proxy. It's job is to receive messages from a web application (PHP) and send them to the Message Queue server asynchronously. The reason for this proxy is that the MQ isn't always avaliable and is sometimes lagging, or even down, but I want to make sure the messages are delivered, and ...

c# generic method

I have a method that receives messages from a queue of msmq. I have 6 different queues in msmq and i d like a single generic method that would receive the messages. THis work, but i need to write 6 methods for each queue. I d like to make it more generic. public List<QueMessage> getMessagesFromObj1Queue() { List<QueMessage> message...