message-queue — все вопросы
1ответ
4 голоса
Определение домена передачи сообщений с очень большим количеством типов сообщений
Большинство примеров передачи сообщений F #, которые я видел до сих пор, работают с 2-4 типами сообщений и могут использовать сопоставление с шаблоном, чтобы направить каждое сообщение к его надлежа
1ответ
4 голоса
Имитация очереди задач Google Appengine с Gearman
Одной из характеристик, которые мне больше всего нравятся в очереди задач Google, является ее простота. Точнее говоря, мне нравится, что он принимает URL-адрес и некоторые параметры, а затем отправл
2ответа
4 голоса
Могут ли длительные подписки пережить перезапуск клиента?
Если я использую долговременную подписку, могу ли я перезапустить свой клиент и повторно подписаться, не теряя ни одного сообщения? (Предполагается, что мой клиент не отписывается никоим образом. До
1ответ
4 голоса
Могу ли я использовать очереди сообщений повышения для связи потоков
Я порождаю несколько рабочих потоков из основного потока. Могу ли я создать message_queue для каждого потока из основного потока и отправить сообщения из основного потока. Я спрашиваю об этом, потом
3ответа
4 голоса
Как вы обрабатываете сообщения параллельно, обеспечивая при этом FIFO для каждого объекта?
Допустим, у вас есть объект, скажем, «Человек» в вашей системе, и вы хотите обрабатывать события, которые изменяют различные объекты «Человек». Важно, что:
События для одного и того же лица обра
2ответа
4 голоса
MSMQ получает таймауты от .NET
Я хочу иметь возможность читать и обрабатывать сообщения из MSMQ. Очереди транзакционные. В настоящее время я использую этот код:
while (true)
{
using (var txn = new MessageQueueTransaction())
1ответ
4 голоса
Как предотвратить голодание сообщений с низким приоритетом в очереди с приоритетом ActiveMQ?
Я работаю в системе, в которой нам нужно реализовать приоритетную очередь. У нас есть сообщения с разными приоритетами, и нам нужно обрабатывать сообщения на основе приоритетов. В настоящее время мы
3ответа
4 голоса
получить очередь сообщений основного обработчика и обработчик
Как получить очередь сообщений основного потока из другого потока? Looper.getMainLooper () получает петлитель основного потока, но я не могу найти способ получить MessageQueue для петлителя другого п
android
2ответа
4 голоса
.NET: очередь сообщений и прямая вставка в MongoDB
У меня есть следующий вариант использования: веб-приложение (на самом деле браузер клиента) периодически отправляет отслеживания /пинги на веб-сервер (через XHR, JSON). Я храню эти треки в коллекции
3ответа
4 голоса
Управление памятью и дублирование RabbitMQ
В настоящее время я оцениваю RabbitMQ для управления очередью. Мне было интересно, как RabbitMQ управляет элементом очереди в памяти.
в этом примере подписчика этого издателя http://www.rabbitmq
1ответ
4 голоса
Где инициализировать MassTransit в приложении Asp.Net MVC 4?
У меня есть простое решение с 3 проектами:
Веб-приложение Asp.Net MVC4 - основной веб-сайт
Консольное приложение - исполнитель задач
Консольное приложение - исполнитель задач
Я хочу испол
1ответ
4 голоса
Изменить сообщение, отправленное rabbitMQ внутри потребителя
Примечание. Использование RabbitMq через RabbitMQBundle в Symfony2 .
Мой продюсер отправляет следующее сообщение:
$message = array(
'class' => get_class($receiver),
'id' =>
1ответ
4 голоса
Akka Event Bus: найти неиспользованные события в канале?
Если актер запускается и подписывается на канал в шине событий Akka, есть ли у актера возможность использовать события, которые уже были отправлены на канал, но не были использованы другим актером?
1ответ
4 голоса
Проверьте, существует ли очередь сообщений
Я создаю очередь сообщений в C следующим образом:
int msgid;
int msgflg = IPC_CREAT | 0666;
key_t key;
key = ftok(".",'a');
if ((msgid = msgget(key,msgflg)) < 0 ){
syserr("msgget error"
1ответ
4 голоса
Настройка сервера WebSocket в Spring 4
Я разрабатываю систему уведомлений в реальном времени с помощью WebSockets , используя Spring 4 .
Исходный код выглядит следующим образом:
WebSocketConfig:
@Configuration
@EnableSchedu
1ответ
4 голоса
Как заставить работать простой пример futures :: sync :: mpsc :: channel?
Я пытаюсь написать простой пример использования очередей mpsc futures-rs /р>
extern crate futures;
use futures::{Sink, Stream};
use futures::sync::mpsc;
use std::thread;
fn main() {
let
1ответ
4 голоса
Можно ли спроектировать веб-приложение, чтобы оно могло быть развернуто либо в облаке, либо на выделенном сервере /VPS? Как?
Существует ли достаточно универсальная архитектура, чтобы ее можно было развернуть либо на облачном сервере, либо на выделенном (или VPS) сервере с минимальными изменениями? Очевидно, что будут изме
azure
2ответа
4 голоса
Можно ли потреблять обмен в RabbitMQ?
Возможно, я задаю не тот вопрос здесь.
что я пытаюсь сделать: несколько производителей помещают данные в динамических категориях в именованный обмен. несколько потребителей должны взять эти данны
2ответа
4 голоса
Должен ли я синхронизировать вызовы mq_timedreceive при выполнении несколькими потоками?
Я использую Posix Message Queues в Linux. По сути, у меня есть несколько потоков, которые получают сообщения из одной очереди по вызовам mq_timedreceive.
Если одновременно запущено несколько пото
2ответа
4 голоса
POSIX очереди и msg_max
Я немного играю с очередями POSIX и столкнулся с проблемой. При создании новой очереди я могу указать, например, размер сообщения и сколько сообщений может быть в очереди. Мой нормальный предел - 10