cloudamqp

    10热度

    1回答

    我在Heroku上运行Flask应用程序(在免费层),并在使用apply_async调度任务时遇到一些麻烦。如果我安排两个以上的任务,我弄了半天堆栈跟踪不同之处: AccessRefused(403,U“ACCESS_REFUSED - 访问交流‘celeryresults’在虚拟主机‘rthtwchf’拒绝了用户rthtwchf'”, (40,10),'Exchange.declare') 奇怪

    1热度

    1回答

    当使用“指定的端点没有一个是可达的” MT服务总线的初始化代码如下: var messageQueueUri = ConfigurationManager.AppSettings["messageQueueUri"]; messageQueueUri = messageQueueUri.Replace("amqp://", "rabbitmq://"); var bus = ServiceB

    4热度

    2回答

    我有一个我已经部署到Heroku的Django应用程序。这个应用程序使用Celery进行消息排队,并且我已经在本地使用RabbitMQ在没有事件的情况下运行它。 不幸的是,当我去部署这个宝贝到Heroku时,我发现RabbitMQ插件不可用,我不得不使用CloudAMQP。 CloudAMQP和Heroku的文档让我相信我可以使用Celery(尽管他们推荐Pika),但是当我尝试部署时,我的调度程

    -1热度

    1回答

    是否有可能通过CloudAMQP从其他云解决方案(如Appfog)向rabbitmq服务发布消息并从互联网(不在云内)使用它们?

    1热度

    1回答

    当您订阅独占队列(一次只允许一个使用者)时,node-amqp在超额订阅队列时引发异常(已经有消费者)。 我试过使用.on(“error”,cb)语法。 我试过错误域(节点0.10.0) 的try/catch显然没有奏效 这里是我的订阅行,但它没有什么特别的: queue.subscribe({ack: true, prefetchCount: 1, exclusive: exclusive},

    5热度

    2回答

    研究在AppHarbor上构建在MVC4上运行的Web应用程序。为了提高响应能力和性能,通过在消息队列中放置消息来处理稍长的运行任务(通常是生成/发送电子邮件,调整图像大小,支付交易处理等)。 还会有一个或多个工作人员在外面的某个地方将消息出队并处理任何需要处理的结果。中央排队机制将是RabbitMQ,特别是通过AppHarbor提供的托管的CloudAMQP服务。理论上,这种架构可以通过增加更多

    1热度

    1回答

    使其工作后: AppHarbor MassTransit CloudAMQP throws Exception None of the specified endpoints were reachable 现在我在CloudAMQP管理看,我有2个连接constanly消费1,9kB/s和1,4千字节/秒至极会吹我的30 Mb快速 有什么办法可以解决这个问题吗?