RequestResponse.ts

module Westeros.Communication{

  export class Message{
    __messageDate: Date;
    __from: string;
    __corrolationId: number;
    body: string;
  }

  export class CrowMailRequestor{
    public Request(){
      var message = { __messageDate : new Date(),
                      __from : "requestor",
                      __corrolationId : Math.random(),
                      body: "Hello there. What is the square root of 9?"};
      var bus = new CrowMailBus(this);
      bus.Send(message);
      console.log("message sent!");
    }

    public processMessage(message: Message){
      console.dir(message);
    }
  }

  export class CrowMailResponder{
    constructor(public bus: CrowMailBus){}
    processMessage(message:Message){
      var response = { __messageDate : new Date(),
                      __from : "responder",
                      __corrolationId : message.__corrolationId,
                      body: "Pretty sure it is 3."};
      this.bus.Send(response);
      console.log("Reply sent");
    }
  }

  export class CrowMailBus{
    responder: CrowMailResponder;
    constructor(public requestor: CrowMailRequestor){
      this.responder = new CrowMailResponder(this);
    }

    public Send(message:Message){
      if(message.__from == "requestor")
      {
        process.nextTick(() => this.responder.processMessage(message));
      }
      else{
        process.nextTick(() => this.requestor.processMessage(message));
      }
    }
  }
}

var requestor = new Westeros.Communication.CrowMailRequestor();
requestor.Request();