Описание тега consumer
1
ответ
Один JMS Consumer перестает слушать активную тему mq, а второй нет
Процесс пружинного кварца выполняется в моем проекте каждые 15 минут, т.е. 96 раз в день. Это извлекает определенные записи из базы данных и отправляет их в службу REST (работает на JBoss 7). Эти записи, как правило, насчитывают от 50 до 100. На слу…
21 ноя '14 в 09:03
0
ответов
Приложение Grails, действующее как собственный поставщик openid
Я использую Grails 2.1.1 с Spring Security, и есть ссылка из моего приложения на другой сайт на том же сервере, что и мое приложение grails, где я использую osqa ( http://www.osqa.net/). Я хочу, чтобы пользователи могли обычно регистрироваться в мое…
22 май '13 в 09:36
3
ответа
Способ разорвать связь от rabbitmq
У меня есть приложение, в котором есть ошибки. По какой-то причине 2 потребителя создаются, когда только один должен быть там - и один из них больше не проверяется на наличие сообщений. Я могу обнаружить эту ситуацию, перечислив очереди и количество…
18 авг '11 в 23:35
1
ответ
Потребитель KAFKA Java не работает
Я не могу получить работу на Java в локальном хосте. Консоль потребителя работает отлично. Ниже мой потребительский код. открытый класс TestConsumer {открытый статический void main(String[] args) выдает исключение { //Kafka consumer configuration se…
12 фев '17 в 12:56
1
ответ
Почему *randNum увеличивается?
Пожалуйста, не отрицайте этот вопрос, я понимаю, что он не слишком конкретен, но это именно моя проблема. Я знаю, что делает каждая команда в моем коде, я просто не знаю, почему они там находятся. Это безумно сложно найти ответы, потому что мои вопр…
29 июл '13 в 12:50
2
ответа
Реагируйте: Как я могу использовать моего потребителя внутри ComponentDidMount для изменения состояния?
Поэтому я использую контекст React, потому что я должен изменить состояние в противоположном направлении.Например:App.js (имеет состояние) <--- Мой компонент (изменяет состояние в App.js) Я знаю, как это сделать, используя событие onClick. Тем не ме…
18 фев '19 в 19:52
1
ответ
ActiveMQ connect, неизвестный тип данных: 49
Я использую ActiveMQ для отправки файлов из приложения в другое, и я столкнулся с этой ошибкой, когда потребитель пытается подключиться к серверу ActiveMQ. Вот метод подключения public void connect() { connectionFactory = new ActiveMQConnectionFacto…
09 фев '16 в 10:09
1
ответ
Пул загрузочных подключений activemq для потребителей
Потребуется настроить пул подключений Spring Boot ActiveMQ? У меня только один потребитель в весеннем загрузочном приложении (как микро сервис), производители находятся в другом приложении. Меня немного смущает следующее: (извлечено из http://active…
08 дек '17 в 16:33
2
ответа
Кафка Потребительская на Яве
Поэтому я изучаю Кафку в настоящее время и пытался продублировать примеры, предоставленные здесь Apache. Это пример кода для потребителя, и я написал его в Java, как показано на рисунке. Однако, когда я пытаюсь выполнить файл, я сталкиваюсь с некото…
26 май '15 в 20:13
1
ответ
Как заставить подключение ActiveMQ случайным образом выбрать брокера для нового потребителя?
Я использую следующий URL для создания ActiveMQConnactionFactory: failover:(tcp://server1:port,tcp://server2:port,tcp://server2:port) Что я хочу сделать, так это создать несколько потребителей сообщений из этой сети брокеров. Следующий код не являет…
16 мар '11 в 10:06
3
ответа
Как изменить список за пределами потребителя
Я работаю над проблемой для школы. Многие из этих методов уже были реализованы, и мне не разрешено вносить слишком много изменений. На самом деле я могу вносить изменения только в определенных местах. Вот код метода, над которым я работаю, хотя неко…
01 мар '17 в 09:25
3
ответа
Очередь без блокировки (или даже без ожидания) с несколькими потребителями
Я ищу документацию о том, как написать очередь MP/MC без блокировки или даже без ожидания. Я использую.Net 4.0. Нашел много кода на C++, но я не очень знаком с моделями памяти, поэтому есть большая вероятность, что я буду вносить некоторые ошибки пр…
20 май '11 в 22:45
1
ответ
Смещение CONSUME_FROM_LAST неэффективно
Я изменил свою группу потребления и начал потреблять, она потребляется из последнего смещения по умолчанию, это правильно. Но когда я перезапускаю этого потребителя, он использует сообщение истории, почему он не использует сообщение истории при пер…
01 июн '17 в 13:38
1
ответ
Кафка 0.10.1.0 смена времени смещения
Конвейер Elasticsearch, настроенный с кластером Kafka между 2 экземплярами logstash. Мне нужно сбросить смещение назад на 12 часов для темы и снова запустить потребителя. bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kfkserver:9092…
28 фев '17 в 09:47
0
ответов
Поток Java, потребитель не хочет заканчивать
Почему мой поток (Runnable) не выходит из метода run(), как только он достигает конца блока? Это код: //1 Entry point for thread with run method public void run() { System.out.println("Hashmaker():/run(). " + threadName + " Running " ); try { String…
08 апр '16 в 07:30
1
ответ
Потребитель Kafka не потребляет, если первый брокер не работает
Я использую последнюю версию kafka(kafka_2.12-1.0.0.tgz). Я установил простой кластер с 3 брокерами (только что изменили broker.id=1 и listeners=PLAINTEXT://:9092 в файле свойств для каждого экземпляра). После того, как кластер запущен, я создал тем…
09 янв '18 в 11:40
1
ответ
Обнаруженные дубликаты FlexSessions на основе HTTP, как правило, из-за того, что удаленный хост отключил файлы cookie сеанса
описание сцены: моя программа реализована с помощью flex+java+blazeDS+activeMQ, она подписывает сообщение jms от activeMQ от Flex Consumer, в настоящее время я поставляю два томата на одном сервере, все они содержат мою программу, а ActiveMQ находит…
10 янв '13 в 09:24
2
ответа
Что такое эквивалент C# Java 8 java.util.function.Consumer<>?
Есть ли эквивалент этого интерфейса в C#? Пример: Consumer<Byte> consumer = new Consumer<>(); consumer.accept(data[11]); Я искал вокруг Func<> а также Action<> но я понятия не имею. Оригинальный код Java Consumer.accept() Инт…
06 апр '16 в 11:08
1
ответ
Распределение потребителей RabbitMQ
Нужна помощь в разработке потребительского распределения rabbit-mq. Например, существует 100 очередей и 10 потоков для приема сообщений из этой 100 очередей. Каждый поток будет потреблять сообщения из 10 очередей каждый. Вопрос 1: Как динамически на…
28 апр '14 в 14:32
1
ответ
С Activemq, как сделать более одного эксклюзивного потребителя для очереди?
Как вы знаете, мы можем использовать Exclusive Consumer, который позволяет только одному потребителю потреблять из очереди одновременно для сохранения заказа... но: у меня есть 4 потребителя, которые мне нужны, чтобы все они получали сообщения и сох…
03 окт '17 в 14:56