Comparing version 0.0.5 to 0.1.0
{ | ||
"name": "pirate", | ||
"version": "0.0.5", | ||
"version": "0.1.0", | ||
"description": "A tuplespace-based messaging transport.", | ||
@@ -9,3 +9,4 @@ "main": "lib/pirate.coffee", | ||
"generic-pool": "2.0.x", | ||
"sprintf": "0.1.1" | ||
"sprintf": "0.1.1", | ||
"fairmont": "0.0.x" | ||
}, | ||
@@ -12,0 +13,0 @@ "devDependencies": { |
@@ -66,5 +66,9 @@ # Pirate | ||
while true | ||
work = -> | ||
worker.accept (error,message) -> | ||
"Hello #{message.content}!" | ||
process.nextTick work | ||
# begin | ||
work() | ||
@@ -71,0 +75,0 @@ That's it! Notice that the only physical endpoint is specified when creating the Transport. The `channel` endpoint is a purely logical one. Any worker listening on this channel can get tasks, and no two workers will get the same task. Similarly, any number of dispatchers can be sending tasks, provided they all provide unique names (which is why we're using the `randomKey` method provided by Pirate to set the name). |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
23850
76
4
+ Addedfairmont@0.0.x