flipkart-incubator / bifrost Goto Github PK

Connection connection = new Connection(Lists.newArrayList("localhost"));

//Start the connection
connection.start();

//Do whatever

//Stop the connection
connection.stop();

class TestAction extends RemoteCallable<Void> {

    public TestAction() {
        super("test");   //Set some name in the constructor
    }

    @Override
    public Void call() throws Exception {
        //Implement your method
        System.out.println("Hello World");
        return null;
    }
}

RemoteCallExecutionServer<Void> executionServer = RemoteCallExecutionServer.<Void>builder(TestAction.class)
                                                                        .objectMapper(mapper)
                                                                        .connection(connection)
                                                                        .concurrency(10)
                                                                        .requestQueue("bifrost-send")
                                                                        .build();

executionServer.start(); //Start the server
...
executionServer.stop(); //To stop the server

BifrostExecutor<Map<String,Object>> executor = BifrostExecutor.<Map<String,Object>>builder(TestAction.class)
                .connection(connection)
                .objectMapper(mapper)
                .requestQueue("bifrost-send")
                .responseQueue("bifrost-recv")
                .executorService(Executors.newFixedThreadPool(10))
                .build();

//To submit job and wait for response
Future<Void> result = scheduler.submit(new TestAction());
result.get();

//To submit job and not wait for response use a RemoteTask<T> wrapper
scheduler.submit(new RemoteTask<Void>(new TestAction());

//To stop the executor
executor.shutdown();