17 |
|
|
18 |
This document describes the use of Tapestry overlay with Storm. We start by |
This document describes the use of Tapestry overlay with Storm. We start by |
19 |
proviving a short introduction to Tapestry, to the SEDA model and to the Tapestry |
proviving a short introduction to Tapestry, to the SEDA model and to the Tapestry |
20 |
API. Then, we propose new classes and a pseudo code to be which provide |
API. Then, we propose new classes to be implemented in order to transfer |
21 |
Tapestry's basic functionality to Storm. New classes are mandatory for |
Storm-related messages in a Tapestry overlay, and a pseudo code which would |
22 |
transferring Storm-related messages in a Tapestry overlay. Pseudo code |
provide Tapestry's basic services to Storm; pseudo code describes a simple |
23 |
describes a simple StormTapestryManager which supports query and insert |
StormTapestryManager class which supports Storm block query and insert operations |
24 |
operations in a Tapestry overlay. |
in a Tapestry overlay. |
25 |
|
|
26 |
This document is based on Tapestry 2.0 release. |
This document is based on Tapestry 2.0 release. |
27 |
|
|
216 |
|
|
217 |
|
|
218 |
Here, we propose a simple StormTapestryManager pseudo code. This is an event |
Here, we propose a simple StormTapestryManager pseudo code. This is an event |
219 |
handler class for Tapestry. In addition, this class provides Storm block |
handler class for Tapestry services. In addition, this class provides Storm |
220 |
query and insert operations in a Tapestry overlay. |
block query and insert operations in a Tapestry overlay. |
221 |
|
|
222 |
class StormTapestryManager implements EventHandlerIF { |
class StormTapestryManager implements EventHandlerIF { |
223 |
|
|
274 |
"ostore.tapestry.api.TapestryLocateFailure" |
"ostore.tapestry.api.TapestryLocateFailure" |
275 |
} |
} |
276 |
|
|
277 |
for (From i = 0 To numberOf(message_types)) { |
for (From i=0 To numberOf(message_types)) { |
278 |
|
|
279 |
// First, register messages we intend to |
// First, register messages we intend to |
280 |
// receive |
// receive |
296 |
method handleEvents(QueueElementIF array items) |
method handleEvents(QueueElementIF array items) |
297 |
throws EventHandlerException { |
throws EventHandlerException { |
298 |
|
|
299 |
for (from i=0 to length(items) |
for (From i=0 to numberOf(items) |
300 |
handleEvent(items[i]) |
handleEvent(items[i]) |
301 |
} |
} |
302 |
|
|