message-queue
Here are 569 public repositories matching this topic...
Hi folks, sory about my bad english.
I'm trying get up nsq services at containerum, at containerum the public port to services and container are random. With nsqlookupd and nsqadmin it's easy not a big trouble.
But when we try to run nsqd it's registrer ther right broadcast url but the follow ports that nsqd register is that expose in container and not the service port random assigned with the
See nats-io/nats-server#944. I spent a couple of hours debugging this issue and believe that it probably should be documented in README (if I've understood things correctly).
We use http_server
as input and http_client
as one of outputs (for a part of message batch). In case when there is some error coming from http_client
, benthos
starts to retry this error message indefinitely (#415). However most significant, is that it stops accepting other, normal messages.
Here is the log when I first try to send message which causes http_client
to get 500 error, and
Prometheus能提供图片吗?
我看到可以通过Prometheus搭建监控环境,如果有图文,更容易理解.
In commit: celery/kombu@5780f1e
support for queues already defined in Amazon SQS was added.
However, simply by following the instructions at https://docs.celeryproject.org/en/latest/getting-started/brokers/sqs.html and Getting Started page, I must say that I'm still not able to process any message (it's not an issue with credentials or
-
Updated
May 21, 2020 - Go
When the queue workers are restarted (using supervisor), all delayed messages are instantly triggered, regardless of the remaining delay.
This happens when using either rabbitmq_dlx
or rabbitmq_delay_plugin
delay strategy.
Implemented via laravel-queue with amqp+rabbitmq dsn.
-
Updated
Aug 25, 2018 - Go
-
Updated
Apr 28, 2020 - C#
-
Updated
May 16, 2020 - Shell
-
Updated
Apr 7, 2019
-
Updated
Mar 25, 2020 - Clojure
-
Updated
Jun 11, 2018 - C
-
Updated
Dec 18, 2019 - Java
-
Updated
Dec 18, 2018 - Go
-
Updated
May 24, 2020 - Go
统一调整在线文档里注意&注解等的格式
The operator should deploy a replica set instead of single pods as it's a bad practice to run individual pods in Kubernetes, even singleton pods.
Ref: https://kubernetes.io/docs/concepts/workloads/pods/pod-overview/#working-with-pods
-
Updated
May 20, 2020 - Go
-
Updated
May 25, 2020 - Go
-
Updated
Apr 26, 2020 - Java
-
Updated
May 4, 2020 - C++
-
Updated
Sep 24, 2017 - Go
-
Updated
Mar 15, 2018 - Go
-
Updated
May 8, 2020 - Java
We're currently having issues with some of our builds that still rely on fairly old versions of akka-rabbitmq
sbt.ResolveException: unresolved dependency: com.thenewmotion.akka#akka-rabbitmq_2.11;2.3: not found
even though we have the resolver configured to use the newmotion Nexus in our build.sbt
s:
resolvers += "New Motion Repository" at "http://nexus.thenewmotion.com/conten
-
Updated
Jan 23, 2019 - Scala
Improve this page
Add a description, image, and links to the message-queue topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the message-queue topic, visit your repo's landing page and select "manage topics."
英雄招募
成为 Doocs 项目维护者
本项目 advanced-java,包括 Doocs 开源组织下的所有项目,都欢迎各位朋友参与完善。
如果你提交的内容有价值,且具备规范性,将有机会提升为项目的维护者,直接参与项目的 review、merge 等维护工作,提交内容时也可以直接
push
到 doocs/advanced-java 主分支 master 下,无须提交 PR 等待 review。目前 advanced-java 只有 [yanglbme](http