腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
视频
沙龙
1
回答
CKafka问题?
1、购买CKafka时的数量是指什么数量? 2、CKafka文档说兼容Kafka接口,是否所有可以访问原生Kafka的第三方工具都可以访问CKafka? 3、CKafka是否支持Kafka streaming接口?
浏览 225
提问于2017-11-22
0
回答
生产者发送消息: Failed to update metadata after 60000 ms?
、
在腾讯云服务器上生产者给Ckafka服务器发送消息报错:org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
浏览 5360
提问于2018-10-10
2
回答
CKafka公网接入是否支持?
、
CKafka公网如何接入? 是否支持? 有相关文档么? [附加信息]
浏览 659
提问于2018-11-07
1
回答
如何删除 CKafka 不再使用的消费组?
、
有个疑问,CKafka 使用了 Kafka 0.10,这个版本的消费组管理似乎是个问题,如何删除不再使用的消费组?你们打了补丁吗?
浏览 1274
提问于2019-07-13
5
回答
可以使用WMI创建MSMQ消息队列(私有队列)吗?
、
我需要在远程机器上创建一个私有消息队列,并且我已经下定决心,我不能以直接的方式使用.NET框架来完成这个任务。我可以在远程计算机上创建公共消息队列,但不能创建私有消息队列。我可以在本地创建消息队列(公共或私有)。 我想知道是否有人知道如何通过WMI访问MSMQ。 编辑:--我看不出使用MSMQ提供程序可以做什么。可能需要使用PSExec登录到远程服务器并执行一些代码。
浏览 1
提问于2008-09-19
得票数 1
回答已采纳
1
回答
ckafka支持Apache Kafka2.0.1版本吗?
、
ckafka支持Apache Kafka2.0.1版本吗?
浏览 334
提问于2019-08-22
1
回答
redis :如何创建多个redis队列/消息代理
Redis是内存数据库和消息代理。 就像我们可以用redis创建多个数据库一样, 所以,就像聪明人一样, 如何在redis中创建多个消息代理/消息队列?
浏览 2
提问于2016-05-08
得票数 0
1
回答
ProcessQueueMessage在WebJob控制台应用程序中的应用
、
、
、
我正在创建一个新的控制台应用程序,我将作为一个WebJob运行在Azure上。当我在Visual中创建新应用程序时,它已经创建了一个Function.cs类,该类包含以下方法,该方法自动从队列中接收消息并对其进行处理。 public static void ProcessQueueMessage([QueueTrigger("queue")] string message, TextWriter log) { log.WriteLine(message); } 我的问题是如何更好地控制队列消息的处理。例如,我希望确保消息被处理和删除。这个方法似乎为我做到了所有这些,但是我
浏览 2
提问于2016-01-28
得票数 1
回答已采纳
2
回答
如何使用MassTransit为Azure中的死信队列创建处理程序?
、
、
、
、
我需要处理死信队列中的消息。我如何为这个创建处理程序?另外,我还需要处理来自错误队列的消息,这些消息也是死信的。
浏览 0
提问于2017-03-29
得票数 0
回答已采纳
1
回答
将Azure队列消息复制到另一个存储帐户
、
、
、
、
我们在存储帐户中创建了一个队列。外部系统正在队列中创建消息。 因此,我需要处理两个环境(例如PROD和Stage)的消息。因此,在这两种环境中都有一个队列触发器可用,但是消息只能在一个队列中使用。 如果我们也将消息复制到另一个队列,队列触发器将在这两个环境中执行。 是否可以将消息从一个队列复制到另一个队列,或者如何完成? 谢谢
浏览 10
提问于2022-01-07
得票数 0
1
回答
RabbitMq交换性能
、
、
、
在性能方面,创建多个交易所更好吗?例如,如果我有多个文件类型,如zip、json、xml、… 最好是创建一个文件交换(主题交换),它接受所有文件并将它们映射到正确的队列中。在这里,我担心的是,如果我得到了许多zip文件,并且在文件交换中积累了很多消息,那么消息处理得比较晚。 或者创建每个文件类型的一个交换(Zip exchange、Json exchange、Xml exchange)。 交换如何处理消息?是只有一个进程处理交换和队列之间的映射,还是多个进程并行执行映射?
浏览 1
提问于2019-01-29
得票数 0
1
回答
AWS SQS:如何使用1 publisher->N接收器?
、
如何在AWS中创建类似于RabbitMQ中的“直接”交换:1消息-> N接收队列。 每个客户端应用程序连接到服务器并创建自己的队列,发布者发送一条消息到exchange (direct+routing密钥)并发送到所有N个队列,然后每个用户读取自己的队列,队列被清空。
浏览 12
提问于2022-02-21
得票数 -1
回答已采纳
1
回答
跨队列的消息排序
、
、
我在我的RabbitMQ设置中有一个场景,我很好奇如何解决这个问题。下图说明了它(为了简洁起见删除了交换和大多数队列): 场景 生产者创建消息A(1),它被顶级使用者接收,开始处理消息。 生产者创建消息A(2),它被最底层的使用者接收(假设两个消费者都在循环交换中)。 底层使用者发布消息B(2),该消息被放入消息B使用者的队列中 低速度的顶级消费者最终完成并发布它的信息B(1)。 问题 如果我们假设B用户不能被幂等,我们如何确保两个B消息的结果都以正确的顺序应用? 我曾想过使用应用于消息A的初始发布的时间戳,让使用者维护最后一次更改的时间戳,在此之前拒绝任何时
浏览 1
提问于2015-04-09
得票数 2
回答已采纳
1
回答
一个进程如何知道另一个进程创建的队列的消息队列描述符?
、
、
POSIX消息队列可以由mq_open()创建,它返回mqd_t形式的消息队列描述符。如果其他进程必须通过mq_notify()或mq_receive()接收消息,它需要消息队列描述符作为参数。 有没有办法使用队列名称来获取消息队列描述符? 如果不是,那么在开始使用消息队列之前,如何将消息队列描述符传递给另一个进程?
浏览 3
提问于2014-11-16
得票数 0
2
回答
Amazon SQS优先级队列
、
是否可以使用Amazon simple queuing服务创建优先级队列? 最初,我找不到关于这个主题的任何东西,这就是为什么我创建了两个队列。一般队列和优先级队列。我正在根据我定义的规则将消息入队到此队列中,但是在将消息出队时出现了混乱。 如何对队列进行长轮询,使我的队列组合表现为单个优先级队列?
浏览 3
提问于2014-03-19
得票数 8
1
回答
使用websphere message broker在队列管理器之间路由消息
、
如何使用WebSphere messages实例在驻留在两个队列管理器中的队列之间路由消息。在创建期间,message实例只能与一个队列管理器关联。因此,我创建了一个MQInputNode并将消息放到特定的源队列中。我的关注点是使用同一个代理实例将此消息路由到驻留在另一个队列管理器中的第二个队列。多么?我使用的是WebSphere Message版本8.0.0.8。还没有进入IIB。
浏览 1
提问于2018-02-08
得票数 1
回答已采纳
1
回答
Azure消息似乎被卡住了
我正在使用Windows Azure服务总线。我创建了一个主题,并使用了一个合作伙伴发送消息的订阅。我注意到的是,“消息计数”保持在1923,并且没有下降。当一条新消息被发送到队列(在本例中为subs )时,它将到达1924年,然后我的服务将轮询该消息,并将其返回到1923年。看起来1923条消息似乎被卡住了,无法检索。 为什么会发生这种情况,以及如何检索这些消息?
浏览 2
提问于2013-03-27
得票数 0
回答已采纳
1
回答
msmq\storage不断填满多播队列
、
、
我想创建一个简单的发布订阅设置,无论订阅者是0、1还是更多订阅者,我的发布者都会持续广播消息,订阅者在需要和阅读最新消息时来来去去。我不希望较旧的消息被订阅者读取。对于ex。如果发布者在线并开始发布,假设它发布了100条消息,而目前没有订阅者,我希望这些消息消失。如果订阅者1上线并发布了第101条消息,这将是订阅者1看到的第一条消息。这似乎是多播msmq的工作方式,但我遇到的问题是,当我的发布者正在运行时,\System32\msmq\storage将很快被4mb文件填满,它们有一些自动递增的名称,在我的例子中通常是r000001a.mq、r000001b.mq或类似的文件。我不知道如何管理这
浏览 2
提问于2017-07-11
得票数 0
1
回答
检查IPC消息队列是否已存在,而不创建它
、
、
、
如何在不创建消息队列的情况下检查消息队列是否存在? 当使用带有O_CREAT | O_EXCL标志的msgget时,如果它存在,调用将失败,返回值为-1,但如果不存在,它将创建一个新的消息队列。有没有什么方法可以检查一下呢?
浏览 0
提问于2016-11-30
得票数 0
3
回答
RabbitMQ内存管理和复制
、
、
、
、
我目前正在评估用于管理队列的RabbitMQ。我想知道RabbitMQ是如何管理内存中的队列项的。 在此发布者/订阅者示例中 是否为每个订阅者(消费者)创建队列?例如,如果我有两个消费者,那么我使用双倍的内存来存储消息吗? 我的印象是,如果我在一个队列上附加了多个worker,那么它将成为一个工作队列,其中每个使用者都会收到不同的消息。 假设我正在为此构建聊天服务器。我需要为每个消费者创建一个队列吗?内存中的每条消息都会乘以连接的用户数吗?或者存储器中只有一条消息,并且每个队列都有指向该消息的指针。 在主题消息的示例中也是如此。 假设我有1kb的消息。那么2个队列是否有2kb的
浏览 1
提问于2012-10-24
得票数 4
3
回答
WCF + MSMQ 4:谁将消息从重试队列移回应用程序队列?
、
、
这是一个简单的问题,但我找不到答案。 假设我的消息被放到重试队列中(谁创建了重试队列?它是WCF还是MSMQ服务?) 5分钟后(这是我的重试延迟),该消息返回到应用程序队列。 问:谁在超时后将消息从重试队列移动到应用程序队列? 奖励问题:延迟是如何被跟踪的?消息是否有“已移动”时间戳和“重试”时间戳?
浏览 5
提问于2012-01-26
得票数 4
回答已采纳
2
回答
RabbitMQ:如何组合任务队列和扇出/路由/主题模型?
我有一个有一个生产者和一些消费者的环境。 生产者创建两种类型的消息: 只需要由一个使用者处理的消息(任何使用者都会这样做)。 需要由所有使用者处理的消息。 如何实施呢? 对于消息类型1,工作队列是合适的模型。 对于消息类型2,扇出/直接/路由/主题是合适的。 但我该如何把它们结合起来呢?
浏览 10
提问于2016-03-20
得票数 3
回答已采纳
1
回答
ckafka?
副本怎么建立 怎么没相关档?
浏览 249
提问于2019-08-05
2
回答
消息队列-多个进程在msgqueue上发送命令
、
、
、
我有一个场景,多个进程(p1、p2等)同时向一个消息队列(Cmd_msg_q)发送一个命令(post)。 并且存在一个接收器进程(R1),其从队列中检索msg并将适当的应答发送回另一msg队列( response_msg_q )上的进程。 如何从接收方进程进行回复,以便将消息发送到该特定进程? (使用Posix消息队列。)在这里,进程A、B或C是动态创建的。最大限制是20个进程,可以发送命令。
浏览 2
提问于2014-04-07
得票数 1
2
回答
如何从队列接收并发布到主题中?
、
、
、
我正在尝试从队列接收消息并将其发布到主题中。我有一个QueueSession实例,但它不能用于创建主题。如果我理解正确的话,QueueSession只用于从一个队列接收消息,并将消息发送到另一个队列。我如何混合它-从队列接收并在单个会话中将其发布到主题中?
浏览 5
提问于2011-03-03
得票数 2
回答已采纳
4
回答
如何确定*USRQ中的最大消息数
它需要创建最大可能大小的*USRQ。根据文档,*USRQ的最大大小是2Gb。创建队列需要指定最大消息大小、队列中消息的初始数量、队列扩展的大小(以消息为单位)和最大展开操作数。消息大小为1024字节。最初的数字是128条消息。队列将扩展128条消息。估计最大可能的消息数- 2Gb / 128字节。然后,我们减去消息的初始数量( 128 ),除以扩展-128的大小。因此,我们得到了最大的扩展数- 16,383。我们将这些参数传递给QUSCRTUQ,然后查看我们得到了什么(调用matqat)。我们看到,设置的最大扩展数(mat_template.Max_Extend)小于请求的扩展数- 15 30
浏览 12
提问于2022-05-10
得票数 2
回答已采纳
1
回答
如何删除消息?
、
、
我有一个队列{QueueName}。我定义了一个消费者和错误消息使用者如下: cfg.ReceiveEndpoint ( queueName: QueueName, e => { e.UseMessageRetry(r => r.Immediate(2));
浏览 0
提问于2020-09-22
得票数 2
回答已采纳
1
回答
如何按组处理来自SQS队列的消息
、
、
、
、
我目前有一个SQS队列来触发lambda函数,但是SQS对在役消息有120 k的限制,这意味着只有120 k的消息可以由lambda使用者处理。大多数情况下都很好。但是假设我有客户机A和B,如果A向队列发送500 k,在此之后B只发送1条消息,B需要等待队列中的所有消息来处理。为每个客户端创建一个队列是没有意义的(至少不是手动的)。例如,我如何能够以循环的方式处理来自客户端的消息,让每个人都有相同的时间来处理他们的任务? 我一直在研究Kinesis数据流,但不太确定这是否能解决我的问题。我是否需要创建一个SNS,将其重定向到一个负责循环消息的lambda到执行相同任务的队列,但这样我就可以避免
浏览 2
提问于2022-03-11
得票数 0
回答已采纳
1
回答
如何检索安慰队列中的所有消息
、
、
我想知道如何检索Solace队列中已经存在的消息。我能够发送和接收从我的机器创建的消息,但是不能接收队列中已经存在的任何消息。我想检索这些消息并将其存储在文本文件中。 我通过在Gradle中集成Solace和用Java编写代码来发送消息。有人能指导我做同样的事吗?
浏览 2
提问于2017-01-25
得票数 0
回答已采纳
1
回答
带Azure服务巴士的Rebus,竞争的消费者和多租户
、
、
、
我一直试图为Azure服务总线设置Rebus,但我发现很难找到适合我的用例的示例,也很难自己构建解决方案。 我有多个生成Message1的实例,每个实例都为特定的客户端运行,但是它们都生成消息类Message1的实例。这些消息需要发送到ASB。接下来,对于每个租户,我有很多竞争的消费者。换句话说,对于每个租户来说,有多个Message1使用者,但是只有一个使用者可以处理这个消息。这使我能够并行计算上的繁重工作。 通常,我会在每个客户的ASB中创建一个队列,从而保证来自不同客户的消息不会被混淆,或者被执行不止一次。然而,Rebus会创建主题,因此启用多个订阅。据我所知,这意味着所有订阅者都将收到
浏览 0
提问于2019-08-29
得票数 4
回答已采纳
4
回答
带有AMQP和RabbitMQ的Spring,具有可选的x死信交换队列。
、
、
、
、
我在RabbitMQ中创建了一个现有队列。可以使用或不使用x-dead-letter-exchange参数来创建它。我正在使用RabbitTemplate在Spring中创建这个队列的使用者。当我声明队列时,我不想指定x-dead-letter-exchange参数。我希望模板能以某种方式找到它本身,或者根本不在乎。我从我的使用者中抛出AmqpRejectAndDontRequeueException来指示坏消息,但是我希望队列的创建者负责决定是否为被拒绝的消息创建一个exchange和队列。 下面是我在Spring中声明队列的bean: @Bean Queue queue() { M
浏览 17
提问于2015-08-11
得票数 11
回答已采纳
1
回答
azure服务总线没有接收所有消息(仅~65%)
、
、
这是我之前能找到的最接近的问题:。 同样的事情也发生在我身上。当我更改主题的名称时,它会再次工作一段时间。然后,服务总线主题再次损坏。只有65-71%的信息到达。也无助于删除子项,也无助于主题。过了一段时间,这个主题的名字似乎被污染了。这真的很糟糕,因为我无法知道什么时候这个话题是腐败的,只是当消息没有到达时,系统就不会像它那样工作了。随机创建一个新名称的新主题似乎是一个非常糟糕的解决方案。 我正在测试它通过一个循环在一个进程,发送消息,然后循环在另一个进程,接收和计数。有了一个新的主题名称,它工作得非常完美。我知道我只有一个订阅监听器,它是一个窥视锁,需要完成消息。 有没有人?我怎么才能解决
浏览 4
提问于2015-10-01
得票数 8
回答已采纳
1
回答
分析驻留在队列RabbitMQ中的消息
、
、
、
我有几个Java客户端使用RabbitMQ默认交换向队列发送消息。 我希望能够分析队列中的消息(如果消息没有明显地被消耗),标识消息的发送方,如果客户端发送的消息太多,那么就绑定一个特殊的队列,以便该客户端向该队列发送消息。 我是RabbitMQ的新手,所以我想知道的是: 是否可以在RabbitMQ中将客户端ID作为头添加? 如何为工作量大的客户端创建特殊队列? 是否可以分析驻留在队列中的消息? 任何帮助都将不胜感激。
浏览 4
提问于2016-07-02
得票数 0
1
回答
DLQ如何在Azure服务总线队列中工作?
我正在学习DLQ如何在Azure service bus queue中工作。也就是说,未使用的消息将在DLQ中。我在消息过期时启用了死字(deadLetteringOnMessageExpiration)。 参考资料: AMR模板: 问题: 如果启用了screenshot)?If ,DLQ是否可用于该队列(如下面的“是的”,我如何处理来自DLQ的消息?(我想我可以在这里看到这样的消息,但不确定接下来会发生什么) 我的目标是使用DLQ创建一个队列,其中可以在某个点处理未处理的消息,实现这一目标的最佳方法是什么。
浏览 3
提问于2022-08-10
得票数 0
回答已采纳
3
回答
如何将消息传递给线程
、
我需要写一种代理服务器,我的设计有点像这样:1.Socket服务器(使用Windows事件选择模型)。程序有一个监听线程监听网络事件。 客户端列表(当前按socketid_list编制索引)。3.套接字服务器接受新的连接,然后为每个客户端创建新的线程。新线程创建到终端目标服务器的套接字连接(需要持久连接)。 我已经编写了套接字服务器,它工作得很好。我的问题是,当新消息从客户端传入时,我如何将此消息传递到相关线程(以便消息可以发送到目标服务器)。 在我的服务器中,我从客户端消息中获取最终目标服务器的地址。我可以从客户端套接字列表中查找客户端套接字。但是我该如何将消息发送到正确的线程呢? 到目前为
浏览 0
提问于2011-09-01
得票数 2
回答已采纳
2
回答
如何删除msgget创建的消息队列
、
我用msgget函数创建了消息队列。下面的代码是它的一小段。 key_t msg_queue_key_id = msgget((key_t)MQ_KEY, IPC_CREAT | IPC_EXCL | 0666); if( msg_queue_key_id == -1 ) { char error_log[MAX_LENGTH]; sprintf(error_log, "failed to create message queue. errno = %d", errno); ERROR_LOGGING(error_log) return 1; }
浏览 5
提问于2015-06-02
得票数 2
2
回答
Azure内向外连接
、
、
、
、
我正在努力连接我的前提应用程序到Azure逻辑应用程序。这里的问题是,我的网络不接受任何入站呼叫,但无论如何不限于打出站电话,所以我必须从内到外打开连接。 在当前的状态下,我有一个逻辑应用程序,它最终应该对我的前提托管的web进行HTTP调用,但基于上述原因,这是一个不可行的解决方案。 我的想法之一是创建Azure SignalR服务,从网络内部连接到它,然后等待消息。要做到这一点,我还必须创建代理Azure函数,以便从Logic获得请求并将其广播给SignalR --我对Azure不是很熟练,但这在我看来并不合适。 其他的想法是使用Azure消息队列,但是接下来我必须按计划运行来读取消息,其
浏览 5
提问于2022-08-22
得票数 1
回答已采纳
1
回答
使用RabbitMQ Java将消息发送到特定的SpringIntegration队列
、
、
、
我正在开发一个使用版本2.0.4.RELEASE和版本3.7.7的Java应用程序。该应用程序将来自RabbitMQ的所有消息缓存在数据库中,并且在RabbitMQ中创建新队列时必须重新发送。目前,我成功地使用和队列名称捕获了队列创建。我使用将消息发送回RabbitMQ。 OutFlow public IntegrationFlow outFlow(AmqpTemplate amqpTemplate) { return IntegrationFlows.from(outputChannel()) .handle(Amqp.outboundAdapter(amqp
浏览 0
提问于2018-08-20
得票数 8
1
回答
websphere 7.0创建消息引擎
、
、
在WebSphere 7.0中的总线上创建消息传递引擎的过程是什么?我有一条总线,但没有创建消息的选项,也不知道如何创建它或让它自动生成。
浏览 1
提问于2012-12-01
得票数 0
回答已采纳
2
回答
是否可以在不创建C++窗口的情况下创建消息循环?
、
、
、
我使用了一些蓝牙库,对于一些蓝牙回调,使用Windows消息循环是必要的。但根据我的要求,我需要创建一个普通的C++程序而不需要任何图形用户界面。有没有可能在没有窗口的情况下创建消息循环? main(){ Discovery disc; disc.startDiscovery(); } Discovery::startDiscovery(){ __hook(&CallBackFromLibrary::OnDiscoveryStarted, &obj, &Discovery::OnDiscoveryStarted); __hook(&C
浏览 1
提问于2018-08-21
得票数 2
回答已采纳
1
回答
空MSMQ队列
、
、
、
我正在尝试从MSMQ队列中获取消息,当我在队列中包含消息并执行线程时,就会出现问题,在运行以下代码时,它正在清除队列: queue = new MessageQueue(queueName); 这意味着我正在覆盖具有itens的队列,我的问题是:如何才能获得先前创建的队列? 编辑: 我在找一种像GetPrivateQueueByLabel这样的方法,但我没有找到!
浏览 0
提问于2014-03-05
得票数 1
1
回答
从Azure函数未添加到Azurite队列的消息
、
、
在下面的文档之后,我尝试创建一个azure函数,它将消息添加到队列中。 代码被触发并执行时没有出现错误,但在Azure Storage队列中看不到任何消息。 我将Azurite存储帐户添加到本地存储资源管理器中。但是队列没有被创建,消息也没有被添加。 AzureWebJobsStorage设置为"UseDevelopmentStorage=true“。 如何在存储资源管理器中对此进行本地测试?这些步骤是什么,我需要什么?
浏览 8
提问于2021-12-21
得票数 0
回答已采纳
1
回答
如何使用ActiveMq和C#创建持久队列使用者?
、
、
、
我对activemq很陌生,并试图将其用作C#.net应用程序中的消息传递服务。我能够为持久主题创建发布服务器/订阅服务器。但是对于我的应用程序需求,我需要使用持久队列。我没有看到在Apache.NMS api中有任何可用于持久队列的创建使用者方法。那么,如何使用持久队列创建pub/sub呢?
浏览 3
提问于2013-10-15
得票数 0
回答已采纳
1
回答
使用路由密钥使用DirectExchange消息并在春季启动时进行交换
、
我试图使用来自退出队列的消息,该队列类型为Direct (在exchange和路由密钥的帮助下创建)。我只有交换名、和路由密钥、和,而没有队列名。虽然支持普通Java,但是没有地方可以找到Spring。 @RabbitListener @RabbitHandler public void consumeMessage(Object message) { LOGGER.debug("Message Consumed.... : {}", message.toString()); } 如何使用具有路由密钥和交换名称的消息,而不是@Rabbit
浏览 0
提问于2019-09-12
得票数 1
回答已采纳
3
回答
在不相关的进程之间使用消息队列
、
、
我正在尝试使用消息队列在Linux中两个不相关的进程之间进行通信。我知道使用公共键值将允许我们在两个不相关的进程中打开相同的消息队列。但问题是,有时对应于消息队列的键值可能已被某些系统实用程序使用。因此,我使用IPC_CREAT | IPC_EXEL标志来确保强制创建新的消息队列。 如果msgget()返回错误,我会递增键值并重新尝试创建一个新的消息队列,直到成功为止。现在,问题是我如何将这个成功的键值传递给另一个想要在同一消息队列上操作的无关进程。 我是不是遗漏了什么?以前有没有人遇到过类似的问题?
浏览 0
提问于2009-11-06
得票数 2
1
回答
通过接收到的C# - UnitTest消息
、
、
我是的新手。 在我们的projet中,我实现了从IBM读取消息的代码。 我已经安装了IBM WebSphere客户端,并且我正在使用、IBM.XMS、和的引用来创建连接并从队列读取消息。 XMSFactoryFactory xff = XMSFactoryFactory.GetInstance(XMSC.CT_WMQ); IConnectionFactory cf = xff.CreateConnectionFactory(); 我已经设置了必要的属性,如HostName、Channel、Port、QueueManager。 我创建了MessageListener: MessageListen
浏览 0
提问于2016-06-28
得票数 3
1
回答
Spring集成-在交付后保留消息
、
、
、
1)我有兴趣了解是否有可能保留使用Spring Integration交付的消息。我已经在使用mongo持久化存储(ConfigurableMongoDbMessageStore),但是只有失败的消息保留在集合中。理想情况下,我希望所有消息都保留列出并重试的功能。 我会使用"status“或类似的字段来标识排队、成功或失败的消息。不确定这个字段是否已经存在,但我猜一定有类似的东西存在。 2)此外,当消息失败并被替换时,消息中有更多的数据。这些数据是序列化的,所以我很好奇如何提取原始消息并重试。 3)目标是在webapp中创建一个接口,所有排队的消息都可以在其中看到并重试。不仅是失败的消
浏览 1
提问于2014-07-28
得票数 0
1
回答
以编程方式向MessageQueue添加消息
、
我有一个旧的‘非事务性’队列(MessageQueue),其中可能包含消息。 现在,通过编程,我想: 1。从旧队列中获取消息->这是完成的2。创建新的‘事务性’队列-->这也是3。将消息从旧消息队列复制到新队列->如何做到这一点? 4。删除旧队列。->我可以调用Close(),然后对旧队列进行Dispose()处理,我可以使用MessageQueue.Delete()删除队列。,对吗?在删除队列之前,是否有必要调用Close和Dispose? 请用粗体字母指导我的问题。
浏览 2
提问于2011-01-17
得票数 0
回答已采纳
1
回答
RabbitMQ / AMQP:多个队列,单个使用者
、
、
我想要创建一个使用者,它处理来自多个变量数目的消息,这些消息是动态连接或断开连接的。 我需要的是每个消费者首先优先处理每个源的N条消息。然后运行多个消费者来提高速度。 我一直在阅读、和以及许多其他文档的文档,而没有确定如何实现这一点。而且我也做了一些没有运气的测试。 有人能指点我怎么做或者在哪里读到吗? -编辑-- QueueA-A3-A2-A1-┐ QueueB QueueC-┘ 所期望的效果是每个使用者获得每个队列的第一条消息。例如: A1、B1、C1、A2、B2、C2、A3、B3、C3等等。如果创建了一个新队列(QueueD),消费者将以同样的方式开始接收来自它的消息。 提前感谢
浏览 1
提问于2018-05-02
得票数 4
1
回答
如何访问线程- Java中的队列
、
、
、
我在线程中创建一个队列,它将一直运行。这个线程正在维护这个队列,并在一定时间内从队列中获取消息。我的问题是如何在另一个类或servlet中访问这个队列??并将消息插入到此队列中。让这个队列保持静态?我需要考虑多线程吗?
浏览 3
提问于2014-09-29
得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
java实现消息队列以及延迟消息(队列DelayQueue)
消息队列是如何保证高可用的
消息队列-架构为什么需要用消息队列
消息队列-延时消息实现
全面理解Handler-1:理解消息队列,手写消息队列
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券