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 для петлителя другого п
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) сервере с минимальными изменениями? Очевидно, что будут изме
2ответа
4 голоса
Можно ли потреблять обмен в RabbitMQ?
Возможно, я задаю не тот вопрос здесь. что я пытаюсь сделать: несколько производителей помещают данные в динамических категориях в именованный обмен. несколько потребителей должны взять эти данны
2ответа
4 голоса
Должен ли я синхронизировать вызовы mq_timedreceive при выполнении несколькими потоками?
Я использую Posix Message Queues в Linux. По сути, у меня есть несколько потоков, которые получают сообщения из одной очереди по вызовам mq_timedreceive. Если одновременно запущено несколько пото
2ответа
4 голоса
POSIX очереди и msg_max
Я немного играю с очередями POSIX и столкнулся с проблемой. При создании новой очереди я могу указать, например, размер сообщения и сколько сообщений может быть в очереди. Мой нормальный предел - 10
1 2 3 4 5

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132