             do (key,group) =>
                 # we don't need rewind buffers for stream groups, but we do
                 # need sources.
-                rpc.request "group_sources", key:key, (err) =>
+                rpc.request "group_sources", key:key, null, timeout:10000, (err) =>
                     @log.error "Error getting StreamGroup sources: #{err}" if err
                     @log.info "Sources received for StreamGroup #{ key }."
                     af()

                            @log.error "Error loading rewind buffer: #{err}" if err
                            c.end()

                    rpc.request "stream_rewind", key:key,path:spath, (err) =>
                        return @log.error "Error loading rewind buffer for #{key}: #{err}" if err
                        @log.info "Rewind buffer loaded for #{key}"


                        , (err,reply) =>
                            @log.error "Error sending group source #{msg.key}/#{source.uuid}: #{err}" if err
                            af()
                else
                    af()


        # -- Stream Rewind Buffers and Sources -- #
