问题标签 [consumer]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
1304 浏览

multithreading - Camel file consumer template - threads remaining alive

I have a problem very similar to http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.html.

How do you kill Camel locked threads on different endpoints? I tried to remove endpoints and stop ConsumerTemplate after setting doneUoW, but those didn't work.

0 投票
1 回答
521 浏览

c# - c# web服务消费报错

我正在尝试使用 .NET C# 项目中的以下 WSDL 来使用 Web 服务。

我添加了网络参考等并尝试调用该方法(getPatients),但它总是返回一个错误:

我认为我的代码没问题(与我之前成功使用过的一样)但我一定做错了什么......

有没有人有任何想法?

谢谢

WSDL:

0 投票
2 回答
39861 浏览

javascript - 如何在 Javascript 中实现安全的 OAuth2 消费?

我正在用 PHP 设计一个将使用 OAuth2.0 的 API。我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序。我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的。前端需要与服务器代码通信,而服务器代码又直接与 API 通信。但是,在研究 OAuth2 时,似乎用户代理流程旨在帮助解决这种情况。

我需要帮助的是在 javascript 中实现 OAuth2 用户代理流程(特别是 AngularJS,如果可能的话,因为这是我在前端使用的)。我还没有找到任何可以做到这一点的示例或教程。我真的不知道从哪里开始,也不想通读整个 OAuth2 规范,至少没有看到我将要做什么的例子。因此,任何示例、教程、链接等都将不胜感激。

0 投票
2 回答
1594 浏览

apache-flex - Flex BlazeDS 消费者未订阅

我的 flex 前端使用 BlazeDS/Tomcat 来收集实时数据。
我在标准流媒体 amf 频道上使用普通消费者。

此设置在所有设置中都可以正常工作,但以下设置除外。可见的差异是:

  • Windows 2008 服务器与 Linux 或更旧的 Windows
  • Java 1.7.0 与 1.6.0
  • Tomcat 7.0 与 6.0

症状是consumer.subscribed从未设置为true,尽管调用了consumer.subscribe()并在服务器端看到:

我检查了所有日志(catalina、stdout 和 stderr),但没有任何明显的线索说明出了什么问题。再一次,这个完全相同的设置适用于所有其他情况有

什么想法吗?

0 投票
2 回答
8551 浏览

jms - JMS - 一个队列和多个接收者(消费者)

我有一个第三方发布的 JMS 队列。我想在不同的机器上设置多个消费者,只有一台特定机器的消费者,确认该队列上的消息。简而言之,如果特定机器的消费者没有收到消息,则不应从队列中删除该消息。这是可以实现的吗?

0 投票
3 回答
4826 浏览

consumer - LMAX Disruptor模式中消费者(eventProcessor)慢问题的解决方案

在使用中断器时,可能会有一个或多个消费者落后,并且由于消费者速度慢,整个应用程序都会受到影响。

请记住,每个生产者(发布者)和消费者(事件处理器)都在一个线程上运行,那么解决消费者缓慢问题的方法是什么?

我们可以在单个消费者上使用多个线程吗?如果没有,有什么更好的选择?

0 投票
0 回答
294 浏览

java - 服务器使用者的 java rabbitmq 超时

我正在使用 java 和 rabittmq 进行 RPC 实现。

我希望能够通过超时停止消费者,这意味着在消费者处理的超时结束后,我希望消息向客户端发送响应消息以通知消费者无法处理请求.

例如,如果我的消费者由于某种原因挂起,那么超时将通知并向客户端发送错误消息。

0 投票
2 回答
939 浏览

c++ - 带有生产者/消费者模型的文件复制工具

所以我正在查看我的下一个学校作业,我很困惑。我想我会向专家寻求一些指导。我严重缺乏同步方面的知识,而且我对它所指的“mcopyfile”任务也没有那么热情。可怕的可能是一个好词。如果我能就如何解决这个问题获得一些指导,将不胜感激。不是找人来做我的任务,只需要有人给我指出正确的方向。婴儿步骤。

基于您在 Lab 2 中创建的多线程文件复制工具(mcopyfile),现在请使用工作池(Producer-Consumer 模型)实现,该实现使用固定数量的线程来处理负载(无论在要复制的目录)。您的程序应创建 1 个文件复制生产者线程和多个文件复制消费者线程(此数字取自命令行参数)。文件复制生产者线程将在有界大小的缓冲区结构中生成(源和目标)文件描述符列表。每次生产者访问缓冲区时,它将写入一个(源,目标)文件条目(每次访问)。并且所有的文件复制消费者线程都会从这个缓冲区中读取,执行实际的文件复制任务,并删除相应的文件条目(每个消费者每次都会消费一个条目)。生产者和消费者线程都会向标准输出写入一条消息,给出文件名和完成状态(例如,对于生产者:“正在完成将文件 1 放入缓冲区”,对于消费者:“正在完成将文件 1 复制到……”)。

0 投票
2 回答
1492 浏览

c# - BlockingCollection 多个消费者

我有以下代码,其中包含一个生产者线程和多个消费者线程。你知道多个消费者是否是线程安全的。例如,线程 1 是否有可能正在消耗,而线程 2 是否并行消耗并更改线程 1 中使用的项目的值?

提前致谢

0 投票
1 回答
1644 浏览

rabbitmq - 按需使用 RabbitMQ 消费者?

我希望消费者每次收到消息时都执行一些操作。消费者必须 24/7 全天候“监听”队列,还是只能在收到适当消息时运行?