在目标队列中将消息入队时发生异常。错误: 15404，状态
错误代码15404是指在消息队列中将消息入队时发生了异常。这个错误通常表示目标队列无法接受消息或者消息入队的过程中发生了错误。
解决这个问题的方法可以包括以下几个方面：
- 检查目标队列的状态：确认目标队列是否正常运行，并且有足够的资源来接受新的消息。可以通过查看队列的状态信息或者使用相关的管理工具来进行检查。
- 检查消息入队的参数：确认消息入队的参数是否正确。包括消息的格式、大小、优先级等。如果参数不正确，可能会导致消息入队失败。
- 检查网络连接：确认消息入队的过程中网络连接是否正常。如果网络连接不稳定或者中断，可能会导致消息入队失败。
- 检查权限设置：确认当前用户是否具有将消息入队的权限。如果权限设置不正确，可能会导致消息入队失败。
- 检查错误日志：查看错误日志，了解具体的错误信息和错误原因。根据错误信息来进行相应的处理和调整。
对于这个问题，腾讯云提供了消息队列产品，可以用来实现消息的异步通信和解耦。腾讯云消息队列 CMQ（Cloud Message Queue）是一种分布式消息中间件，具有高可用、高可靠、高性能、可弹性伸缩等特点。您可以通过腾讯云消息队列 CMQ来实现消息的入队和出队操作。
更多关于腾讯云消息队列 CMQ的信息，请参考腾讯云官方文档：腾讯云消息队列 CMQ
相关·内容
我使用Spring的JMS (v.3.1.2) listener-container，它的JMS connectionFactory来自WebSphere 7的JNDI设置。应用程序正确地处理消息(put/get)，但是MQ队列管理器中设置的备份设置似乎不起作用。
要使消息消耗失败，我对setRollbackOnly()使用spring事务，并且它确实增加了属性“退出计数”，因为我可以看到，随着指向远程队列的"WebSphere MQ资源管理器“，这个数量在增加。
通过阅读一些IBM文档，它描述了IBM客户端需要将坏消息移动到备份队列中。Spring的listener-containe
浏览 2提问于2014-10-03得票数 3
回答已采纳
1回答
我在rebus实现中使用MSMQ传输。下面是启动rebus服务的代码：
BuiltinHandlerActivator handlerActivator;
this.handlerActivator.Handle<TransportMessage>
(this.HandleTransportMessageAsync);
var bus = Configure.With(this.handlerActivator)
.Transport(t => t.UseMsmq(this.SenderName))
.Routing(r
浏览 4提问于2017-03-23得票数 1
回答已采纳
这是在集群环境中。队列管理器在群集中丢失了其标识，并且无法连接到其他服务器。所有到存储库和其他通道的通道都在重新尝试状态。
CPU的使用在此服务器中是最佳的。这是一个UNIX盒。
当我检查下面的日志时，
AMQ9532:程序不能设置队列属性。
说明:在队列管理器'SYSTEM.CLUSTER.TRANSMIT.QUEUE‘上设置队列'QMGR.SERVER6A’属性的尝试失败，原因是代码2102。操作:确保队列可用，并重试操作。- amqrmssa.c : 690
AMQ9999:频道节目异常结束。
说明:频道节目“Channel.Coord00”异常结束。操作:查看错误文件
浏览 8提问于2011-03-07得票数 4
我是NServcie总线的新手，我试图实现消息的发布和订阅，.This是我遇到的错误
启动端点时出现异常时，错误已被记录。原因:找不到目标队列“我的网关”。您可能在配置(NServiceBus.Unicast.Transport.CompletionMessage)的MessageEndpointMappings of UnicastBusConfig部分中错误配置了此类消息UnicastBusConfig的目的地，这也可能是给定队列尚未创建或已被删除的情况。
这是我在app config中使用的配置。
<MsmqTransportConfig
浏览 2提问于2010-08-10得票数 5
回答已采纳
仅当我使用Azure门户编辑器时，才会出现此问题。如果我从Visual Studio上传，这个问题不会发生，但我不能从Visual Studio上传，因为有一个无关的bug：。
在使用Azure Portal Editor时，如果我从C#抛出异常或从JavaScript使用context.done(error)，则Application Insights会显示发生错误，但消息只是被使用。消息不会重试，也不会进入有毒队列。
从Visual Studio上传时，C#的相同代码会正确重试，所以我认为这是一个配置问题。我已经尝试将Azure Portal Editor版本的host.json文件修改为
浏览 10提问于2018-07-19得票数 0
回答已采纳
2回答
我目前正在建造两个窗口服务：
第一个接收来自internet连接的消息并将这些消息插入数据库。这是为了快速和稳定的，不做任何其他的处理，第二个执行一个批处理过程，与任何新的消息，这些消息是自上次运行以来到达的。
我正在尝试一种方法，以便第二个服务只在准备处理新消息时才运行其批处理过程，如果第二个服务错误，则第一个服务将继续运行，反之亦然。目前，它每5秒使用一个循环。
我目前正在考虑使用消息队列，其中第一个服务只在队列为空时才写入消息，第二个服务将查看队列是否包含任何消息，如果没有进入异步等待，直到消息到达，然后删除消息并运行。因此，使用队列不是真正作为队列，而是作为一个二进制开关，当它的状态发
浏览 1提问于2009-01-28得票数 1
回答已采纳
当异常发生时，有没有记录消息内容的方法？
我查看了各种日志扩展，但它们只记录CorrelationId。并且消息内容不可用。
MessageContext中有一个CurrentMessge属性，但在时间记录器写入异常时该属性不可用。
我尝试处理PoisonMessage事件，它允许我记录消息内容。
public static void OnPoisonMessage(IBus bus, ReceivedTransportMessage receivedTransportMessage, Rebus.Bus.PoisonMessageInfo poisonMessageInfo) {
var
浏览 5提问于2014-10-15得票数 1
我正在开始使用NServiceBus，并且有一个关于Pubsub示例的问题。
我的目的是让多个Publisher1实例运行并接收发布者发送的消息。我还破解了发布者，只发送eventMessage类型的消息。
但是，如果我启动发布器和三个Subscriber1实例，一次只有一个实例会收到消息。
为什么会这样呢？是配置设置还是其他什么？
这是我尝试过的方法，它返回一个异常“启动端点时出现异常，已记录错误。原因:在配置组件之前无法配置属性。请先调用' configure‘。”：
using NServiceBus;
namespace Subscriber1
{
public cl
浏览 0提问于2010-03-17得票数 2
3回答
我从WebSPhere MQ队列收到一条消息。我尝试进行处理，如果收到一些异常，我希望将消息回滚到MQ队列。
我在做同样的事情时没有问题。消息会发生什么情况？它会排在队列的底部吗？
如果我尝试从队列中拉出一条消息，我会收到与回滚相同的消息吗？
可能的行为是什么？我想知道这种行为在大容量队列场景中的典型情况？
感谢您的任何意见。
谢谢你，芒露
浏览 0提问于2009-05-26得票数 6
我有一个应用程序监听IBM Websphere MQ队列上的消息。一旦消息被使用，应用程序就会执行一些处理逻辑。如果处理完成正常，我希望应用程序确认消息并将其从队列中删除。如果在处理过程中发生错误，我希望消息保留在队列中。这是如何实现的？(我正在使用.NET应用程序接口)谢谢。
浏览 0提问于2016-12-20得票数 2
1回答
我有一个场景，队列1使用数据库启动事务，并通过出站通道适配器将消息放入队列2。如果队列2中发生异常，我也应该在队列1中回滚。示例代码会很有帮助。
浏览 0提问于2018-04-10得票数 0
我们有一个Django应用程序，它使用一些基本的默认和初始信息在DB中创建一个存根对象，然后将一条消息放到Rabbit MQ上，以执行IO繁重的操作，这是填充此存根对象的数据所必需的。我们有一个单独的rabbit使用者，它作为命令行脚本运行(由daemontools包装-这样它就不会停机)，它处理来自rabbit的消息。
所以会发生这样的事情--有时，当消息返回时(此消息具有存根对象ID)，我们尝试使用StubObject.objects.get(pk=消息‘ID’)读取此对象，我们会得到一个匹配的查询不存在异常(消息通常需要大约30秒才能返回)。然而，当我们检入数据库时，当我们得到查询不存在
浏览 4提问于2013-02-16得票数 1
1回答
我遇到了一些奇怪的JMS问题，如下所示:有两个EAR文件，它使用一个通用的jar，jar文件负责将消息放入file.This队列中。
现在，从一个EAR文件中，我可以正确地将消息发送到队列，如果我尝试从其他EAR文件中检索it.But，则没有消息发送到JMS队列。在执行代码时，不会抛出JMS或任何其他异常。
有没有人能建议我，这类问题的可能原因是什么？
是否会与其他JAR files.If发生冲突?是的，可能与之相关的JAR文件是什么？
浏览 0提问于2013-10-19得票数 0
4回答
我有一个使用python的包、多处理和队列的程序。我的一个函数有这样的结构：
from multiprocessing import Process, Queue
def foo(queue):
while True:
try:
a = queue.get(block = False)
doAndPrintStuff(a)
except:
print "the end"
break
if __name__ == "__main__"
浏览 0提问于2011-08-18得票数 8
回答已采纳
1回答
EJB、XA事务和错误处理
、、、、
我们认为这是一个相当常见的XA用例：
从队列中读取消息
将一些数据写入数据库
将响应消息写入输出队列(这与队列中的响应消息不同)
然而，我们还需要一种处理内部错误和有害消息的方法。我们想到的控制流如下所示：
从队列中读取消息。
写入数据库
如果有异常，请回滚数据库事务
如果没有异常，运行提交phase1在数据库上
如果一切顺利(没有回滚并提交phase1，确定)，则向外队列写入成功消息。
如果数据库上的提交phase1失败或出现异常并回滚数据库事务，则向外队列写入失败消息。
提交队列内、外队列和数据库(除非由于异常而滚动)
浏览 2提问于2013-10-06得票数 3
回答已采纳
11回答
我本地安装了一台运行SharePoint 2010的Windows2012服务器，该服务器使用SQL Server Express。不幸的是，我的日志当前充斥着消息“在目标队列中排队消息时出现异常。错误: 15404，状态: 19。无法获取有关Windows NT组/用户‘域\用户’的信息，错误代码0x5。”每秒可以有20条这样的消息！
(...and‘域\用户’恰好是我的个人帐户。)
是否有正在运行的作业缺少权限？"Qoute from “尝试根据作业的属性将作业的所有者更改为sa帐户。”如果我是正确的，SQL server的express版本不能运行作业?或者是否有人/某物想要访问
浏览 0提问于2014-09-15得票数 91
在迁移到NService 4 (4.0.4)之后，我遇到了一些问题。当消息处理失败时，整个NServiceBus似乎停止而不执行任何工作(来自MSMQ的消息不再被消耗)。在查看日志之后，我发现了以下错误：
NServiceBus.log：
2013-10-02 17:49:31.5786 \x{e76f}\x{e76f}17:49:49:31.5786\x{e76f}\x{e76f}未能处理错误消息( id a32dce1-f408-4f6d-b448-a24b0118ec27 System.InvalidOperationException: System.InvalidOperation
浏览 3提问于2013-10-03得票数 1
回答已采纳
2回答
服务器多线程过度杀伤力？
、、、、
目前我正在创建一个服务器类型的应用程序，它将执行常规的监听来自外部客户端的连接，并在它们连接时处理请求等。
目前，每次客户端连接时，我的实现都会创建一对线程。一个线程只是从套接字读取请求并将其添加到队列中，另一个线程从队列中读取请求并对其进行处理。
我基本上是在寻求意见，看看你是否认为拥有所有这些线程是过度杀伤力，以及重要的是，这种方法是否会给我带来问题。
需要注意的是，这些线程大部分时间都是空闲的--我在两个线程中都使用了等待句柄(ManualResetEvent)。Reader线程等待，直到有消息可用，如果有消息可用，则读取该消息并将其转储到进程线程的队列中。流程线程等待，直到读取器发出消
浏览 3提问于2010-03-03得票数 0
1回答
众所周知，标准队列支持两个基本操作：insert和popout。insert发生在队列的尾部，而popout发生在队列的顶部。在这里，我不知道是否可以根据这两个操作来保持队列的有序性，就像不递减一样，还是使用一些额外的帮助函数来实现这个目标呢？
浏览 6提问于2014-10-10得票数 0
回答已采纳
2回答
我正在使用txamqp python库连接到AMQP broker (RabbitMQ)，并且我有一个带有以下回调的消费者：
@defer.inlineCallbacks
def message_callback(self, message, queue, chan):
"""This callback is a queue listener
it is called whenever a message was consumed from queue
c.f. test_amqp.ConsumeTestCase for use cases
浏览 0提问于2012-08-29得票数 4
回答已采纳
1回答
我遇到了一些问题的php联盟的飞系统包。当我试图使用数据库队列驱动程序将一个文件放入远程ftp服务器时，我会将以下错误作为返回：
local.ERROR:异常“ErrorException”和消息“未定义索引:000000000d1334030000000073b7555d”在C:...\league\flysystem\src\SafeStorage.php:30中
这种情况只发生在数据库队列驱动程序中！有人知道这件事吗？
我的代码是：
public function __construct()
{
$this->filesystem = new Filesystem(
浏览 3提问于2017-02-03得票数 0
在没有明显原因的情况下，我遇到了NSB恢复到Xml序列化程序的问题，这显然会在尝试反序列化消息时导致错误。下面是日志的摘录，您可以看到其中一些来自与Json相同的来源，然后突然出现了XML！
2018-06-05 08:51:36.924 INFO Stockly.Services.Messaging.Common.Extensions.MessageBodyWriter序列化消息体: 2018-06-05 08:51:37.026 INFO Stockly.Services.Messaging.Common.Extensions.MessageBodyWriter{"Exchang
浏览 2提问于2018-06-05得票数 0
2回答
是否可以在没有任何输入队列的情况下在应用程序中使用NServiceBus？
原因是，我有一个ASP.NET MVC应用程序，当发生一些事情(例如，一个新用户注册)时，它会向其他应用程序发送消息。web应用程序永远不会收到任何响应或其他消息，因此我不想让应用程序陷入困境。使用msmq窥视，它每秒抛出一个异常。
浏览 0提问于2010-07-29得票数 2
回答已采纳
我的MSMQ中的Maxtries是5。5次之后，nservicebus将消息发送到我定义的错误队列。现在我想在发生这种情况时执行一些进一步的操作(我必须将一些进程的状态更新为错误)，是否可以在我的Saga类中编写一个处理程序来读取这些错误队列？
提前感谢哈里斯
浏览 1提问于2012-04-03得票数 1
我的PHP脚本从我的数据库中读取消息，并将消息发送到队列，以便工作者角色(以及其他LAMP机器)可以提取它们并并行工作。
但是，我的脚本经常在我的apache服务器上的error_log中以致命错误结束，并显示以下消息。此错误发生在发送端。
PHP Notice: fwrite(): send of 414 bytes failed with errno=32
Broken pipe in /home/azureuser/pear/share/pear/HTTP/Request2/SocketWrapper.php on line 202
PHP Fatal error: Uncaug
浏览 0提问于2015-08-05得票数 1
需求是创建一个用于web服务压力测试的应用程序。我们的想法是将1000K大小为4KB的HTTPWebRequests轰击到web服务。为了实现这一点，我们创建了一个应用程序，其结构类似于几个线程在队列中添加要发送的数据，而线程池异步发送这些请求。Task responseTask = Task.Factory.FromAsync(testRequest.BeginGetResponse, testRequest.EndGetResponse, null);"但现在发生的情况是，经过一段时间后，请求数/秒显着减少(可能是因为服务的响应时间增加了..但同样，如果我们异步发送请求，响应时间是
浏览 0提问于2012-04-20得票数 2
是否可以在发送/回复配置中配置NSB，使同一应用程序同时负责发送消息和处理/回复相同的消息？目标是利用NSB提供的消息传递的持久性。
浏览 1提问于2011-11-24得票数 0
回答已采纳
在我们的场景中，我正在考虑使用pub子技术。不过，我不知道哪一个更好。
1个########
我们的web服务将发布一条消息，当它被外部调用时发生了一些事情，ExternalPersonCreatedMessage！
此消息将包含一个字段，该字段表示要将消息处理为(多个允许的)的目的地。
不同的订户将订阅。这些订阅者将通过检查目标字段来筛选消息，以查看是否需要任何操作。
2个########
我们的web服务将解析传入的呼叫，并根据字段中提供的目的地发布特定类型的消息。也就是说，将创建许多DestinationnPersonCreatedMessage消息。
订阅者只订阅他们所关心的特定消息。
浏览 10提问于2011-11-22得票数 0
回答已采纳
与相关:据我所知，两个物理发布者代表一个逻辑发布者，每个发布者都必须有自己的订阅队列。使用DBSubscriptionStorage允许他们拥有一个公共的订阅者列表，但是当一个新的订阅者弹出并订阅时会发生什么呢？subscribe消息将进入一个订阅队列，然后进入数据库。除了重启其他出版商之外，有没有办法让他们知道新的订阅者？
浏览 1提问于2011-05-21得票数 1
回答已采纳
我们使用以下设置：
我们使用带有队列触发器的Azure函数来处理JSON消息队列。
这些消息都是通过HTTP转发到API端点的，以供进一步处理。
API可以返回3个可能的HTTP状态代码: 200 (OK)、400 (坏请求)、500 (内部服务器错误)。
如果API返回200，则消息被正确处理，一切正常。队列触发器函数似乎自动删除队列消息，这对我们来说很好。
如果API返回400，则API具有接收消息并将其添加到状态指示格式错误或无法处理的表的逻辑。因此，我们可以自动从队列中删除消息，Azure函数可以正常结束。
如果API返回500，我们确保函数重新尝试将消息发送到API，直到状态代码为2
浏览 0提问于2017-05-13得票数 2
回答已采纳
1回答
我对进程间通信很陌生，我正在寻找关于实现以下目标的最佳方法的输入和指导:我有一个功能，可以将图像从一种格式转换为另一种格式，并且我希望使用多个进程进行批处理图像转换。
我有1000幅图像，我想从一种格式转换到另一种格式。
我创建了6个子进程，并希望将图像文件名发送给进程:一个子进程，一个要转换的图像。
我应该简单地创建6个消息队列并向每个进程发送一个消息队列，还是最好创建一个消息队列，存储图像名称的向量，并将该向量发送到6个子进程？
如何将一个子进程的结果传递给父进程？我怎样才能一直把工作发送到这个过程，直到我处理完1000个文件？
我正在使用C++，Windows和学习助推器
浏览 2提问于2014-10-16得票数 0
2回答
我们的应用程序使用带有spring的MQ类来使用来自WebSphere MQ的消息。MQ队列定义没有为退出阈值(BOTHRESH)和退出队列名称(BOQNAME)设置任何值。在会话事务处理模式中，当处理消息时发生异常时，不会发生邮件传递重试。我看到异常显示没有定义断电队列。由于它没有定义，所以它试图将消息添加到死信队列中。这也失败了。我的问题是-
当BOTHRESH = 0时，MQ类可以重新传递消息吗？
使用上述设置，是否可以使用重传计数管理应用程序代码对邮件传递重试？
浏览 13提问于2014-11-12得票数 2
需要帮助在一个链的错误处理过程中，文件:splitter和http:出站网关.现在，如果当我们收到状态代码=400,500 .时，错误消息中存在任何异常，我希望在错误激活器通道中处理该异常，并继续处理其他拆分的消息。
当我们收到异常时，它将在服务激活器中处理，而其他拆分的消息则不会被处理。
链条：
<int-file:inbound-channel-adapter> ---><int-file:splitter> ---> <int-http:outbound-gateway>
对于从文件中读取的每一行，我们都应该调用WS，因此当我们收到错误消息
浏览 1提问于2015-10-19得票数 1
回答已采纳
我是个新手，所以如果这个问题措辞不好，请让我知道！我有一个Android应用程序，即使手机处于锁定状态，它也需要大约每15分钟执行一次任务。上下文是：- Im以SDK23或更高版本为目标-任务1)获取用户的位置2)使用OKHttpClient调用HTTPS API，然后3)将结果发送到Firestore数据库 我正在使用WorkManager来尝试实现这个目标。然而，问题是它每次执行时，它都会执行8-9次，并且它的时间非常不规则。我可以从Firestore条目和Logcat中看到这一点。 WorkManager真的是这项任务的正确方式吗？我正在使用 implementation "a
浏览 113提问于2019-06-20得票数 5
回答已采纳
1回答
我试图用ApacheNifi.putElasticSearch处理器将流数据写入elasticsearch，
PutElasticSearch具有名为“批处理大小”的属性，当我将此值设置为1时，所有事件都会尽快写入elasticsearch。
但如此低的“批次大小”显然不能工作时，负载是高的。因此，为了获得合理的吞吐量，我需要将其设置为1000。
我的问题是，PutElasticSearch是否等待到可用事件的批处理大小。如果是，当处理器上有999个事件等待时，它可以等待几个小时。
我想了解logstash是如何在elasticsearch输出插件上做同样的工作的。可能有一些基于时间的刷新逻辑
浏览 4提问于2017-06-06得票数 0
回答已采纳
3回答
我目前正在使用Quartz Scheduler执行异步任务，例如在发生异常时发送电子邮件、从web界面发送电子邮件或定期分析流量。
我应该使用消息队列来发送电子邮件吗？这样做是不是更有效率或更正确呢？调度器方法工作得很好。
如果我使用队列，而电子邮件发送失败，队列是否可以稍后重试发送电子邮件？对于需要立即发生的任务，队列方法看起来比调度器更简单，但对于调度器任务，调度器仍然是调度器，除非队列中有比我所知道的更多的任务。
我还没有使用过JMS，所以这就是我所读到的。
沃尔特
浏览 0提问于2010-04-23得票数 7
回答已采纳
1回答
我有以下JS代码
$('#dialog').dialog({
...
buttons: {
OK: function() {
callAjax({"some":"param"});
$('#dialog').dialog('close');
}
}
});
var ajaxBatch = [];
function callAjax(cmd) {
ajaxBatch.push(cmd);
if (ajaxBatch.length == 1)
se
浏览 3提问于2011-12-26得票数 1
回答已采纳
2回答
我希望启动一个单独的线程来处理窗口消息(通过阻塞的GetMessage循环)，但之后仍然在初始线程中创建窗口。
在单独的线程中，一旦启动，我将使用PM_NOREMOVE调用PeekMessage，以确保消息队列存在(这是必要的吗？)，然后是..
AttachThreadInput(initial thread id,GetCurrentThreadId(),true)
..before最终进入消息循环
我还没有使用互斥或cs来确保这是及时发生的，但为了简单起见，我只是在我的初始线程中使用了Sleep语句。
无论如何，窗口消息似乎不会被单独的线程截获。
我有点不确定我这样做是否正确，并感谢任何可
浏览 0提问于2009-12-27得票数 6
回答已采纳
2回答
我有一个消息驱动的bean，它在某些情况下抛出异常。当它抛出异常时，消息不会被处理并放回队列中。根据我对MQ和WAS (Websphere Application Server)的理解，消息应该在x次尝试后被标记为坏的，并从队列中删除。这种情况不会发生，消息仍保留在标记为坏的队列中。
MQ和/或我错过了设置正确的配置的哪一部分？
( MDB抛出异常的问题不是这里的重点)
谢谢。
浏览 5提问于2010-06-01得票数 3
回答已采纳
我尝试对整数对进行递增排序，如果一个整数对的两个条目都严格小于另一个整数对的条目，则认为该整数对小于另一个整数对；如果两个整数对的条目都严格大于另一个整数对的条目，则认为该整数对大于另一个整数对。所有其他情况都被认为是不可比较的。
我想要解决这个问题的方法是定义一个实现上述功能的Comparator，但对于不可比较的情况会抛出异常，并将其提供给PriorityQueue。当然，在插入一对时，优先级队列会进行多次比较，同时将新条目冒泡到它在堆中的正确位置，其中许多比较是可比较的。但它可能发生在冒泡过程中，遇到一个新的对是不可比较的，并将抛出异常。如果发生这种情况，PriorityQueue的状态
浏览 1提问于2010-04-09得票数 1
3回答
如何在SQS上延迟4小时重试？
、、、、
TL;DR:如何模仿保持消费者：
无国籍
不需要管理预定的消息
从接收消息到最终使用正确的预定时间之间，从预定的消息到最终消耗它之间没有无用的重试。
我有一个SQS队列，在创建时具有默认属性。使用者处理消息的平均时间是1~2s。但是一些消息需要处理两次，在一个4小时的窗口之间。这些消息被称为B，其他消息被称为A。
假设我的队列中有以下消息：A1, A2, B1, A3, B2 (5条消息，最多10条)在这些表的开头：
time | what should happen
---------|-------------------
now | consumer
浏览 7提问于2021-06-24得票数 2
回答已采纳
我希望我的订阅者能够处理两种不同的信息流。我希望每种消息类型都有一个MSMQ队列，但是我不知道如何在我的.config文件的MsmqTransportConfig部分中指定多个InputQueue。
下面是我的订阅者的无XML配置：
Configure.With(new[] { typeof(EventMessage), typeof(EventMessageHandler), typeof(NServiceBus.Unicast.Transport.CompletionMessage) })
.CustomConfigurationSource(new
浏览 3提问于2010-12-04得票数 4
回答已采纳
我有第一行/墓地后缀服务器结构，当第一行服务器收到软故障时，第一行服务器向墓地发送消息。
但有时，我想队列太忙了，消息被锁定在传入队列中，只能在几天后发送。我宁愿丢弃邮件，也不愿寄很旧的邮件。
设置maximal_queue_lifetime将无法工作，因为它至少需要发送一次消息，如果消息太旧，我不希望它被发送一次。
浏览 0提问于2013-01-02得票数 0
回答已采纳
我们在带有ASP.NET核心(2.1)的Azure服务总线(Microsoft.Azure.ServiceBus 3.1.0)中使用会话队列。
我们创建了一个HostedService (实现IHostedService接口并将其添加到启动中的ConfigureService-Method中的托管服务中)。
在托管服务中，我们有以下代码：
this.client = new QueueClient(
this.configuration.ServiceBusConnectionString,
this.configuration.SessionBasedQueueName,
浏览 4提问于2018-08-21得票数 1
1回答
MSMQ专用队列大小限制
、、、
我正在尝试将消息放入在本地计算机上定义的专用队列中，但队列大小不能超过8MB。每次达到该大小后，我都会得到一个异常。指定队列的大小设置为10 GB。我运行的是Windows 7专业版。有没有因为这一点而受到限制？
浏览 0提问于2010-04-29得票数 2
回答已采纳
1回答
我一直在评估不同的.Net消息传递组件，我在使用MSMQ时遇到了一些问题，我无法用docs、sample或google来解决这些问题。
我相信我的场景唯一的独特之处就是我的客户可以发送或发布消息。看起来应该很简单，但我有以下问题。代码片段跟踪问题。
问题：
MetersRequest没有被处理。它们只是堆积在outgoingMetersRequests队列中。
如果说creditAuthRequests队列不存在或者我没有权限，就会出错。我已经确认队列没有被创建，但我的假设是，Rebus将确保它是在创建outgoingMetersRequests队列时创建的。(附带注意:如果我从Bus
浏览 2提问于2016-12-20得票数 0
回答已采纳
1回答
我想知道在以下情况下首选的体系结构是什么：
我需要有一个.NET应用程序，它将同时执行多个数据文件的批处理上载到Server。这将从WPF应用程序中调用，该应用程序将允许用户选择文件和目标表，并报告每次上传的单个进度(包括错误消息)。我绝对不会为这其中的任何一件事编写代码。但是，需要用户能够完全关闭WPF应用程序并继续上传过程。此外，如果用户从同一台机器重新启动WPF应用程序，它应该能够获得现有上传的句柄，并报告状态，就好像程序从未关闭过一样。
我的问题是，实现这一目标的方法是什么，哪些似乎是最标准/最合适的？
我考虑过的不是实际上关闭WPF应用程序，而是隐藏所有的窗口，但这似乎是一种欺骗。最
浏览 2提问于2014-01-20得票数 2
回答已采纳
当试图延迟单向客户端上的消息发送时，以下异常背后的理由是什么: System.InvalidOperationException“不能使用我们自己作为超时管理器，因为我们是单向客户端”
浏览 0提问于2016-04-15得票数 4
我有一个工人，他的运行时间变化很大，从10秒到1小时不等。我希望每五分钟运行一次此worker。只要作业在五分钟内完成，这就没问题。但是，如果作业花费的时间更长，Iron.io会一遍又一遍地将同一任务排入队列，并且在worker运行时会累积一堆相同类型的任务。
此外，任务不能并发运行是至关重要的，因此此工作线程的最大并发设置为1。
所以我的问题是:有没有一种方法可以防止Iron.io将仍在运行的工作进程的任务排入队列？
浏览 9提问于2016-08-30得票数 0
我有一个Workflow服务，它有几个接收到MSMQ队列的接收。我想实现以下行为：
如果发生关联异常(即工作流实例已消失)，则丢弃消息。
如果发生了InstanceLockException (即此工作流实例正在另一台服务器上执行某些操作)，则将消息放入重试队列中。
我已经尝试过在接收活动周围放置TransactedReceiveScope，但是它会将消息放在重试队列中，这样就会出现相关错误。另外，它在沉重的负荷下也会造成很多问题。
如果没有TransactedReceiveScope，如果有InstanceLockException，消息就会被丢弃。
是否有一种方法来实现这种
浏览 3提问于2011-05-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
