← Back to branch summary

~ubuntu-branches/ubuntu/trusty/smuxi/trusty-proposed

« back to all changes in this revision

Viewing changes to lib/ServiceStack/src/ServiceStack.Common/Messaging/InMemoryTransientMessageService.cs

  • Committer: Package Import Robot
  • Author(s): Mirco Bauer
  • Date: 2013-05-25 22:11:31 UTC
  • mfrom: (1.2.12)
  • Revision ID: package-import@ubuntu.com-20130525221131-nd2mc0kzubuwyx20
Tags: 0.8.11-1
* [22d13d5] Imported Upstream version 0.8.11
* [6d2b95a] Refreshed patches
* [89eb66e] Added ServiceStack libraries to smuxi-engine package
* [848ab10] Enable Campfire engine
* [c6dbdc7] Always build db4o for predictable build result
* [13ec489] Exclude OS X specific libraries from dh_clideps

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/ServiceStack/src/ServiceStack.Common/Messaging/InMemoryTransientMessageService.cs
 
1
#if !SILVERLIGHT 
 
2
using System;
 
3
using System.Collections;
 
4
 
 
5
namespace ServiceStack.Messaging
 
6
{
 
7
    public class InMemoryTransientMessageService
 
8
        : TransientMessageServiceBase
 
9
    {
 
10
        internal InMemoryTransientMessageFactory Factory { get; set; }
 
11
 
 
12
        public InMemoryTransientMessageService()
 
13
            : this(null)
 
14
        {
 
15
        }
 
16
 
 
17
        public InMemoryTransientMessageService(InMemoryTransientMessageFactory factory)
 
18
        {
 
19
            this.Factory = factory ?? new InMemoryTransientMessageFactory(this);
 
20
            this.Factory.MqFactory.MessageReceived += factory_MessageReceived;
 
21
        }
 
22
 
 
23
        void factory_MessageReceived(object sender, EventArgs e)
 
24
        {
 
25
            //var Factory = (MessageQueueClientFactory) sender;
 
26
            this.Start();
 
27
        }
 
28
 
 
29
        public override IMessageFactory MessageFactory
 
30
        {
 
31
            get { return Factory; }
 
32
        }
 
33
 
 
34
        public MessageQueueClientFactory MessageQueueFactory
 
35
        {
 
36
            get { return Factory.MqFactory; }
 
37
        }
 
38
    }
 
39
}
 
40
#endif
 
 
b'\\ No newline at end of file'