# File lib/puppet/util/queue/stomp.rb, line 14
14:     def initialize
15:         begin
16:             uri = URI.parse(Puppet[:queue_source])
17:         rescue => detail
18:             raise ArgumentError, "Could not create Stomp client instance - queue source %s is invalid: %s" % [Puppet[:queue_source], detail]
19:         end
20:         unless uri.scheme == "stomp"
21:             raise ArgumentError, "Could not create Stomp client instance - queue source %s is not a Stomp URL: %s" % [Puppet[:queue_source], detail]
22:         end
23: 
24:         begin
25:             self.stomp_client = Stomp::Client.new(uri.user, uri.password, uri.host, uri.port, true)
26:         rescue => detail
27:             raise ArgumentError, "Could not create Stomp client instance with queue source %s: got internal Stomp client error %s" % [Puppet[:queue_source], detail]
28:         end
29:     end