1
голосов
1ответов
923 просмотров

Очередь сообщений System-V PHP C ++

Мне интересно, каковы ограничения очереди сообщений System-V, т.е. максимальный размер очереди, максимальный размер на элемент и т. д. Поскольку я работаю над интеграцией C ++ с моими сценариями PHP и имею очень большой объем данных, которые будут помещены в очередь из php, и процесс C ++ буд...

1
голосов
1ответов
1072 просмотров

Правильная обработка пользовательских сообщений с помощью WTL

Я написал многопоточную утилиту WTL для стресс-тестирования внутренней службы. Коммуникационные потоки сигнализируют основному потоку, что они вышли, поэтому основной поток может удалить соответствующий объект. Они подают сигнал так: PostThreadMessage(m_dwParentThreadId, WM_THREADQUIT, ...

5
голосов
3ответов
6129 просмотров

PHP + очередь MySQL

Мне нужна простая таблица, которая действует как очередь. Ограничение моего сервера MySQL - я не могу использовать таблицы InnoDB, только MyISAM. Клиенты / сотрудники будут работать одновременно, и им нужно будет каждый раз получать разные задания. Моя идея - сделать следующее (псевдокод):...

0
голосов
1ответов
1825 просмотров

Очередь сообщений IPC.Системный вызов msgrcv.Система V. как выйти из цикла

У меня есть очередь сообщений, из которой я получаю сообщения в цикле.Проблема в том, что я не знаю, как выйти из цикла.msgrcv возвращает тип size_t и продолжает работу.С каким значением я должен сравнить возвращаемое значение, чтобы выйти из цикла? while(msgrcv(msqid, &msgreceived, sizeo...

5
голосов
1ответов
2417 просмотров

Какая самая быстрая очередь IPC / сообщений Perl для отдельной машины?

Я работаю (в основном) над проектом Perl и хочу использовать очередь сообщений, чтобы изолировать процессы друг от друга.У меня такой рабочий процесс: Вход -> Приемник -> Процессор (ы) -> Выход (ы) Мне нужно обрабатывать несколько сотен транзакций в секунду, так что ускорите мой г...

0
голосов
4ответов
4688 просмотров

Какой хороший брокер сообщений работает с PHP?

Я ищу брокера сообщений (например, Apache ActiveMQ для Java), который работает с PHP, предпочтительно с открытым исходным кодом.Есть идеи?

1
голосов
2ответов
453 просмотров

Какие системы очереди сообщений подходят для использования на общем веб-хостинге?

В настоящее время я использую веб-сервер общего хостинга и пытаюсь настроить систему очередей, в которую мой основной веб-сайт будет отправлять сообщения.Затем я воспользуюсь чем-нибудь другим (возможно, cronjob) для обработки элементов в очереди. Мне нужно что-то безопасное, чтобы другие пол...

7
голосов
5ответов
8197 просмотров

Динамическое создание асинхронных очередей сообщений в Java

Мне нужно динамически создавать асинхронные очереди сообщений в Java. Мой вариант использования - отправка электронной почты через несколько SMTP-серверов: мне нужно обеспечить, чтобы электронные письма на один и тот же SMTP-сервер обрабатывались последовательно, но электронные письма на разные ...

0
голосов
1ответов
168 просмотров

PocketPC c ++ проблема рекурсии обработки сообщений windows

У меня проблема в крупномасштабном приложении, которое, похоже, связано с обменом сообщениями Windows на КПК. У меня есть приложение для PocketPC, написанное на C ++. Он имеет только один стандартный цикл сообщений. while (GetMessage (& msg, NULL, 0, 0)) { {TranslateMessage (& m...

0
голосов
1ответов
520 просмотров

How to handle MSMQ delay problem?

Scenerio: Function A() ->creates the message and puts the message in the queue Listener -> checks constantly if theres a message in the queue and sends it to the service to process it and get the result and inserts the result into db Function B() ->gets the result from the...

1
голосов
3ответов
5505 просмотров

How can I implement JMS MessageListener?

I tried to implement MessageListener, but it dosen't work, but when I use MessageListner, it doesn't work. So what should I do that MessageListener starts working, I'm using jboss 4.02. recv.receive(); // This works recv.setMessageListener(new ExListener()); // This doesn't work public sta...

1
голосов
1ответов
712 просмотров

Building a Message Delivery Queue in PHP

I'm building a system that will send verses of scripture to subscribers over e-mail. Subscribers will be able to: Determine what volume of scripture they want to receive verses from Determine the daily frequency of the messages and how many verses will be included in each message Determine whic...

3
голосов
4ответов
11833 просмотров

How can I cleanup the IPC message-queue?

I am using msgget() function in my IPC based application. How can I clean up the queue filled up with old message queues?

1
голосов
3ответов
661 просмотров

Blackboard messaging using queues

I have an application, where I need to add role-based messaging. The messages are generated ny the application itself, and every message have an starttime (where is show on the client message-window) and an expire-time. Depending on your role, you will see a subset of the messages. Some messages ...

2
голосов
1ответов
4988 просмотров

How to solve "msgget: No space left on device" error?

I am writing an IPC application using message queues. While using msgget() function to get Message Queue I am getting this error. The requested operations does not require lot of space on the device and there should be space left as well. Any ideas. Thank you in advance

2
голосов
1ответов
308 просмотров

What are some techniques to push changes from tokyo cabinet in a multi-service setup?

Let's say I have N> 1 TCP-based, connection-oriented (read: not a website) services handling connections from end users in some load-balanced/sharing configuration. These users do things that cause updates to one or more keys in the centralized Tokyo Tyrant datastore. What do you recommend...

1
голосов
1ответов
548 просмотров

Process All Windows Messages Generated By A Compact Framework Application

Hoepfully someone can shed some light on a problem - I am trying to listen to\intercept all windows messages generated by an application and dispose of certain types, for example Notify or Gesture messages. I have been reading articals on how to do this using the Microsoft.WindowsCE.Forms.Messag...

3
голосов
2ответов
556 просмотров

JMS architectural problem?

Greetings, In the application that I am working on, I have a long-running process (DNA analysis). Users can send requests, and I am thinking of queuing the requests in a JMS queue, then processing the requests in the queue accordingly. Then, the result is emailed to the particular user. Howev...

0
голосов
1ответов
82 просмотров

Using messaging to do writes as well as reads

I come from a web background where I only have to deal with HTTP so please excuse my ignorance. I have an app which where clients listen for changes in a message queue which uses stomp. Previously the client only needed to listen to the relevant channels for messages telling them about changes o...

20
голосов
3ответов
16940 просмотров

Can you/should you use SQL Server Service Broker with .NET applications?

I have many operations in the database that need to trigger application code. Currently I am using database polling, but I hear that SQL Server Service Broker can give me MSMQ-like functionality. Can I listen to SQL Server Service Broker queues from .NET applications running on a different mach...

0
голосов
2ответов
4490 просмотров

JBoss EJB3 MDB config

I am trying to understand some EJB 3 code running in JBoss 4.3. We've got an ejb3-interceptors-aop.xml file configured in JBoss with some MDB configuration and then we've got the MDB Java class. What I'd like to understand is when and how does the MDB get "bound" to the MQ? That is, when/how ...

8
голосов
4ответов
10824 просмотров

Multithreaded single-reader single-writer fifo queue

I need a queue for passing messages from one thread (A) to another (B), however ive not been able to find one that really does what I want, since they generally allow adding an item to fail, a case which in my situation is pretty much fatal since the message needs to be processed, and the thread ...

1
голосов
3ответов
3043 просмотров

postthreadmessage and peekmessage problem in delphi 2006

I created a multichilded application. The application windows (W[n]: TMyWindows) are all the same and all have an private object class instance associated with them (E: TMyObject). The child windows generate through this objects some messages. I have created in the main application two threads wh...

0
голосов
1ответов
216 просмотров

Can a message queue be shared across PHP scripts?

How do I create message queue in PHP, such that it can be modified and read by 2 different scripts running at the same time? Or is it better to use a database for this?

0
голосов
1ответов
1094 просмотров

Flex + Spring + BlazeDS + Glassfish + OpenMQ - How do you configure the web-application-config for OpenMQ?

I have the spring-flex-testdrive example (JMS chat application which uses a Topic to pub/sub messages) to work on Tomcat with ActiveMQ now I want to run this example on Glassfish with OpenMQ. This is a related sample config I found online but it doesn't quite work for the Flex/Glassfish/OpenMQ...

3
голосов
3ответов
3719 просмотров

Is a System.MessageQueue (MSMQ) message lost if my function fails while processing it?

I send a message using the following code: var transaction = new MessageQueueTransaction()) transaction.Begin( ); var message = new Message { Body = myContent, Recoverable = true }; m_oMessageQueue.Send( message , myTransaction ); transaction.Commit( ); And receive it using a Begi...

2
голосов
5ответов
1438 просмотров

Dynamic Delphi form creation - ensuring correct mouse message handling

I have an Application layout that is based on a treeView at the left, and a panel on the right. The panel hosts a differnt TForm class depending on the tree node selected (a kind of 'form explorer'). There is only one form displayed at a time which exposes underlying data stored elsewhere and the...

6
голосов
3ответов
2929 просмотров

What is the difference between jboss.jms and jboss.mq ?

What is the difference between the classes org.jboss.jms.server.destination.QueueService and org.jboss.mq.server.jmx.Queue?

3
голосов
2ответов
5251 просмотров

Websphere MQ using JMS, closed connections stuck on the MQ

I have a simple JMS application deployed on OC4J under AIX server, in my application I'm listening to some queues and sending to other queues on a Websphere MQ deployed under AS400 server. The problem is that my connections to these queues are terminated/closed when it stays idle for some time w...

17
голосов
3ответов
11847 просмотров

How to set timeout detection on a RabbitMQ server?

I am trying out RabbitMQ with this python binding. One thing I noticed is that if I kill a consumer uncleanly (emulating a crashed program), the server will think that this consumer is still there for a long time. The result of this is that every other message will be ignored. For example if yo...