MarkMenard

RuntimeError: RingNotFound
  method_missing at /Users/mark/.rvm/rubies/jruby-1.6.3/lib/ruby/1.9/drb/drb.rb:1099
             run at /Users/mark/.rvm/gems/jruby-1.6.3@we_build_pages/bundler/gems/rspec-core-e16d328ab0c3/lib/rspec/core/drb_command_line.rb:19
    run_over_drb at /Users/mark/.rvm/gems/jruby-1.6.3@we_build_pages/bundler/gems/rspec-core-e16d328ab0c3/lib/rspec/core/runner.rb:76
             run at /Users/mark/.rvm/gems/jruby-1.6.3@we_build_pages/bundler/gems/rspec-core-e16d328ab0c3/lib/rspec/core/runner.rb:63
         autorun at /Users/mark/.rvm/gems/jruby-1.6.3@we_build_pages/bundler/gems/rspec-core-e16d328ab0c3/lib/rspec/core/runner.rb:10

MarkMenard

class ConsumptionJunction::MessageProcessor
  include Celluloid
  
  attr_accessor :message_count, :worker_class
  
  def initialize (worker_class)
    puts "[ ConsumptionJunction::MessageProcessor ] CREATE MessageProcessor for #{worker_class}"
    self.worker_class = worker_class
    self.message_count = 0
    puts "[ ConsumptionJunction::MessageProcessor ] END initialize()"

MarkMenard

2011-08-16 23:41:56
Full thread dump Java HotSpot(TM) 64-Bit Server VM (20.1-b02-384 mixed mode):

"RMI TCP Connection(2)-192.168.1.109" daemon prio=9 tid=101969000 nid=0x111a19000 runnable [111a18000]
   java.lang.Thread.State: RUNNABLE
	at java.net.SocketInputStream.socketRead0(Native Method)
	at java.net.SocketInputStream.read(SocketInputStream.java:129)
	at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
	at java.io.BufferedInputStream.read(BufferedInputStream.java:237)

MarkMenard

# gem install work_queue

require 'rubygems'
require 'work_queue'

100.times do |j|
  wq = WorkQueue.new(100, nil, 0.01)
  1000.times do |i|
    wq.enqueue_b do
      puts "!!!!!!!!!!!!!!!!!!!! DONE - Finished run #{j} !!!!!!!!!!!!!!!!!!!!" if i == 999

MarkMenard

2011-08-09 09:29:44
Full thread dump Java HotSpot(TM) 64-Bit Server VM (20.1-b02-384 mixed mode):

"RMI TCP Connection(2)-192.168.1.109" daemon prio=9 tid=101936000 nid=0x1283c9000 runnable [1283c8000]
   java.lang.Thread.State: RUNNABLE
	at java.net.SocketInputStream.socketRead0(Native Method)
	at java.net.SocketInputStream.read(SocketInputStream.java:129)
	at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
	at java.io.BufferedInputStream.read(BufferedInputStream.java:237)

MarkMenard

class ServerInformationTool < Tool
  accepts :homepage_url, :format => :http_url, :validates => { :http_url => { :require_valid_host_name => true } }
  for_each_input :homepage_url do
    build ServerInformationInfo
    build GeoIpInfo
    build DnsInfo
  end
end

MarkMenard

      create  public/javascripts/rails.js.backup
      remove  public/javascripts/rails.js
      create  public/stylesheets/application.css
      create  public/stylesheets/formatting.css
      create  public/stylesheets/home.css
      create  public/stylesheets/theme.css
      create  public/javascripts/admin.js
      append  config/environments/development.rb
      append  config/environments/test.rb
      append  config/environments/production.rb

MarkMenard

May 31, 2011 4:22:32 PM org.apache.coyote.AbstractProtocolHandler init
INFO: Initializing ProtocolHandler ["http-bio-3000"]
May 31, 2011 4:22:32 PM org.apache.catalina.core.StandardService startInternal
INFO: Starting service Tomcat
May 31, 2011 4:22:32 PM org.apache.catalina.core.StandardEngine startInternal
INFO: Starting Servlet Engine: Apache Tomcat/7.0.11
May 31, 2011 4:22:32 PM org.apache.catalina.startup.ContextConfig webConfig
INFO: No global web.xml found
May 31, 2011 4:22:33 PM org.apache.catalina.core.ApplicationContext log

MarkMenard

class FooBar
  include Mongoid::Document
  field :query_subject, :type => String
  field :content, :type => String
  
  class << self
    
    def find_current (query_subject)
      self.where(:query_subject => query_subject).order_by(:created_at.desc).first
    end

MarkMenard

class Document
  include Mongoid::Document
  field :query_subject, :type => String
  field :content, :type => String
  
  class << self
    
    def find_current (query_subject)
      self.where(:query_subject => query_subject).order_by(:created_at.desc).first
    end