首页 文章
  • 2 votes
     answers
     views

    查看队列使用者时出错

    导航到Active MQ管理控制台然后:队列 - >活动消费者(一个's I' m尝试名称前缀为私有:)我得到: 处理此请求时发生异常,请检查日志以获取更多信息! 从日志中提取: ==> activemq.log <== 2017-06-29 08:22:06,564 |警告| | org.eclipse.jetty.servlet.ServletHandler | qtp...
  • 6 votes
     answers
     views

    芹菜如何运作?

    我最近开始致力于分布式计算,以提高计算速度 . 我选择了Celery . 但是,我对某些术语不太熟悉 . 所以,我有几个相关的问题 . 来自Celery docs: 什么是任务队列? ...芹菜通过消息进行通信,通常使用经纪人在客户和 Worker 之间进行调解 . 为了启动任务,客户端向队列添加消息,然后代理将该消息传递给工作者 . 什么是客户(这里)?什么是经纪人?为什么通过经纪人传递消息...
  • 1 votes
     answers
     views

    处理经纪人在 Kafka

    我在异步模式下使用kafka生成器,但是当所有代理都关闭时,它就像sync一样,等到metadata.fetch.timeout.ms到期,对我来说是60秒 . 我的第一个问题是,这是正常行为还是我做错了什么? 由于我的逻辑中的事务应该在最长100毫秒内完成,因此这个超时值对我来说是一个非常大的延迟 . 也许将metadata.fetch.timeout.ms设置为10毫秒可能会解决我的问题,但我...
  • 0 votes
     answers
     views

    ActiveMQ:缓慢处理消费者

    关于ActiveMQ:我有一个场景,我有一个 生产环境 者向消费者发送小(大约10KB)文件 . 尽管文件很小,但消费者需要大约10秒钟来分析它们并将结果返回给 生产环境 者 . 我研究了很多,但我仍然无法找到以下问题的答案: 如何让代理(完全)将文件存储在队列中? 我应该使用ObjectMessage(因为文件很小)还是blob消息? 由于消费者处理速度慢,我应该降低prefetch...
  • 4 votes
     answers
     views

    如何在WSO2 ESB中调解纯TCP消息

    我有一个应用程序(比方说,TcpApp)发送纯TCP消息(即没有SOAP,没有信封......只是原始字符串甚至是字节) . 我需要连接ESB以通过特定端口(例如,3333)监听这些消息,并进行一些调解(现在,只做日志记录就足够了) . 我认为从TcpApp创建ActiveMQ队列然后在ESB中从JMS创建代理服务(而不是直接将ESB连接到TcpApp)是个好主意 . 我阅读了几个示例和答案,但始...
  • 2 votes
     answers
     views

    如何在故障转移方案中通过Active-MQ Broker传递相同的Java应用程序?

    有两个名为 GC1 和 GC2 的客户端使用主题“ GC1Alive " & " GC2Alive ”通过ActiveMQ相互通信 . 他们只是通过使用这些主题发送心跳 . Purpose 两个GC之间通信的目的是当 GC1 发生故障时, GC2 应该在故障转移场景中替换 GC1's 位置 . 故障转移方案由ActiveMQ自行处理,其中包含以下URL: URL =...
  • 1 votes
     answers
     views

    Fiware cepheus cep订阅上下文经纪人问题

    我想让cepheus cep接收来自上下文代理而不是cepheus代理的传入事件但是当我上传config.json文件时我检查了cepheus-cep日志,发现它没有订阅上下文中的实体经纪人,因为没有订阅启动 . 此外,当我尝试代表cepheus-cep手动发送订阅并开始向上下文代理中的实体发送消息时,Cepheus-cep将通知仅仅视为发布请求而不是作为应该处理的事件的消息并显示一条消息,指出“...
  • 2 votes
     answers
     views

    Fiware Cepheus更新上下文代理失败,错误为“不支持的媒体类型”

    因为使用fiware cephues我按照文件我发送的配送文件 { "host":"http://localhost:8080", "in":[ { "id":"Lab.*", "type":"Lab", ...
  • 1 votes
     answers
     views

    Fiware Orion上下文代理订阅通知问题

    我正在使用orion上下文代理GE映像orion-psb-image-R5.4版本1.7.0并且我在其中注册了一个设备实体,然后我在我的raspberry pi简单python服务器脚本中实现,该脚本侦听任何传入的消息并打印它在Pi的日志上 . 然后我向上下文代理发送了一条订阅消息,让我的raspberry pi订阅上下文代理中的相应实体 . 问题在于,每当我更新上下文代理中实体的条件属性时,它们...
  • 1 votes
     answers
     views

    FIWARE Orion:订阅的servicePath

    我正在尝试创建订阅,以通知我一些传感器值的变化 . curl broker.waziup.io/v2/subscriptions -s -S --header 'Content-Type: application/json' --header 'Accept: application/json' --header 'Fiware-Service:watersense' --header 'Fiwa...
  • 2 votes
     answers
     views

    Fiware Orion上下文代理和iotagentUL命令问题

    我是Fiware用户,我在 Cloud 上的不同虚拟机中部署了猎户座上下文代理GE,cepheus GE和iotagent-ul实例 . 我在iot代理中注册了一个设备,在注册请求中指定了一个命令属性,并在注册过程中在上下文代理中创建了相应的实体 . 现在,当我使用其属性和命令属性及其名称和类型注册设备时,设备在iot代理上注册,并且其实体也在上下文代理中创建 . 但奇怪的是,命令属性只被转换为其...
  • 0 votes
     answers
     views

    编写关于WSO2 CEP的自定义代理

    我有关于Custom Broker的问题 . 我使用this博客文章中的示例尝试了Custom Broker .我从“https://dl.dropbox.com/u/17922825/blog/cep-ext-broker.zip”下载了样本模板Custom Broker,我在 CEP_HOME/repository/components/lib 中放了 cep-broker-1.0-SNAPS...
  • 0 votes
     answers
     views

    在WSO2 CEP上使用JMS编写自定义代理

    我想在WSO2 CEP上使用JMS创建自定义代理 . 我创建了两个类,NewJMSBrokerType和NewJMSBrokerTypeFactory . 我为NewJMSBrokerType扩展了JMSBrokerType,并为NewJMSBrokerTypeFactor实现了JMSBrokerTypeFactory . 我把 broker.xml 放在 CEP_HOME/repository/...
  • 70 votes
     answers
     views

    动物园管理员是 Kafka 必须的吗?

    在Kafka中,我想只使用一个代理,单个主题和一个具有一个 生产环境 者和多个消费者的分区(每个消费者从代理获得自己的数据副本) . 鉴于此,我不想要使用Zookeeper的开销;我不能只使用经纪人吗?为什么动物园管理员必须?

热门问题