Changeset 4126

Show
Ignore:
Timestamp:
10/11/07 02:52:26 (1 year ago)
Author:
sylvain.hellegouarch
Message:

Extended LLUP messaging support

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/nuxleus/Scripts/qs.sh

    r3980 r4126  
    4848   
    4949  echo "Starting the queue server on port $PORT against memcached servers at $MEMCACHED_SERVERS" 
    50   queue-server.py -v -s $MEMCACHED_SERVERS -p $PORT -i $PID_FILE & 
     50  queue-server.py -s $MEMCACHED_SERVERS -p $PORT -i $PID_FILE & 
    5151;; 
    5252 

  • trunk/nuxleus/src/Nuxleus.Messaging/LLUP/InternalReceiverHandler.cs

    r4121 r4126  
    6161    private void BlipReceived(ISocketConnection sender, IMessage message) { 
    6262      Notification n = Notification.Parse(message.InnerMessage); 
    63       // The publisher always ensure that each notification has its llup:id  
    64       // element set so that consumers can decide whether or not 
    65       // they have already processed a notification 
    66       // The form of the id doesn't matter as long as it's unique. 
    67       n.Id = Guid.NewGuid().ToString(); 
    6863      postOffice.Post(n); 
    6964    } 

  • trunk/nuxleus/src/Nuxleus.Messaging/LLUP/PublisherHandler.cs

    r4121 r4126  
    104104      set {  
    105105        postOffice = value;  
    106         postOffice.Mailbox += new BlipPostedHandler(this.BlipReceived); 
     106        postOffice.Mailbox += new BlipPostedHandler(this.BlipToDispatch); 
    107107      } 
    108108    } 
    …… 
    132132    } 
    133133 
    134     private void BlipReceived(Notification n) { 
     134    private void BlipToDispatch(Notification n) { 
     135      // The publisher always ensure that each notification has its llup:id  
     136      // element set so that consumers can decide whether or not 
     137      // they have already processed a notification 
     138      // The form of the id doesn't matter as long as it's unique. 
     139      n.Id = Guid.NewGuid().ToString(); 
    135140      SendToAll(n); 
    136141    } 

  • trunk/nuxleus/src/nux.build

    r4120 r4126  
    464464      <sources> 
    465465        <include name="${source.dir}/ServiceApps/LLUP/Publisher.cs"/> 
     466      </sources> 
     467      <references> 
     468        <include name="${build.dir}/Nuxleus.Service.dll"/> 
     469        <include name="${build.dir}/Nuxleus.Vendor.dll"/> 
     470        <include name="${build.dir}/Nuxleus.Messaging.dll"/> 
     471        <include name="System.dll"/> 
     472        <include name="System.ServiceProcess.dll"/> 
     473        <include name="System.Xml.dll"/> 
     474        <include name="System.Web.dll"/> 
     475        <include name="System.Web.Services.dll"/> 
     476      </references> 
     477    </csc> 
     478  </target> 
     479  <target name="LLUPSubscriberService" depends="init Nuxleus Nuxleus.Service Nuxleus.Vendor Nuxleus.Messaging"> 
     480    <csc target="exe" output="${build.dir}/LLUPSubscriberService.exe"> 
     481      <sources> 
     482        <include name="${source.dir}/ServiceApps/LLUP/Subscriber.cs"/> 
    466483      </sources> 
    467484      <references> 
    …… 
    567584    <call target="LLUPPublisherService"/> 
    568585    <call target="LLUPRouterService"/> 
     586    <call target="LLUPSubscriberService"/> 
    569587    <call target="System.Messaging"/> 
    570588  </target>