Результаты поиска по запросу "amqp"
Я обнаружил, что есть конструктор DeviceClient, который позволяет установить AmqpConnectionPoolSettings.
зрабатываем службу .Net Core, которая будет размещена в Azure Service Fabric. Эта служба SF должна взаимодействовать с 10 000 устройств, зарегистрированных в концентраторе IoT Azure, через конечные точки SSL TLS AMQP 1.0. Каждое устройство IoT ...
Однако это не означает, что приложение-потребитель обработало сообщение или имеет достаточно памяти для хранения входящих сообщений. Отставание в статье - это просто структура данных, используемая для хранения необработанных сообщений (в потребительском приложении).
ал о принципах обмена сообщениями AMQP подтверждает. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html] ). Действительно полезная и хорошо написанная статья, но одна конкретная вещь о потребителях действительно ...
Следующий код работает:
ал тот же вопрос несколько дней назад:Невозможно «просмотреть» сообщения из очереди служебной шины Azure с помощью AMQP и ...
Этот класс Consumer предоставляет полученное событие, которое вы можете использовать, и поэтому НЕ блокирует. Остальная часть кода в основном остается прежней.
ичок в RabbitMQ. Я хочу иметь возможность обрабатывать чтение сообщений без блокировки, когда есть несколько очередей (для чтения из). Есть какие-то отзывы о том, как я могу это сделать? // Редактировать 1 public class Rabbit : IMessageBus { ...
stackoverflow.com/questions/11926077/...
ся, чем дольше я работаю на своем сервере rabbitmq, тем больше у меня проблем с неподтвержденными сообщениями. Я хотел бы потребовать их. На самом деле, кажется, для этого есть команда amqp, но она применяется только к каналу, который использует ...
Восстановление из zmq.error.ZMQError: Адрес уже используется
Я нажал Ctrl-C во время запускаPAIR шаблон (неблокирующие клиентские серверы) соединение с ZMQ. Позже, когда я попытался запуститьREQ-REP (блокировка подключения клиента к одному серверу), я продолжаю получатьAddress already in use ошибка. Я ...
Группы сообщений в RabbitMQ / AMQP
ActiveMQ / JMS имеет встроенный механизм, гарантирующий, что сообщения с общим заголовком (а именно заголовок JMSXGroupID) всегда потребляются одним и тем же потребителем очереди при использовании шаблона конкурирующих потребителей. Потребители ...
Как сделать очереди конфиденциальными / безопасными в RabbitMQ в многопользовательской системе?
Я прочиталНачать [http://www.rabbitmq.com/getstarted.html]руководство, предоставленное RabbitMQ и даже внесло шестой примерштурмовали-AMQP [https://github.com/paolo-losi/stormed-amqp/tree/master/examples/tutorial6]Итак, у меня есть немного знаний ...
RabbitMQ basic.get и подтверждение
Я призываю: GetResponse response = channel.basicGet("some.queue", false); // no auto-ack .... channel.basicAck(deliveryTag, ...);Тем не менее, когда я призываюbasicGetсообщения в очереди остаются в «Готово», а не в «Неподтвержденном». Я хочу, ...
Неустранимая ошибка PHP: класс 'AMQPConnection' не найден
Я уже виделэтот вопрос [https://stackoverflow.com/questions/5424419/rabbitmq-error-when-connect], Это говорит о том, что расширение AMQP PECL не установлено. Тем не менее, я успешно установил как RabbitMQ, так и встроенное расширение PECL AMQP. ...