Set Messaggio TTL ad una RabbitMQ un'ora

Come posso impostare il messaggio TTL (non la coda) sia dalSet Messaggio TTL ad una RabbitMQ un'ora

Exchange (Lo scambio manda a più code)
messaggio (durante la pubblicazione del messaggio)
coda (sulla coda stessa, ma ancora una volta questo è il messaggio TTL e non TTL coda)

io corro 3.x RabbitMQ, Symfony 2.1.x e il RabbitMqBundle.

Quello che ho provato:

Impostazione della TTL Messaggio quando faccio la stessa coda dal RabbitMQ Admin UI

ho impostato le proprietà del messaggio per 'x-message-ttl' => 3600000. Nel RabbitMQ config sembra che questo:

{ 
    "name": "blah_queue", 
    "vhost": "foobar", 
    "durable": true, 
    "auto_delete": false, 
    "arguments": { 
      'x-message-ttl' => 3600000 
    } 
},

questo è l'errore che ottengo:

PRECONDITION_FAILED - inequivalent arg 'x-message-ttl'for queue

ho provato a fissare nel config.yml (symfony/https://github.com/videlalvaro/RabbitMqBundle/README)

questo dà un sacco di errori con la libreria AMQP utilizzata dal bundle.

Ho provato a modificare la libreria AMQP stessa per consentire le proprietà del messaggio x-message-ttl e ottengo un'eccezione Error sending data.

Qualcuno ha impostato il messaggio TTL utilizzando RabbitMQBundle?

queue_options: {name: 'blah_queue', arguments: {'x-message-ttl' => 3600000}}

fonte

2013-01-16 Phill Pafford

Credo che si voglia fare qualcosa del genere: 'argomenti: {'x-message-ttl': ['I', 3600000]} 'guarda [questo file di test] (https: // github.com/romainneutron/php-amqplib/blob/9165f99461c3455ddc93916ad0821e99b0d19c43/demo/queue_arguments.php) per la libreria menzognera –

queue_options: {name: 'blah_queue', arguments: {'x-message-ttl' : ['I', '3600000']}}

fonte

2013-01-16 21:06:06

Scusa che era una delle opzioni che ho provato già, non ha funzionato –

Questo funziona correttamente con Rabbit 2.8 e le ultime versioni di RabbitMQBundle e php-ampqlib. Non ho provato con le versioni 3.x di Rabbit, ma forse l'opzione è cambiata? –

Inoltre, è necessario eliminare la coda prima di eseguire un consumatore/produttore. Non è possibile aggiungere questo argomento a una coda che non lo ha già. –

posso impostare il tempo di messaggio della coda di vivere dalla console di gestione RabbitMQ come questo:

sto usando RabbitMQ 3.1.5 su Fedora Linux, visitare questo nel browser:

http://your_rabbitmq_server.com:15672
Fare clic sulla scheda "Code" e scorrere verso il basso per cui si dice: "Aggiungere una nuova coda"

Sotto la sottosezione: "Aggiungere una nuova coda", compilare queste caselle di testo:

Virtual host:   /
Name:      myqueue1 
Durability:    Durable 
Auto delete:    No 
Message TTL:  
Auto expire: 
Max length: 
Dead letter exchange: 
Dead letter routing key: 

Argument key  = x-message-ttl 
Argument value = 3600000 
Argument datatype = number

Fare clic su OK per salvarlo.

Ora ho potuto consumare dalla coda e il messaggio sarà ancora lì per il tempo specificato.

fonte

2014-09-10 14:15:02

Set Messaggio TTL ad una RabbitMQ un'ora

risposta

Problemi correlati