diff options
author | Rick Bradley <rick@rickbradley.com> | 2007-10-04 13:19:15 -0500 |
---|---|---|
committer | Rick Bradley <rick@rickbradley.com> | 2007-10-04 13:19:15 -0500 |
commit | 102ad23acb1c798c99b013e86b1d67350bbced7c (patch) | |
tree | 84c24132dccef50f5504f2167b6ebc98d641dc03 /lib | |
parent | 187d91010687199457b892ca765fc1a76471c04f (diff) | |
download | puppet-102ad23acb1c798c99b013e86b1d67350bbced7c.tar.gz puppet-102ad23acb1c798c99b013e86b1d67350bbced7c.tar.xz puppet-102ad23acb1c798c99b013e86b1d67350bbced7c.zip |
Added .listening to REST server, handle listen states and transitions.
Diffstat (limited to 'lib')
-rw-r--r-- | lib/puppet/network/rest_server.rb | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/lib/puppet/network/rest_server.rb b/lib/puppet/network/rest_server.rb index 0ffa8ff16..7c745f321 100644 --- a/lib/puppet/network/rest_server.rb +++ b/lib/puppet/network/rest_server.rb @@ -1,5 +1,6 @@ class Puppet::Network::RESTServer # :nodoc: @@routes = {} + @@listening = false def self.register(*indirections) raise ArgumentError, "indirection names are required" if indirections.empty? @@ -17,4 +18,18 @@ class Puppet::Network::RESTServer # :nodoc: def self.reset self.unregister(@@routes.keys) unless @@routes.keys.empty? end + + def self.listening? + @@listening + end + + def self.listen + raise "Cannot listen -- already listening" if @@listening + @@listening = true + end + + def self.unlisten + raise "Cannot unlisten -- not currently listening" unless @@listening + @@listening = false + end end |