MM
есть плагин
Size: a a a
2021 March 09
MM
который тоже костыль, но скрытый от глаз
MM
rabbitmq delayed message plugin
JK
Давно было, но плагин я этот юзал. Всё норм пока кролик один. Как только нужен кластер кролику становится плохо с этим плагином.
JK
Может что и поправили.
MM
ну самый надёжный способ - костыль для dead letter'а. у плагина есть множество минусов
MM
ну либо не выпендриваться и воткнуть крон/аналог. Всё ж плагин для другого, равно как и варианты с dead letter'ом
AK
так dead letter тебе все равно нужно обработать, т.е у тебя должен быть консьюмер, который умеет понимать эти "отложенные" сообщения
JK
так dead letter тебе все равно нужно обработать, т.е у тебя должен быть консьюмер, который умеет понимать эти "отложенные" сообщения
Не совсем понимаю.
Если AmqpMessage не имеет TTL, то и dead letter exchange не нужен. Висит себе набитая очередь и висит. Пусть висит пока консьюмер не поднимется.
* Это в отрыве от delayed.
Если AmqpMessage не имеет TTL, то и dead letter exchange не нужен. Висит себе набитая очередь и висит. Пусть висит пока консьюмер не поднимется.
* Это в отрыве от delayed.
AK
Не совсем понимаю.
Если AmqpMessage не имеет TTL, то и dead letter exchange не нужен. Висит себе набитая очередь и висит. Пусть висит пока консьюмер не поднимется.
* Это в отрыве от delayed.
Если AmqpMessage не имеет TTL, то и dead letter exchange не нужен. Висит себе набитая очередь и висит. Пусть висит пока консьюмер не поднимется.
* Это в отрыве от delayed.
так а кто его поднимет? и почему он не поднят?
JK
Если у тебя падают консьюмеры обычные, то проблему нужно решать не dead letter-ом ))
AK
так к этому я и веду)
JK
Кароч, я к тому, что если у мессенджера транспорт AMQP, то я б не использовал DelayedStamp события вообще.
JK
Ну либо отдельную очередь для них с транспотротом в SQL
ST
Здравствуйте. А в каком случае может не создаться поле в базе данных (в миграции). Использую Embeddable для выделения Address, миграция не создает поле city
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
DS
Здравствуйте. А в каком случае может не создаться поле в базе данных (в миграции). Использую Embeddable для выделения Address, миграция не создает поле city
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
@JoinColumn@JoinColumn ===> @ORM\JoinColumn
ST
Dimitriy Serikov
@JoinColumn@JoinColumn ===> @ORM\JoinColumn
Спасибо. Но не создает всё равно. Создает другие поля прописанные в Address, но city не создает
DT
Здравствуйте. А в каком случае может не создаться поле в базе данных (в миграции). Использую Embeddable для выделения Address, миграция не создает поле city
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
/ @Embeddable */
final class Address
{
/@Embeddable */
final class Address
{
/
* @ORM\ManyToOne(targetEntity="City",inversedBy="companies")
* @JoinColumn(name="city", referencedColumnName="id")
* @Assert\NotNull
*/
private $city;
Что в родителе прописано?
ST
/** @Embedded(class = "Address") */
private $address;
private $address;
ST
Видимо "Embeddables can only contain properties with basic @Column mapping."