Show
Ignore:
Timestamp:
01/18/08 14:06:15 (8 months ago)
Author:
xmlhacker
Message:

various across the board changes

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/nuxleus/Source/Xameleon/Function/QueueManager.cs

    r4359 r4541  
    77using Nuxleus.PubSub; 
    88 
    9 namespace Xameleon.Function 
    10 { 
    11     public static class QueueManager 
    12     { 
     9namespace Xameleon.Function { 
    1310 
    14         public static string Push(HttpContext context, string queueName, string message) 
    15         { 
     11    public static class QueueManager { 
     12 
     13        public static string Push (HttpContext context, string queueName, string message) { 
    1614            return Push(queueName, message); 
    1715        } 
    1816 
    19         private static string Push(string queueName, string message) 
    20         { 
    21           // Notification 
    22           Notification n = new Notification(); 
    23           n.Action = "publish"; 
    24           n.Expires = DateTime.Now.AddHours(1); 
    25           n.Categories = new Category[2]; 
    26           n.Categories[0] = new Category(); 
    27           n.Categories[0].Term = message; 
    28           n.Categories[1] = new Category(); 
    29           n.Categories[1].Term = "indie"; 
     17        private static string Push (string queueName, string message) { 
     18            // Notification 
     19            Notification n = new Notification(); 
     20            n.Action = "publish"; 
     21            n.Expires = DateTime.Now.AddHours(1); 
     22            n.Categories = new Category[2]; 
     23            n.Categories[0] = new Category(); 
     24            n.Categories[0].Term = message; 
     25            n.Categories[1] = new Category(); 
     26            n.Categories[1].Term = "indie"; 
    3027 
    31          // The actual Queue Message to send 
    32          Message pm = new Message(); 
    33          pm.Op.Type = OperationType.PushMessage; 
    34          pm.QueueId = queueName; 
     28            // The actual Queue Message to send 
     29            Message pm = new Message(); 
     30            pm.Op.Type = OperationType.PushMessage; 
     31            pm.QueueId = queueName; 
    3532 
    36          Console.WriteLine(queueName); 
    37          Console.WriteLine(n.ToString()); 
    38          pm.Payload = Convert.ToBase64String(Notification.Serialize(n)); 
     33            Console.WriteLine(queueName); 
     34            Console.WriteLine(n.ToString()); 
     35            pm.Payload = Convert.ToBase64String(Notification.Serialize(n)); 
    3936 
    40          // An event handler 
    41          MessageEvent me = new MessageEvent(); 
    42          me.Message = pm; 
    43          // Let's see what the response of the server was 
    44          me.MessageReceived += new MessageEventHandler(queue_MessageReceived); 
     37            // An event handler 
     38            MessageEvent me = new MessageEvent(); 
     39            me.Message = pm; 
     40            // Let's see what the response of the server was 
     41            me.MessageReceived += new MessageEventHandler(queue_MessageReceived); 
    4542 
    46          QueueClientPool.Enqueue(me); 
     43            QueueClientPool.Enqueue(me); 
    4744 
    48          return "message sent"; 
     45            return "message sent"; 
    4946        } 
    5047 
    51       private static void queue_MessageReceived(object sender, MessageStateEventArgs e){ 
    52        MessageEvent me = (MessageEvent)sender; 
    53        Message received = e.Message; 
    54        //Console.WriteLine("RESPONSE: {0}", received.ToString()); 
    55       } 
     48        private static void queue_MessageReceived (object sender, MessageStateEventArgs e) { 
     49            MessageEvent me = (MessageEvent)sender; 
     50            Message received = e.Message; 
     51            //Console.WriteLine("RESPONSE: {0}", received.ToString()); 
     52        } 
    5653 
    5754        //public static void Push(HttpContext context, object message) {