package test.hystrix;

import java.util.concurrent.Future;

import org.apache.log4j.PropertyConfigurator;

public class ClientTest {

    public static void main(String[] args) {
        try {
            PropertyConfigurator.configure("conf/log4j.properties");
            final HelloCommand command = new HelloCommand();
            //            System.out.println("result: " + command.execute());
            //            System.out.println("");

            Future<String> future = command.queue();
            System.out.println("result: " + future.get());
            System.out.println("");

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

@@ -106,16 +106,41 @@
 tor;%0D%0A%0D%0A
+import rx.Observable;%0D%0A%0D%0A
 public c
@@ -630,32 +630,215 @@
 println(%22%22);%0D%0A%0D%0A
+            Observable%3CString%3E observe = command.observe();%0D%0A            observe.asObservable().subscribe((result) -%3E %7B%0D%0A                System.out.println(result);%0D%0A            %7D);%0D%0A
         %7D catch 

add rxjava