message-queue

Does RabbitMq do round-robin from the exchange to the queues

Hi, I am currently evaluating message queue systems and RabbitMq seems like a good candidate, so I'm digging a little more into it. To give a little context I'm looking to have something like one exchange load balancing the message publishing to multiple queues. I don't want to replicate the messages, so a fanout exchange is not an opt...

Opinions on Client Server communication in a very restricted environment.

I have a server that needs to receive information from a client, web services was my first thought until a limitation was imposed. I am not allowed to setup a normal client/server interaction, because the server is not allowed to listen on any ports. The server is allowed to call out, so I'm left with : Having the server poll from the...

.NET Message Queuing using SQL Server as Message Storage

Hi, I'm looking for a MSMQ alternative which use SQL Server as messages persistance since MSMQ as some limitations : 4Mb Message Size, 1.6Go Queue Size ... Is there any open source or free project doing that ? Thanks. ...

How to build a Terabyte queue ?

How to build/design/program a Terabyte or Petabyte queue in memory? (Imagine a twitter like service with huge number of users.) ...

Thread loses Message after wait() and notify()

Hey Guys! I have a problem handling messages in a Thread. My run-method looks like this public void run() { Looper.prepareLooper(); parserHandler = new Handler { public void handleMessage(Message msg) { Log.i("","id from message: "+msg.getData.getString("id")); // handle message this....

Messaging strategies to connect different systems

I have a system to handle Applications online and a different system to send SMS/Email notifications to applicants on completion using web services. I can't guarantee the availability of the SMS/Email gateway. Option 1 After an application is complete, place a message on a JMS queue. A Message Driven bean receives the message and make ...

ZooKeeper and RabbitMQ/Qpid together - overkill or a good combination?

Greetings, I'm evaluating some components for a multi-data center distributed system. We're going to be using message queues (via either RabbitMQ or Qpid) so agents can make asynchronous requests to other agents without worrying about addressing, routing, load balancing or retransmission. In many cases, the agents will be interacting w...

IBM MQ Messages getting reposted

hi I am posting messages to an MQ and reading them into my application For some reason randomly some messages are getting reposted. The fist time they are corrupted but the second time they are fine. How can I handle this ? I want to ensure that a message gets posted only once. ...

Sending messages between two Python servers

I have two servers - one Django, the other likely to be written in Python - and one is putting 'tasks' into a database and another is processing these tasks. They share a database, but I want the processor to react quickly to new tasks rather than polling periodically. Are there any straightforward ways for two Python servers to talk t...

4.0/WCF: Best approach for bi-idirectional message bus?

Just a technology update, now that .NET 4.0 is out. I write an application that communicates to the server through what is basically a message bus (instead of method calls). This is based on the internal architecture of the application (which is multi threaded, passing the messages around). There are a limited number of messages to go ...

Problems creating JMS Queue on Glassfish

i'm get the following error when deploying my application with a JMS producer and consumer com.sun.enterprise.connectors.ConnectorRuntimeException: JMS resource not created : QueueName I used the annotations below: Producer @Resource(name = "jms/EmailNotificationQueue", mappedName = "EmailNotificationQueue") private Destination dest...

Storing data temporarily

All, I just need some pointers in a problem I have. Basically 100 C++ engine instances write to an SQL Server 2005 and it is creating some problems for us. As we don't really need to write the data in the database at that point we are thinking to stop doing it and use either messaging to send the data to a service for furher processin...

Using both a message queue and database.

I will be developing a system that will involve a data acquisition server where each acquisition will fill a row. I also need to have the ability to inform the user application of when new data has been acquired. From what I have read, it's not a good idea to use a database as a message queue and vice versa, but I was wondering if I co...

Message Queue or Scheduler

Hi all, I am currently using Quartz Scheduler for asynchronous tasks such as sending an email when an exception occurs, sending an email from the web interface, or periodically analyzing traffic. Should I use a message queue for sending an email? Is it any more efficient or correct to do it that way? The scheduler approach works just...

Django ORM and multiprocessing

Hi, I am using Django ORM in my python script in a decoupled fashion i.e. it's not running in context of a normal Django Project. I am also using the multi processing module. And different process in turn are making queries. The process ran successfully for an hr and exited with this message "IOError: [Errno 32] Broken pipe" Upon ...

Returning from dll (Asynchronous sockets)

I am trying to do a simple http-server in (c++) dll-file that I can use from managed (C#) application with P/Invoke. I was trying to do this with asynchronous functions (WSAAsyncSelect() and stuff), so that I could manage server by calling functions inside dll whenever needed and after that it would return to my main program. Now I'm not...

Calling finish() After Starting a New Activity

The first Activity that loads in my application is an initialization activity, and once complete it loads a new Activity. I want to ensure if the user presses 'Back' they go straight to the Launcher, and not the initialization screen. Side note, is this even the best approach, or would this be better done with some kind of Intent Flag? ...

Is there a better tool than postcat for viewing postfix mail queue files?

So I got a call early this morning about a client needing to see what email they have waiting to be delivered sitting in our secondary mail server. Their link for the main server had (still is) been down for two days and they needed to see their email. So I wrote up a quick Perl script to use mailq in combination with postcat to dump e...

MSMQ - Message Queue Abstraction and Pattern

Hi All, Let me define the problem first and why a messagequeue has been chosen. I have a datalayer that will be transactional and EXTREMELY insert heavy and rather then attempt to deal with these issues when they occur I am hoping to implement my application from the ground up with this in mind. I have decided to tackle this problem b...

How to process database writes asynchronously (maybe with a message queue) from Django?

After a user submitted data to my app, I'd like to write to the database asynchronously, possibly through a message queue. How do I set up such a system? Are there any pluggable Django apps that do such message queue-based database writes? Also how do i handle errors that happens during the async processing? Would really appreciate an...