问题标签 [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.
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.
c# - c# web服务消费报错
我正在尝试使用 .NET C# 项目中的以下 WSDL 来使用 Web 服务。
我添加了网络参考等并尝试调用该方法(getPatients),但它总是返回一个错误:
我认为我的代码没问题(与我之前成功使用过的一样)但我一定做错了什么......
有没有人有任何想法?
谢谢
WSDL:
javascript - 如何在 Javascript 中实现安全的 OAuth2 消费?
我正在用 PHP 设计一个将使用 OAuth2.0 的 API。我的最终目标是用 javascript(使用 AngularJS)构建一个直接访问这个 API 的前端应用程序。我知道传统上没有办法保护 javascript 中的事务,因此直接访问 API 是不可行的。前端需要与服务器代码通信,而服务器代码又直接与 API 通信。但是,在研究 OAuth2 时,似乎用户代理流程旨在帮助解决这种情况。
我需要帮助的是在 javascript 中实现 OAuth2 用户代理流程(特别是 AngularJS,如果可能的话,因为这是我在前端使用的)。我还没有找到任何可以做到这一点的示例或教程。我真的不知道从哪里开始,也不想通读整个 OAuth2 规范,至少没有看到我将要做什么的例子。因此,任何示例、教程、链接等都将不胜感激。
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),但没有任何明显的线索说明出了什么问题。再一次,这个完全相同的设置适用于所有其他情况有
什么想法吗?
jms - JMS - 一个队列和多个接收者(消费者)
我有一个第三方发布的 JMS 队列。我想在不同的机器上设置多个消费者,只有一台特定机器的消费者,确认该队列上的消息。简而言之,如果特定机器的消费者没有收到消息,则不应从队列中删除该消息。这是可以实现的吗?
consumer - LMAX Disruptor模式中消费者(eventProcessor)慢问题的解决方案
在使用中断器时,可能会有一个或多个消费者落后,并且由于消费者速度慢,整个应用程序都会受到影响。
请记住,每个生产者(发布者)和消费者(事件处理器)都在一个线程上运行,那么解决消费者缓慢问题的方法是什么?
我们可以在单个消费者上使用多个线程吗?如果没有,有什么更好的选择?
java - 服务器使用者的 java rabbitmq 超时
我正在使用 java 和 rabittmq 进行 RPC 实现。
我希望能够通过超时停止消费者,这意味着在消费者处理的超时结束后,我希望消息向客户端发送响应消息以通知消费者无法处理请求.
例如,如果我的消费者由于某种原因挂起,那么超时将通知并向客户端发送错误消息。
c++ - 带有生产者/消费者模型的文件复制工具
所以我正在查看我的下一个学校作业,我很困惑。我想我会向专家寻求一些指导。我严重缺乏同步方面的知识,而且我对它所指的“mcopyfile”任务也没有那么热情。可怕的可能是一个好词。如果我能就如何解决这个问题获得一些指导,将不胜感激。不是找人来做我的任务,只需要有人给我指出正确的方向。婴儿步骤。
基于您在 Lab 2 中创建的多线程文件复制工具(mcopyfile),现在请使用工作池(Producer-Consumer 模型)实现,该实现使用固定数量的线程来处理负载(无论在要复制的目录)。您的程序应创建 1 个文件复制生产者线程和多个文件复制消费者线程(此数字取自命令行参数)。文件复制生产者线程将在有界大小的缓冲区结构中生成(源和目标)文件描述符列表。每次生产者访问缓冲区时,它将写入一个(源,目标)文件条目(每次访问)。并且所有的文件复制消费者线程都会从这个缓冲区中读取,执行实际的文件复制任务,并删除相应的文件条目(每个消费者每次都会消费一个条目)。生产者和消费者线程都会向标准输出写入一条消息,给出文件名和完成状态(例如,对于生产者:“正在完成将文件 1 放入缓冲区”,对于消费者:“正在完成将文件 1 复制到……”)。
c# - BlockingCollection 多个消费者
我有以下代码,其中包含一个生产者线程和多个消费者线程。你知道多个消费者是否是线程安全的。例如,线程 1 是否有可能正在消耗,而线程 2 是否并行消耗并更改线程 1 中使用的项目的值?
提前致谢
rabbitmq - 按需使用 RabbitMQ 消费者?
我希望消费者每次收到消息时都执行一些操作。消费者必须 24/7 全天候“监听”队列,还是只能在收到适当消息时运行?