我使用MassTransit发送和接收微服务命令。当我在本地运行它(远程连接到实例)时,它发送和接收很好。例如,我从本地控制台应用程序向远程ServiceBus队列(在ServiceBus 3.0.4中可以看到)发送一个命令,然后本地TopShelf服务接收并处理该命令。但是,当我部署我的服务时,它会失败,出现以下错误:
Microsoft.ServiceBus.Messaging.MessageSizeExceededException: The received message (delivery-id:0, size:1904586 bytes) exceeds the limit (2
我正在我的接收端实现一个MassTransit中间件来记录处理消息的性能,我想从PipeContext获取消息类型,我如何获得它?
public async Task Send(T context, IPipe<T> next)
{
// I want to know the message type from here so that i can log it
using (_logger.BeginTimedOperation("Time for handling message", null, LogEventLevel
我在事件网格上发送事件,像这样。我可以看到他们到达了蓝色仪表盘
NomeEmailChange yay = new NomeEmailChange
{
Nome = "cesco",
Email = "cesco"
};
var primaryTopicKey = _config["EventGridConfig:AcessKey"];
var primaryTo
在迁移到Masstrasit8.0.3之后,ScopeFilter确实允许响应并结束发送中的使用者进程(ConsumeContext.)方法。在我们的例子中,我们有一个带有中介设置的缓存作用域过滤器。在消费发送方法中有一个CacheScopeFilter,它检查特定请求是否在内存缓存中:
var cacheResponse = cacheService.GetCachedResponse(cacheRequest);
if (cacheResponse != null)
{
我正在尝试为我的FluentValidation管道创建一些MassTransit中间件。我认为对于我的第一个MassTransit中间件来说,这将是一个非常容易的项目,但恐怕我已经陷入困境了。有人能救我吗?
除了之外,我还参考了来提供指导:
这是我的过滤器:
public class FluentValidationFilter<TMessage> : IFilter<ConsumeContext<TMessage>>
where TMessage : class
{
public void Probe(ProbeContext conte
我正在尝试创建过滤器来填充使用者中的correlationId,并在发送的消息中添加这个correlationId。
但是,我相信,由于它是多总线的上下文在2配置的总线之间是不同的,是否有任何方法使这个工作。
下面是其中一个过滤器的示例:
public class CorrelationSendFilter<T> :
IFilter<SendContext<T>>
where T : class
{
private CorrelationContext _correlationContext;
public Correlat