Size: a a a

2020 February 28

A

Anatoliy in Go-go!
Bogdan (SirEdvin) Gladyshev
В кратце - вообще все.
Нормальный мониторинг, нормальное разделение между exchange/queue, возможность делать зеркалирование очередей, их autoexpire и еще кучу других штук
эм... а зачем? да и автовыпил по времени у натса тоже есть.
и что значит нормальное разделение между exchange/queue?
источник

GG

Go Go in Go-go!
Оо ну раз так тогда да. Я думал один экземпляр только
источник

ЕК

Евгений Клецов in Go-go!
Bogdan (SirEdvin) Gladyshev
В nats-streaming оно будет висеть в количестве n штук в очереди
никогда с таким не сталкивался
источник

MD

Maxim Dororonin in Go-go!
Bogdan (SirEdvin) Gladyshev
В nats-streaming оно будет висеть в количестве n штук в очереди
Ничего там не будет висеть, как только сообщение обработается, больше оно не будет доставлено.
источник

A

Anatoliy in Go-go!
Евгений Клецов
никогда с таким не сталкивался
+1
источник

ЕК

Евгений Клецов in Go-go!
чтоб сообщение в очереди дублировалось
источник

GG

Go Go in Go-go!
Может что-то не так делали ?
источник

BG

Bogdan (SirEdvin) Gladyshev in Go-go!
Anatoliy
эм... а зачем? да и автовыпил по времени у натса тоже есть.
и что значит нормальное разделение между exchange/queue?
В rabbitmq вы пишите в exchange, а читаете из queue. Связь между exchange и queue устанавливается отдельно и может быть очень разнообразной
источник

GG

Go Go in Go-go!
Поидее даже логически не правильно чтобы тоже самое сообщение дублировалось
источник

BG

Bogdan (SirEdvin) Gladyshev in Go-go!
Maxim Dororonin
Ничего там не будет висеть, как только сообщение обработается, больше оно не будет доставлено.
Не так. Оно больше не будет отправлено в очередь. Попробуйте обрабатывать одно сообщение, например, в два раза больше чем выставили timeout в nats-streaming
источник

GG

Go Go in Go-go!
Bogdan (SirEdvin) Gladyshev
Не так. Оно больше не будет отправлено в очередь. Попробуйте обрабатывать одно сообщение, например, в два раза больше чем выставили timeout в nats-streaming
Сегодня протестирую )
источник

BG

Bogdan (SirEdvin) Gladyshev in Go-go!
Я просто на одном проекте очень сильно от этого отхватил :)
источник

GG

Go Go in Go-go!
Хаха)
источник

A

Anatoliy in Go-go!
Ну да, и натс таким образом позволяет из за этого делать вот такую штуку если я все верно понимаю: https://github.com/nats-rpc/nrpc
Кстати щупал кто?)
источник

MD

Maxim Dororonin in Go-go!
Bogdan (SirEdvin) Gladyshev
Не так. Оно больше не будет отправлено в очередь. Попробуйте обрабатывать одно сообщение, например, в два раза больше чем выставили timeout в nats-streaming
Ну оно прилетит еще раз с флагом redelivered и это нормально)
источник

MD

Maxim Dororonin in Go-go!
Акайте сообщения при получении)
источник

MD

Maxim Dororonin in Go-go!
Если не знаете сколько оно будет выполнятся
источник

ЕК

Евгений Клецов in Go-go!
Maxim Dororonin
Акайте сообщения при получении)
только хотел сказать )
источник

BG

Bogdan (SirEdvin) Gladyshev in Go-go!
Maxim Dororonin
Акайте сообщения при получении)
Так оно в очереди лежить, что акать то?
источник

MD

Maxim Dororonin in Go-go!
Bogdan (SirEdvin) Gladyshev
Так оно в очереди лежить, что акать то?
Что то я запутался)
источник