ACommand cmd = new ACommand() { Tag = "aaa" };
CommandBusDistributer<ACommand, ACommandResult> cmdDistributer = new CommandBusDistributer<ACommand, ACommandResult>();
cmdDistributer.ResultCatached += new CommandResultCatchedDelegate<ACommandResult>(cmdDistributer_ResultCatached);
cmdDistributer.SendRequest(cmd);

ACommand cmd = new ACommand() { Tag = "aaa" };
CommandBusDistributer<ACommand, ACommandResult> cmdDistributer = new CommandBusDistributer<ACommand, ACommandResult>();
cmdDistributer.SendRequest(cmd);
ACommandResult result=cmdDistributer.WaitResponse();

<?xml version="1.0" encoding="utf-8" ?>
<CommandBusSetting><AutoCreateIfNotExists>true</AutoCreateIfNotExists><WebSessionSupport>true</WebSessionSupport><CommandQueue>PC-20130606HCVP\private$\Commands_{0}</CommandQueue><ResponseQueue>PC-20130606HCVP\private$\CommandResponses</ResponseQueue><NetworkLocation>\\PC-20130606HCVP\network</NetworkLocation>
</CommandBusSetting>

[QueueName("ACommand")]//这个可选，没有QueueName时，默认对应的msmq队列名为类名，此处为ACommand
public class ACommand : BaseCommand  //需要继承自BaseCommand
{public string Tag { get; set; }//自定义的属性
}

static void Main(string[] args){Thread.Sleep(2000);CommandHandlerListener listener = new CommandHandlerListener();listener.AddHandler(new TestCommandHandlers());listener.AddHandler(new Test2CommandHandlers());listener.Start();Console.ReadKey();}

static void Main(string[] args){Thread.Sleep(2000);CommandHandlerListener listener = new CommandHandlerListener();listener.AddHandler(new Test3CommandHandlers());listener.Start();Console.ReadKey();}

public class TestCommandHandlers : ICommandHandlers,ICommandHandler<ACommand, ACommandResult>,ICommandHandler<BCommand, BCommandResult>{public ACommandResult Handler(ACommand cmd, ISessionContext session){Console.WriteLine("From [public ACommandResult Handler(ACommand cmd)]: " + cmd.Tag);ACommandResult result = new ACommandResult();result.Result = "result from ACommand";return result;}public BCommandResult Handler(BCommand cmd, ISessionContext session){Console.WriteLine("From [public BCommandResult Handler(BCommand cmd)]: " + cmd.Tag);if (session != null){Console.WriteLine("session not null");object o = session.GetWebSession("key1");if (o != null){Console.WriteLine("From Session['key1']: " + Convert.ToString(o));//session.Set("key1", "changed from command handler: " + DateTime.Now);
                }}BCommandResult result = new BCommandResult();result.Result = "result from BCommand";return result;}}