james-carr

conn.on('ready', function(){
  withConnection(conn)
    ('foo', {autoDelete:false}, 1000, consumer)
    ('bar', queueOpts,          500 , consumer)
    ('baz', queueOpts,          1   )
});

james-carr

arakis λ ~/projects/high-availability/java-quick-start ➤ 650a339|master⚡
10196 ± : vagrant provision                                                                                                [5h45m] ✹ ✭
/home/jamescarr/projects/high-availability/java-quick-start/Vagrantfile:8:in `block (2 levels) in <top (required)>': undefined method `validation_key_path=' for #<Vagrant::Provisioners::ChefSolo::Config:0x00000001e0f208> (NoMethodError)
	from /home/jamescarr/.rvm/gems/ruby-1.9.2-p290/gems/vagrant-0.9.2/lib/vagrant/config/vm/provisioner.rb:32:in `call'
	from /home/jamescarr/.rvm/gems/ruby-1.9.2-p290/gems/vagrant-0.9.2/lib/vagrant/config/vm/provisioner.rb:32:in `configure'
	from /home/jamescarr/.rvm/gems/ruby-1.9.2-p290/gems/vagrant-0.9.2/lib/vagrant/config/vm/provisioner.rb:21:in `initialize'
	from /home/jamescarr/.rvm/gems/ruby-1.9.2-p290/gems/vagrant-0.9.2/lib/vagrant/config/vm.rb:104:in `new'
	from /home/jamescarr/.rvm/gems/ruby-1.9.2-p290/gems/vagrant-0.9.2/lib/vagrant/config/vm.rb:104:in `provision'
	

james-carr

map = function(){
  this.log.forEach(function(logItem){
    if(logItem.action == 'Call' && logItem.user != ''){
      emit({user: logItem.user, time:logItem.time}, 1);
    }
  });
};

reduce = function(key, values){
  return values;

james-carr

<?xml version="1.0" encoding="UTF-8"?>
<Configure class="org.mortbay.jetty.Server">
<!-- =========================================================== -->
    <!-- Initialize an mbean server                                  -->
    <!-- =========================================================== -->
    <!-- Use the jdk 1.5 platformMBeanServer -->
    <Call id="MBeanServer" class="java.lang.management.ManagementFactory" name="getPlatformMBeanServer"/>

    <!-- =========================================================== -->
    <!-- Initialize the Jetty MBean container                        -->

james-carr

	providedRuntime "org.mortbay.jetty:jetty-management:6.1.25"
	providedRuntime "mx4j:mx4j-tools:2.1.1"
	providedRuntime "mx4j:mx4j:2.1.1"

james-carr

[jettyRun, jettyRunWar]*.with {
	reload='automatic'
	jettyEnvXml = file('src/test/resources/jetty-jndi.xml')
	jettyConfig= file('src/test/resources/jetty-config.xml')
	additionalRuntimeJars =  sourceSets.main.runtimeClasspath
}

james-carr

     System.setProperty(Context.INITIAL_CONTEXT_FACTORY,
            "org.apache.commons.naming.java.javaURLContextFactory");
      System.setProperty(Context.URL_PKG_PREFIXES,
            "org.apache.naming");
      InitialContext ic = new InitialContext();

      ic.createSubcontext("java:");
      ic.createSubcontext("java:/comp");
      ic.createSubcontext("java:/comp/env");
      ic.bind("java:/comp/env/amqpBroker", 'localhost');

james-carr

public class MirroredQueue extends Queue{
   private static Map<String, Object> arguments = new HashMap<String,Object>(){
      {
         put("x-ha-policy", true);
      }
   };

   public MirroredQueue(String name) {
      super(name,true,false,false,arguments);
   }

james-carr

{error,{exit,{{noproc,{gen_server,call,
                                 [file_handle_cache,
                                  {info,[obtain_count]},
                                  infinity]}},
             {gen_server2,call,
                          [{rabbit_mgmt_external_stats,rabbit@brokerm03p},
                           {info,[os_pid,mem_ets,mem_binary,fd_used,fd_total,
                                  sockets_used,sockets_total,mem_used,
                                  mem_limit,mem_alarm,proc_used,proc_total,
                                  statistics_level,erlang_version,uptime,

james-carr

<?xml version="1.0" encoding="UTF-8"?>
<Configure class="org.mortbay.jetty.webapp.WebAppContext">

        <New id="dataSource0" class="org.mortbay.jetty.plus.naming.Resource">
                <Arg></Arg>
                <Arg>java:comp/env/jdbc/a</Arg>
                <Arg>
                         <New class="org.apache.commons.dbcp.BasicDataSource">
                 <Set name="driverClassName">org.hsqldb.jdbcDriver</Set>
                 <Set name="url">jdbc:hsqldb:hsql://localhost/test</Set>