"Message queue" is a design pattern or software engineering component that defines discipline or API for communication between two or more interrelated processes or systems. The message queue enforces asynchronous processing and loose coupling. Depending on the implementation they may also provide ...
2
votes
0answers
12 views
Realtime synchronization of live data over network
How do you sync data between two processes (say client and server) in real time over network?
I have various documents/datasets constructed on the server, which are downloaded and displayed by ...
2
votes
0answers
66 views
ServiceStack: repalce web service with message queue
I'm working on a project that provides some API for getting information about our partners' products.
Every search request to our site has to make n other requests to partners sites, collect and ...
2
votes
0answers
70 views
How to ACK celery tasks with parallel code in reactor?
I have a celery task that, when called, simply ignites the execution of some parallel code inside a twisted reactor. Here's some sample (not runnable) code to illustrate:
def run_task_in_reactor():
...
2
votes
0answers
84 views
Where is Message queue content stored?
While using the POSIX Message queues I noticed there were some files being created on the File system with the name I was creating the queues. My questions :
Q1. Do message queues queue up the ...
2
votes
0answers
96 views
Pull all item from Message queue
There is an application which connect to multiple sockets. It has two threads, receiving thread and processing thread. So in between them, I create a message queue. Since it does not require to ...
2
votes
0answers
307 views
Rabbitmq mirrored queue performance
I am going to user rabbitmq cluster for my web app. As I am implementing auto scaling using AutoScaling service of AWS, I am planning to use mirrored queue. I have read this article of rabbitmq ...
2
votes
0answers
575 views
Boost message queue
I have the following boost::interprocess::message_queue related question.
As intended I plan to share a message queue between >= 2 processes. Obviously one of them may crash while inside the message ...
1
vote
0answers
23 views
Learning MPI Implementation
What is the best way to find out how MPI is implemented? What kind of support is there in hardware to speed up MPI? What exactly are the features provided by a NIC? How does the MPI implementation ...
1
vote
0answers
44 views
Are there any free or open-source persistent publish/subscribe (PPS) systems?
I've been working with QNX lately and found their Persistent Publish/Subscribe (PPS) to be very useful. Does anyone know if there are any systems that are similar to QNX PPS that might work with the ...
1
vote
0answers
50 views
rabbit mq message listener
Im using
@Autowired
RabbitTemplate temp;
temp.convertAndSend("aQueue", msg);
for sending and
@Autowired
RabbitTemplate temp;
return temp.receiveAndConvert("aQueue");
for receving ...
1
vote
0answers
67 views
Externalizing resource adapter configs from standalone.xml in Jboss-as 7.1.1
I'm using Jboss-as 7.1.1
I have configured the resource adapter as below in the standalone.xml file. This basically is the configuration for a outbound queue using Websphere MQ and it works fine.
...
1
vote
0answers
44 views
A short explanation of how MSMQ queue permissions are applied
I'm trying to understand how queue permissions are applied in different situations, for example:
Everyone has Send permission allowed, but "MachineName$" or user doesn't have Send permission allowed
...
1
vote
0answers
40 views
Whats the POCO Equivalent of ACE/ActivationQueue?
Is Poco::NotificationQueue the same as ACE/ActivationQueue?
1
vote
0answers
103 views
How to update values of a row in a table after polling for new incoming data in a loop
I had already implemented polling for this database in java and reads all incoming data which resides in the outgoingqueue. Now I have problems in updating the polled rows, which is like I just change ...
1
vote
0answers
151 views
Message queue for IPC with fork and want to know whether the processes 'share' the message buffer or just copy and 'show' to the other process
I am student and was programming with fork() in C for multi-process matrix multiplication.
but while I was doing this, I had question about
when we use IPC with MESSAGE QUEUE, then,
If I put
struct ...
android