Repository navigation
Expand file tree
/
Copy pathcore.py
More file actions
190 lines (145 loc) · 7.16 KB
/
Copy pathcore.py
File metadata and controls
190 lines (145 loc) · 7.16 KB
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
"""
Copyright 2006-2008 SpringSource (http://springsource.com), All Rights Reserved
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
"""
# stdlib
import locale
from string import Template
from cStringIO import StringIO
# Spring Python
from springpython.jms import JMSException
from springpython.jms import DEFAULT_DELIVERY_MODE
__all__ = ["MessageConverter", "JmsTemplate", "TextMessage"]
# These attributes have special meaning to connection factories.
reserved_attributes = set(("text", "jms_correlation_id", "jms_delivery_mode",
"jms_destination", "jms_expiration", "jms_message_id", "jms_priority",
"jms_redelivered", "jms_reply_to", "jms_timestamp", "max_chars_printed",
"JMS_IBM_Report_Exception", "JMS_IBM_Report_Expiration", "JMS_IBM_Report_COA",
"JMS_IBM_Report_COD", "JMS_IBM_Report_PAN", "JMS_IBM_Report_NAN",
"JMS_IBM_Report_Pass_Msg_ID", "JMS_IBM_Report_Pass_Correl_ID",
"JMS_IBM_Report_Discard_Msg", "JMSXGroupID", "JMSXGroupSeq", "JMS_IBM_Feedback",
"JMS_IBM_Last_Msg_In_Group", "JMSXUserID", "JMS_IBM_PutTime", "JMS_IBM_PutDate",
"JMSXAppID"))
# Magic methods are also forbidden.
reserved_attributes.update(set(dir(object) + ["__weakref__", "__dict__", "__module__"]))
text_message_template = """
JMS message class: jms_text
jms_delivery_mode: $jms_delivery_mode
jms_expiration: $jms_expiration
jms_priority: $jms_priority
jms_message_id: $jms_message_id
jms_timestamp: $jms_timestamp
jms_correlation_id: $jms_correlation_id
jms_destination: $jms_destination
jms_reply_to: $jms_reply_to
jms_redelivered: $jms_redelivered
""".lstrip()
class MessageConverter(object):
def to_message(self, object_to_be_converted_to_a_message):
raise NotImplementedError("Should be implemented by subclasses")
def from_message(self, message_to_be_converted_to_an_object):
raise NotImplementedError("Should be implemented by subclasses")
class JmsTemplate(object):
def __init__(self, factory=None, delivery_persistent=None,
priority=None, time_to_live=None, message_converter=None,
default_destination=None):
self.factory = factory
# QoS
self.delivery_persistent = delivery_persistent
self.priority = priority
self.time_to_live = time_to_live
self.message_converter = message_converter
self.default_destination = default_destination
def convert_and_send(self, object_, destination=None):
if not self.message_converter:
raise JMSException("Couldn't send the message, no message converter set")
self.send(self.message_converter.to_message(object_), destination)
def send(self, message, destination=None):
if isinstance(message, basestring):
message = TextMessage(message)
if destination:
dest = destination
elif self.default_destination:
dest = self.default_destination
else:
raise JMSException("No destination given and no default destination set")
message.jms_destination = dest
self.factory.send(message, dest)
def receive(self, destination=None, timeout=1000):
if destination:
dest = destination
elif self.default_destination:
dest = self.default_destination
else:
raise JMSException("No destination given and no default destination set")
return self.factory.receive(dest, timeout)
def receive_and_convert(self, destination=None, timeout=1000):
if not self.message_converter:
raise JMSException("Couldn't receive a message, no message converter set")
return self.message_converter.from_message(self.receive(destination, timeout))
def open_dynamic_queue(self):
return self.factory.open_dynamic_queue()
def close_dynamic_queue(self, dynamic_queue_name):
self.factory.close_dynamic_queue(dynamic_queue_name)
class TextMessage(object):
def __init__(self, text=None, jms_correlation_id=None, jms_delivery_mode=None,
jms_destination=None, jms_expiration=None, jms_message_id=None,
jms_priority=None, jms_redelivered=None, jms_reply_to=None,
jms_timestamp=None, max_chars_printed=100):
self.text = text
self.jms_correlation_id = jms_correlation_id
self.jms_delivery_mode = jms_delivery_mode or DEFAULT_DELIVERY_MODE
self.jms_destination = jms_destination
self.jms_expiration = jms_expiration
self.jms_message_id = jms_message_id
self.jms_priority = jms_priority
self.jms_redelivered = jms_redelivered
self.jms_reply_to = jms_reply_to
self.jms_timestamp = jms_timestamp
self.max_chars_printed = max_chars_printed
def __str__(self):
basic_data = {
"jms_delivery_mode": self.jms_delivery_mode,
"jms_expiration":self.jms_expiration,
"jms_priority":self.jms_priority,
"jms_message_id":self.jms_message_id,
"jms_timestamp":self.jms_timestamp,
"jms_correlation_id":self.jms_correlation_id,
"jms_destination":self.jms_destination,
"jms_reply_to":self.jms_reply_to,
"jms_redelivered":self.jms_redelivered,
}
buff = StringIO()
buff.write(Template(text_message_template).safe_substitute(basic_data))
user_attrs = set(dir(self)) - reserved_attributes
user_attrs = list(user_attrs)
user_attrs.sort()
if user_attrs:
for user_attr in user_attrs:
user_attr_value = getattr(self, user_attr)
if isinstance(user_attr_value, unicode):
user_attr_value = user_attr_value.encode("utf-8")
buff.write(" %s:%s\n" % (user_attr, user_attr_value))
if self.text != None:
text_to_show = self.text[:self.max_chars_printed]
if isinstance(text_to_show, unicode):
text_to_show = text_to_show.encode("utf-8")
buff.write(text_to_show)
if len(text_to_show) < len(self.text):
omitted = locale.format("%d", (len(self.text) - len(text_to_show)), True)
buff.write("\nAnother ")
buff.write(omitted)
buff.write(" character(s) omitted")
else:
buff.write("<None>")
value = buff.getvalue()
buff.close()
return value