Examples of execute()


Examples of com.hazelcast.test.WatchedOperationExecutor.execute()

        final ReplicatedMap<String, String> map1 = instance1.getReplicatedMap("default");
        final ReplicatedMap<String, String> map2 = instance2.getReplicatedMap("default");

        final int operations = 100;
        WatchedOperationExecutor executor = new WatchedOperationExecutor();
        executor.execute(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < operations; i++) {
                    map1.put("foo-" + i, "bar");
                }
View Full Code Here

Examples of com.hazelcast.util.executor.ManagedExecutorService.execute()

            }
        }

        ManagedExecutorService executor = nodeEngine.getExecutionService().getExecutor(ExecutionService.ASYNC_EXECUTOR);
        MigrationRequestTask task = new MigrationRequestTask(tasks, out, replicaVersions, destination);
        executor.execute(task);
    }

    private BufferObjectDataOutput createDataOutput(SerializationService serializationService) {
        return serializationService.createObjectDataOutput(1024 * 32);
    }
View Full Code Here

Examples of com.hazelcast.util.executor.StripedExecutor.execute()

    }

    @Override
    public void handleEvent(final Packet packet) {
        StripedExecutor ex = getExecutor();
        ex.execute(new StripedRunnable() {
            @Override
            public void run() {
                final Data data = packet.getData();
                try {
                    WanReplicationEvent replicationEvent = (WanReplicationEvent) node.nodeEngine.toObject(data);
View Full Code Here

Examples of com.heroku.api.connection.Connection.execute()

     * @param password Heroku password.
     * @return An API key that can be used for subsequent API calls.
     */
    public static String obtainApiKey(String username, String password) {
        Connection tmpConn = ConnectionFactory.get();
        LoginVerification verification = tmpConn.execute(new BasicAuthLogin(username, password), null);
        return verification.getApiKey();
    }

    /**
     * Constructs a HerokuAPI with a {@link Connection} based on the first {@link com.heroku.api.connection.ConnectionProvider}
View Full Code Here

Examples of com.heroku.api.connection.HttpClientConnection.execute()

    @Test(retryAnalyzer = InternalServerErrorAnalyzer.class)
    public void testUserInfo() {
        IntegrationTestConfig.TestUser testUser = CONFIG.getDefaultUser();
        Connection userInfoConnection = new HttpClientConnection();
        UserInfo userInfo = new UserInfo();
        User user = userInfoConnection.execute(userInfo, testUser.getApiKey());
        assertEquals(user.getEmail(), testUser.getUsername());
    }

    @Test(dataProvider = "newApp", retryAnalyzer = InternalServerErrorAnalyzer.class)
    public void testListReleases(App app) {
View Full Code Here

Examples of com.hp.hpl.jena.shared.Command.execute()

    */
    protected static void runTests( boolean internetTest ) throws Exception {
        Class<?> rdfparse = Class.forName( "jena.test.rdfparse" );
        Constructor<?> constructor = rdfparse.getConstructor( new Class[] {boolean.class} );
        Command c = (Command) constructor.newInstance( new Object[] {new Boolean( internetTest ) } );
        c.execute();
//        ARPTests.internet = internetTest;
//        TestRunner.main( new String[] { "-noloading", ARPTests.class.getName()});
        }
}
View Full Code Here

Examples of com.hp.hpl.jena.sparql.engine.main.StageGenerator.execute()

            return input ;

        boolean hideBNodeVars = execCxt.getContext().isTrue(ARQ.hideNonDistiguishedVariables) ;

        StageGenerator gen = StageBuilder.executeInline ;
        QueryIterator qIter = gen.execute(pattern, input, execCxt) ;

        // Remove non-distinguished variables here.
        // Project out only named variables.
        if (hideBNodeVars)
            qIter = new QueryIterDistinguishedVars(qIter, execCxt) ;
View Full Code Here

Examples of com.hp.hpl.jena.sparql.modify.UpdateProcessRemoteBase.execute()

    @Test(expected = HttpException.class)
    public void update_with_auth_01() {
        UpdateRequest updates = UpdateFactory.create("CREATE SILENT GRAPH <http://graph>");
        UpdateProcessRemoteBase ue = (UpdateProcessRemoteBase) UpdateExecutionFactory.createRemote(updates, serviceUpdate);
        // No auth credentials should result in an error
        ue.execute();
    }

    @Test(expected = HttpException.class)
    public void update_with_auth_02() {
        UpdateRequest updates = UpdateFactory.create("CREATE SILENT GRAPH <http://graph>");
View Full Code Here

Examples of com.hp.hpl.jena.update.UpdateProcessor.execute()

    defaultGraphData(gStore, graph1) ;
    QuadDataAcc acc = new QuadDataAcc() ;
    acc.addTriple(triple2) ;
        UpdateDataInsert insert = new UpdateDataInsert(acc) ;
        UpdateProcessor uProc = UpdateExecutionFactory.create(insert, gStore) ;
        uProc.execute();
       
        assertFalse(graphEmpty(gStore.getDefaultGraph())) ;
        assertTrue(graphContains(gStore.getDefaultGraph(), triple1)) ;
        assertTrue(graphContains(gStore.getDefaultGraph(), triple2)) ;
    }
View Full Code Here

Examples of com.hp.hpl.squirrelrdf.ldap.LdapSparqlMap.execute()

    map.addTriple(Triple.create("?paul http://jena.hpl.hp.com/schemas/hpcorp#manager ?manager"));
    map.addTriple(Triple.create("?manager http://xmlns.com/foaf/0.1/name ?name"));
   
    QueryIterator results = new QueryIterSingleton(new BindingRoot());
   
    results = map.execute(results, null);
   
    assertTrue("I have a manager for Paul", results.hasNext());
   
    Binding binding = results.nextBinding();
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.