Issue #7988 has been updated by R.I. Pienaar. Branch set to ripienaar/feature/master/7988
A first stab at this exist in the branch, it needs some polish like making it configurable etc. Given a request that hits 5 machines: <pre> $ mco rpc rpcutil ping -W /dev_server/ D, [2011-06-23T16:14:45.932439 #17537] DEBUG -- : activemq.rb:177:in `publish' Sending a message 05c7e51564f8b69aa5fcebe0bebd494f to ActiveMQ target '/queue/mcollective.nodes' with headers 'mc_identity, reply-to' D, [2011-06-23T16:14:45.932695 #17537] DEBUG -- : activemq.rb:177:in `publish' Sending a message 05c7e51564f8b69aa5fcebe0bebd494f to ActiveMQ target '/queue/mcollective.nodes' with headers 'mc_identity, reply-to' D, [2011-06-23T16:14:45.933016 #17537] DEBUG -- : activemq.rb:177:in `publish' Sending a message 05c7e51564f8b69aa5fcebe0bebd494f to ActiveMQ target '/queue/mcollective.nodes' with headers 'mc_identity, reply-to' D, [2011-06-23T16:14:45.933270 #17537] DEBUG -- : activemq.rb:177:in `publish' Sending a message 05c7e51564f8b69aa5fcebe0bebd494f to ActiveMQ target '/queue/mcollective.nodes' with headers 'mc_identity, reply-to' D, [2011-06-23T16:14:45.934718 #17537] DEBUG -- : activemq.rb:177:in `publish' Sending a message 05c7e51564f8b69aa5fcebe0bebd494f to ActiveMQ target '/queue/mcollective.nodes' with headers 'mc_identity, reply-to' </pre> And then given a request with an unknown amount or large amounts of nodes it reverts to broadcast: <pre> $ mco rpc rpcutil ping D, [2011-06-23T17:19:04.692732 #20586] DEBUG -- : activemq.rb:183:in `publish' Sending a message to ActiveMQ target '/topic/mcollective.rpcutil.command' with headers 'reply-to' </pre> These logs are from a yet unreleased activemq specific connector plugin. ---------------------------------------- Bug #7988: MCollective::Message should support point to point comms https://projects.puppetlabs.com/issues/7988 Author: R.I. Pienaar Status: Accepted Priority: Normal Assignee: R.I. Pienaar Category: SimpleRPC Target version: 1.3.x Keywords: Branch: ripienaar/feature/master/7988 Affected mCollective version: The MCollective::Message object should support point to point comms. You should give it the list of discovered nodes and if that list is below a threshold it should use directed requests. This will require MC::Client and MC::RPC::Client to create Message objects rather than sending hashes around. This will provide the basis for creating plugable discover and improve scalability -- You have received this notification because you have either subscribed to it, or are involved in it. To change your notification preferences, please click here: http://projects.puppetlabs.com/my/account -- You received this message because you are subscribed to the Google Groups "Puppet Bugs" group. To post to this group, send email to [email protected]. To unsubscribe from this group, send email to [email protected]. For more options, visit this group at http://groups.google.com/group/puppet-bugs?hl=en.
