1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
from Pyro5.api import expose, behavior, serve, current_context
@behavior(instance_mode="single")
class SingleInstance(object):
def __init__(self):
print("created SingleInstance instance with id", id(self))
@expose
def msg(self, message):
print("[%s] %s.msg: %s" % (id(self), self.__class__.__name__, message))
return id(self)
@behavior(instance_mode="session", instance_creator=lambda clazz: clazz.create_instance())
class SessionInstance(object):
def __init__(self):
print("created SessionInstance instance with id", id(self))
@expose
def msg(self, message):
print("[%s] %s.msg: %s" % (id(self), self.__class__.__name__, message))
return id(self), self.correlation_id
@classmethod
def create_instance(cls):
obj = cls()
obj.correlation_id = current_context.correlation_id
return obj
@behavior(instance_mode="percall")
class PercallInstance(object):
def __init__(self):
print("created PercallInstance instance with id", id(self))
@expose
def msg(self, message):
print("[%s] %s.msg: %s" % (id(self), self.__class__.__name__, message))
return id(self)
if __name__ == "__main__":
# please make sure a name server is running somewhere first.
serve({
SingleInstance: "instance.single",
SessionInstance: "instance.session",
PercallInstance: "instance.percall"
}, verbose=True)
|
