0
ответов

Преобразование сообщений обработки потоков Java в очередь с использованием Kotlin Coroutines

В моем приложении для Android есть выделенная нить, которая выполняет сетевые вызовы API с использованием дооснащения. Поток выполняет дооснащение API-вызовов в зависимости от типа полученного сообщения. Я хотел бы перенести этот код в ...
вопрос задан: 16 January 2019 11:37
0
ответов

Как узнать, когда набор задач RabbitMQ завершен?

Я использую RabbitMQ, чтобы рабочие процессы кодировали видеофайлы. Я хотел бы знать, когда все файлы будут завершены, то есть когда все рабочие процессы будут завершены. Единственный способ, которым я могу ...
вопрос задан: 23 May 2017 12:31
0
ответов

Приостановить поток менее чем на одну миллисекунду

В тестовом приложении клиента обмена сообщениями необходимо регулировать поток производителя, чтобы избежать переполнения сервера. Поскольку скорость передачи составляет около 25000 сообщений в секунду (40 микросекунд на ...
вопрос задан: 23 May 2017 12:26
0
ответов

Обработка сообщения ровно один раз

Пожалуйста, рассмотрите сценарий, показанный на прикрепленном изображении :Производитель портала ()отправит некоторое сообщение на шину, которая должна быть обработана несколькими приложениями (потребитель )– PAYROLLAPP,...
вопрос задан: 23 May 2017 12:02
0
ответов

Готов ли ZeroMQ к использованию в производственной среде?

Тот же вопрос был задан год назад здесь. Я ищу обновление статуса на сегодня. Как сообщения об ошибках, документация и т. д.? Есть ли частые ошибки, которые вызывают проблемы при разработке? Как...
вопрос задан: 23 May 2017 11:57
0
ответов

Fastest reliable way for Clojure (Java) and Ruby apps to communicate

We have cloud-hosted (RackSpace cloud) Ruby and Java apps that will interact as follows: Ruby app sends a request to Java app. Request consists of map structure containing strings, integers, other ...
вопрос задан: 23 May 2017 11:43
0
ответов

NServiceBus Publish () vs. Send () в контексте веб-сайта

Я хочу лучше понять, почему рекомендуется никогда не публиковать сообщения Publish () с веб-сайта, использующего NServiceBus (документация NServiceBus, прокрутите примерно две трети вниз). ...
вопрос задан: 29 January 2016 05:12
0
ответов

запустить WhatsApp с android.content.Intent.ACTION_SENDTO

Я пытаюсь запустить WhatsApp с намерением Android: String uri = "smsto: +123456"; Intent messageIntent = новое намерение (Intent.ACTION_SENDTO, Uri.parse (uri)); messageIntent.putExtra ("sms_body", "My ...
вопрос задан: 28 November 2015 14:45
0
ответов

Android - почему «content: // sms / sent» возвращает только один результат?

При попытке получить отправленные смс я вижу, что смс / отправленные uri возвращают только 1 смс (хотя устройство имеет больше), и кажется, что это первая отправленная смс. Как я могу получить все смс в отправленной коробке? ...
вопрос задан: 26 February 2015 12:49
0
ответов

RabbitMQ и связь между каналом и соединением

Java-клиент RabbitMQ имеет следующие концепции: Соединение - соединение с экземпляром сервера RabbitMQ. Канал - ??? Пул потребительских потоков - пул потоков, которые потребляют сообщения от ...
вопрос задан: 24 August 2013 13:08
0
ответов

Тестирование Camel с помощью MockEndpoints

У меня есть ряд «конвейерных» компонентов, которые все общаются через очереди сообщений ActiveMQ. Каждый компонент использует Camel для обработки каждой из этих очередей как конечной точки. Каждый компонент использует одно и то же ...
вопрос задан: 7 March 2013 16:21
0
ответов

Ищем простой постоянный буфер сообщений в Java

Я ищу простой постоянный буфер в качестве временного хранилища для сообщений JSON в приложении Java. Использование памяти должно быть относительно постоянным и не зависеть от количества сообщений в...
вопрос задан: 13 August 2012 13:53
0
ответов

Высокопроизводительный обмен сообщениями JMS

Я читал слайды с UberConf этого года, и один из выступавших приводит аргумент, что Spring JMS увеличивает производительность вашей системы очередей сообщений, однако я не вижу никаких доказательств того, что...
вопрос задан: 7 August 2012 06:46
0
ответов

JMS AUTO _ПОДТВЕРЖДЕНИЕ когда подтверждается?

Я пытался найти это в Google, но безуспешно. Если я использую АВТОМАТИЧЕСКОЕ _ПОДТВЕРЖДЕНИЕ и у меня есть потребительский клиент, написанный на Java, когда сообщение подтверждается? Я использую MessageListener...
вопрос задан: 26 July 2012 16:01
0
ответов

Захват всех сообщений Windows

Я хочу использовать машинное обучение для моделирования намерений пользователя и потенциальной автоматизации часто выполняемых задач. Для этого хотелось бы иметь доступ к пожарному -шлангу информации о действиях пользователей...
вопрос задан: 6 July 2012 12:01
0
ответов

SMS нельзя предотвратить с помощью abortBroadcast()?

Я работаю над приложением для блокировки смс, в котором я использую широковещательный приемник и метод abortBroadcast() - как многие предлагали здесь - чтобы сообщения не попадали в папку "Входящие" и предупреждали...
вопрос задан: 29 June 2012 18:23
0
ответов

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

Я работаю над системой обмена сообщениями с двумя таблицами и другой таблицей с информацией о пользователях. Диалог может вестись от 2 и более пользователей. Каждый разговор имеет UID и каждое сообщение, которым обмениваются ...
вопрос задан: 9 June 2012 15:45
0
ответов

socket.io и node.js для отправки сообщения конкретному клиенту

Отправка сообщения всем клиентам работает хорошо, но я хочу отправить сообщение определенному имени пользователя. мой файл server.js выглядит так. Что он делает, так это когда http://localhost:8080 запускается, код клиента добавляет пользователя ...
вопрос задан: 17 May 2012 03:36
0
ответов

RabbitMQ/AMQP: одна очередь, несколько потребителей для одного и того же сообщения?

Я только начинаю использовать RabbitMQ и AMQP в целом. У меня есть очередь сообщений У меня есть несколько потребителей, которым я хотел бы делать разные вещи с одним и тем же сообщением. Большая часть RabbitMQ...
вопрос задан: 16 May 2012 14:56
0
ответов

Очень низкая пропускная способность при использовании основного моста HornetQ

Мы пытаемся использовать механизм хранения и пересылки HornetQ... однако пересылка сообщений от одного автономного экземпляра HornetQ к другому с использованием основного моста происходит очень медленно. Нам не удалось...
вопрос задан: 2 May 2012 06:53
0
ответов

сервер поддерживает миллионы одновременных подключений

Я создаю распределенную систему, которая потенциально может состоять из миллионов клиентов, которым всем необходимо поддерживать открытое (предпочтительно HTTP)соединение для ожидания команды с сервера (который работает...
вопрос задан: 11 April 2012 23:46
0
ответов

Как использовать очередь сообщений в реальном сценарии?

Итак, меня интересует организация очереди сообщений. Я действительно уже провел множество исследований на эту тему. Я читал "программирование Windows Azure" (о очередях Azure), я прочитал множество руководств и информации...
вопрос задан: 4 April 2012 23:40
0
ответов

Использование APN в приложении для обмена сообщениями

Я работаю над приложением для обмена сообщениями (что-то вроде WhatsApp) и у меня возникла дилемма по поводу реализации его основной функциональности - отправки сообщения от клиента1 клиенту2. Дело в том, что я использую ...
вопрос задан: 28 February 2012 11:26
0
ответов

Параметры отправки и прослушивания Tibco RV перепутаны

Привет, я новичок в Tibco RV. Прочитав концепцию Tibco Rendezvous, я все еще не понимаю, какие параметры транспорта: служба, сеть, демон. Итак, концептуально существует только один демон, работающий на ...
вопрос задан: 19 February 2012 08:24
0
ответов

Обычная очередь против очереди SEDA

Будучи новичком в Apache Camel, я недавно просматривал длинный список его компонентов и наткнулся на их поддержку компонентов очереди SEDA. Страница не имела для меня особого смысла, поэтому я сделал пару ...
вопрос задан: 6 February 2012 15:31
0
ответов

Вызывает ли RabbitMQ функцию обратного вызова для потребителя, когда у него есть какое-то сообщение для него?

Вызывает ли RabbitMQ функцию обратного вызова для потребителя, когда у него есть какое-то сообщение для него, или потребитель должен опросить клиента RabbitMQ? Итак, на стороне потребителя, если есть PHP-скрипт, может ли ...
вопрос задан: 5 February 2012 19:59
0
ответов

Как реализовать решение для конкурирующего потребителя?

В качестве упражнения я пытаюсь найти пример, который реализует конкурирующего потребителя. многие производители -> MSMQueue <- конкурирующие потребители Пока я не нашел никакой документации о том, как достичь ...
вопрос задан: 1 February 2012 19:28
0
ответов

CQRS применяет сквозные проблемы, такие как безопасность

Предположим, у меня есть сложная система, в которой есть большие деревья людей. Простые мысли - это отношения сотрудников и менеджеров, многие сотрудники подчиняются одному менеджеру. Теперь помимо менеджера есть ...
вопрос задан: 25 January 2012 21:30
0
ответов

как создать несколько экземпляров подписчиков темы activemq с помощью виртуальных назначений?

У меня есть издатель, который отправляет сообщения в тему. У меня есть несколько подписчиков, каждый из которых выполняет свою задачу, когда получает сообщение из темы. Теперь я хочу, чтобы моя система масштабировалась до нескольких ...
вопрос задан: 2 January 2012 23:22
0
ответов

Есть ли корпоративная очередь сообщений, которая может отбрасывать повторяющиеся сообщения (первое значение остается)?

Я ищу очередь сообщений с этими требованиями. Не нашел; возможно, самым близким был плагин rabbitmq-lvc (но мне нужно, чтобы первое значение в строке оставалось впереди). ...
вопрос задан: 16 December 2011 21:59