amqp

13calore

2risposta

Sto usando rabbitMQ, prendo tutti i messaggi dalla coda con basic_get senza procedura acking automatica, il che significa che il messaggio rimane in coda fino a quando non accetto o nack il messaggio.

9calore

4risposta

Embedded Java Broker AMQP

Sto provando a creare test di integrazione per un'applicazione Scala/Java che si connette a un broker RabbitMQ. Per ottenere questo mi piacerebbe un broker embedded che parli di AMQP che inizio e ferm

5calore

1risposta

Microservizio, amqp e registro di servizio/rilevamento

Sto studiando l'architettura dei microservizi e mi sto davvero chiedendo qualcosa. Sono abbastanza d'accordo con il fatto di utilizzare (indietro) l'individuazione del servizio per rendere possibile l

16calore

1risposta

Possiamo avere una forte capacità di routing con Apache Kafka simile a RabbitMq?

Stiamo provando a valutare Kafka e sostituire Rabbit Mq nel nostro software. Sappiamo i vantaggi di Kafka in termini di RabbitMq rispetto al consumo offline, enorme persistenza, prestazioni eccellenti

37calore

3risposta

RabbitMQ/AMQP - Coda best practice/progettazione di argomenti in un'architettura MicroService

Stiamo pensando di introdurre un approccio basato su AMQP per la nostra infrastruttura di microservizi (coreografia). Disponiamo di diversi servizi, ad esempio il servizio clienti, il servizio utente,

8calore

1risposta

RabbitMQ: Qual è il valore predefinito x-message-ttl

Non ho trovato nella documentazione RabbitMQ il valore predefinito x-message-ttl fornito con l'installazione. So come impostarlo su un valore desiderato ma sono curioso di sapere il valore predefinito

6calore

1risposta

RabbitMQ Rpc: EventingBasicConsumer o QueueingBasicConsumer

Il tutorials on RabbitMq's site sono piuttosto semplice, ma ho notato che in the Rpc example, gli sviluppatori scelgono di utilizzare la chiamata filo-blocco consumer.Queue.Dequeue() invece di utilizz

17calore

1risposta

Celery & RabbitMQ in esecuzione come contenitori docker: attività non registrata ricevuta di tipo '...'

Sono relativamente nuovo alla finestra mobile, al sedano e al coniglioMQ. Nel nostro progetto abbiamo attualmente la seguente configurazione: 1 host fisico con più contenitori docker in esecuzione: 1x

5calore

1risposta

Monitorare più abbonamenti RabbitMq utilizzando un'unica applicazione

Ho un'applicazione che ho scritto in .NET in grado di monitorare più code RabbitMq utilizzando un singolo utente. Ad esempio: using (IConnection connection = factory.CreateConnection()) { using

6calore

1risposta

Connessione Pika chiusa dopo 3 heartbeat

Sto scrivendo uno script che riceve richieste HTTP (usando Tornado), le analizza e le invia a un broker RabbitMQ usando pika. Il codice simile a questo: def main(): conn_params = pika.ConnectionP