Permalink
Browse files

Method to destroy actors

  • Loading branch information...
1 parent abab514 commit 28ccd666a41c77754af9ae76e34355bb37a76769 @flashingpumpkin committed Nov 23, 2010
Showing with 5 additions and 0 deletions.
  1. +5 −0 src/actors.coffee
View
@@ -109,6 +109,11 @@ class Actor extends events.EventEmitter
else
@messages.publish('actor.'+id.toString(), bison.encode({ message: message}))
+
+ destroy: ->
+ @queue.destroy()
+ delete @connection.queues[@id]
+
# The only export wraps `amqp.createConnection` and creates a new actor connection that
# receives the AMQP connection to work with. Then the actor object is returned.
exports.createConnection = (options)->

0 comments on commit 28ccd66

Please sign in to comment.