rabbitmq Les consommateurs ne consomment pas

Question

public class RequestConsumer : 
    IConsumer<StartFlowCommand>, 
    IConsumer<List<StartAndNextCommand>> 
{ 
    readonly IWorkFlowHandler _flowHandler; 
    public RequestConsumer(IContainer container) 
    { 
     _flowHandler = container.Resolve<IWorkFlowHandler>(); 
    } 

    public async Task Consume(ConsumeContext<StartAndNextCommand> context) 
    { 
     var result =await _flowHandler.WorkFlowStartNext(context.Message); 
     await context.RespondAsync(result); 
    } 


    public async Task Consume(ConsumeContext<List<StartAndNextCommand>> context) 
    { 
     var result = await Task.Run(() => _flowHandler.WorkFlowStartNextBatch(context.Message)); 
     await context.RespondAsync(result); 
    } 

type de message StartAndNextCommand peut consommer, mais le type de liste ne parviennent pas à consommer, pourquoi?

Answer 1

Ceci est voulu. Nous ne pouvons consommer qu'un seul message. Vous pouvez avoir un nouveau contrat, comme:

public interface StartAndNextBatch 
{ 
    IList<StartAndNextCommand> Commands { get; } 
} 

et un consommateur pour ce type de message

public async Task Consume(ConsumeContext<StartAndNextBatch> context) 

mais vous devez également publier ce type de message

await bus.Publish<StartAndNextBatch>(
    new { Commands = ... } 
);