Package org.apache.s4.client

Examples of org.apache.s4.client.Driver


    public App loadApp(File s4r, String appName) {

        // TODO handle application upgrade
        logger.info("Loading application [{}] from file [{}]", appName, s4r.getAbsolutePath());

        S4RLoaderFactory loaderFactory = injector.getInstance(S4RLoaderFactory.class);
        S4RLoader cl = loaderFactory.createS4RLoader(s4r.getAbsolutePath());
        try {
            JarFile s4rFile = new JarFile(s4r);
            if (s4rFile.getManifest() == null) {
                logger.warn("Cannot load s4r archive [{}] : missing manifest file");
                return null;
View Full Code Here


            outputStreamsString = args[4];
        }

        String[] outputStreams = outputStreamsString.split(" ");
       
        Driver d = new Driver(hostName, port);
        Reader inputReader = null;
        BufferedReader br = null;
        try {
            if (!d.init()) {
                System.err.println("Driver initialization failed");
                System.exit(1);
            }
           
            d.setReadMode(ReadMode.All);
            if (outputStreams.length > 0) {
                d.setReadMode(ReadMode.Select);
                for (String outputStream : outputStreams) {
                    System.out.printf("Registering output stream name '%s'\n", outputStream);
                    d.readInclude(outputStream);
                }
            }
           
            if (!d.connect()) {
                System.err.println("Driver initialization failed");
                System.exit(1);          
            }
           
            inputReader = new InputStreamReader(System.in);
            br = new BufferedReader(inputReader);

            // send all messages
            for  (String inputLine = null; (inputLine = br.readLine()) != null;) {
                Message m = new Message(streamName, clazz, inputLine);
                d.send(m);
            }
           
            // read all responses
            while (true) {
                Message response = d.recv();
                System.out.println(response);
            }
            /*List<Message> responses = d.recvAll(999999999);
            for (Message message : responses) {
                System.out.println(message);
            }*/
        } catch (IOException e) {
            e.printStackTrace();
        }
        finally {
            try { d.disconnect(); } catch (Exception e) {}
            try { br.close(); } catch (Exception e) {}
            try { inputReader.close(); } catch (Exception e) {}
        }

    }
View Full Code Here

            System.err.println("No class name specified");
            System.exit(1);
        }
        String clazz = args[3];      
       
        Driver d = new Driver(hostName, port);
        Reader inputReader = null;
        BufferedReader br = null;
        try {
            if (!d.init()) {
                System.err.println("Driver initialization failed");
                System.exit(1);
            }
           
            if (!d.connect()) {
                System.err.println("Driver initialization failed");
                System.exit(1);          
            }
           
            inputReader = new InputStreamReader(System.in);
            br = new BufferedReader(inputReader);

            for  (String inputLine = null; (inputLine = br.readLine()) != null;) {
                Message m = new Message(streamName, clazz, inputLine);
                d.send(m);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        finally {
            try { d.disconnect(); } catch (Exception e) {}
            try { br.close(); } catch (Exception e) {}
            try { inputReader.close(); } catch (Exception e) {}
        }

    }
View Full Code Here

        String displayId = "read";
        if (args.length >= 4) {
            displayId = args[3];
        }   
       
        Driver d = new Driver(hostName, port);
        Reader inputReader = null;
        BufferedReader br = null;
        try {
            if (!d.init()) {
                System.err.println("Driver initialization failed");
                System.exit(1);
            }
           
            d.setReadMode(ReadMode.All);
            if (outputStreams.length > 0) {
                d.setReadMode(ReadMode.Select);
                for (String outputStream : outputStreams) {
                    System.out.printf("Registering output stream name '%s'\n", outputStream);
                    d.readInclude(outputStream);
                }
            }
           
            if (!d.connect()) {
                System.err.println("Driver initialization failed");
                System.exit(1);          
            }

            // read all responses
            while (true) {
                Message response = d.recv();
                System.out.println(displayId + ":" + response);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        finally {
            try { d.disconnect(); } catch (Exception e) {}
        }

    }
View Full Code Here

   
    public boolean connect() {
        isConnected = false;
        try {
            System.out.println("Connecting...");
            driver = new Driver(clientAdapterHost, clientAdapterPort);
            boolean isInitialized = driver.init();
            isConnected = isInitialized & driver.connect();
            System.out.println("Connection made: " + isConnected);
            return isConnected;
        }
View Full Code Here

    //
    // }

    @Before
    public void prepareEmitter() throws IOException {
        injector = Guice.createInjector(new DefaultCommModule(Resources.getResource("default.s4.comm.properties")
                .openStream(), "cluster1"), new DefaultCoreModule(Resources.getResource("default.s4.core.properties")
                .openStream()));

        emitter = injector.getInstance(TCPEmitter.class);
View Full Code Here

    }

    public static Injector createInjectorWithNonFailFastZKClients() throws IOException {
        return Guice.createInjector(Modules.override(
                new DefaultCommModule(Resources.getResource("default.s4.comm.properties").openStream(), "cluster1"),
                new DefaultCoreModule(Resources.getResource("default.s4.core.properties").openStream())).with(
                new NonFailFastZookeeperClientsModule()));
    }
View Full Code Here

        super(numTasks);
    }

    public Injector newInjector() {
        try {
            return Guice.createInjector(new DefaultCommModule(Resources.getResource("default.s4.comm.properties")
                    .openStream(), CLUSTER_NAME));
        } catch (IOException e) {
            Assert.fail();
            return null;
        }
View Full Code Here

        super(numTasks);
    }

    @Override
    protected Injector newInjector() throws IOException {
        return Guice.createInjector(new DefaultCommModule(Resources.getResource("udp.s4.comm.properties").openStream(),
                "cluster1"), new UDPCommTestModule());
    }
View Full Code Here

    public final static String CLUSTER_NAME = "cluster1";

    @Test
    public void test() throws Exception {
        Injector injector = Guice.createInjector(
                new DefaultCommModule(Resources.getResource("default.s4.comm.properties").openStream(), CLUSTER_NAME),
                new DefaultCoreModule(Resources.getResource("default.s4.core.properties").openStream()));
        MyApp myApp = injector.getInstance(MyApp.class);

        /* Normally. the container will handle this but this is just a test. */
        myApp.init();
View Full Code Here

TOP

Related Classes of org.apache.s4.client.Driver

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.