ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [04/12] incubator-ignite git commit: # IGNITE-45 - Examples
Date Sat, 21 Mar 2015 21:58:09 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicLongExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicLongExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicLongExample.java
deleted file mode 100644
index 5e99393..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicLongExample.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple usage of distributed atomic long.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class IgniteAtomicLongExample {
-    /** Number of retries */
-    private static final int RETRIES = 20;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Atomic long example started.");
-
-            // Make name for atomic long (by which it will be known in the cluster).
-            String atomicName = UUID.randomUUID().toString();
-
-            // Initialize atomic long.
-            final IgniteAtomicLong atomicLong = ignite.atomicLong(atomicName, 0, true);
-
-            System.out.println();
-            System.out.println("Atomic long initial value : " + atomicLong.get() + '.');
-
-            // Try increment atomic long from all nodes.
-            // Note that this node is also part of the ignite cluster.
-            ignite.compute().broadcast(new IgniteCallable<Object>() {
-                @Override public Object call() {
-                    for (int i = 0; i < RETRIES; i++)
-                        System.out.println("AtomicLong value has been incremented: " + atomicLong.incrementAndGet());
-
-                    return null;
-                }
-            });
-
-            System.out.println();
-            System.out.println("Atomic long value after successful CAS: " + atomicLong.get());
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicReferenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicReferenceExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicReferenceExample.java
deleted file mode 100644
index 4632a45..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicReferenceExample.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple usage of distributed atomic reference.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class IgniteAtomicReferenceExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Atomic reference example started.");
-
-            // Make name of atomic reference.
-            final String refName = UUID.randomUUID().toString();
-
-            // Make value of atomic reference.
-            String val = UUID.randomUUID().toString();
-
-            // Initialize atomic reference.
-            IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true);
-
-            System.out.println("Atomic reference initial value : " + ref.get() + '.');
-
-            // Make closure for checking atomic reference value on cluster.
-            IgniteRunnable c = new ReferenceClosure(refName);
-
-            // Check atomic reference on all cluster nodes.
-            ignite.compute().run(c);
-
-            // Make new value of atomic reference.
-            String newVal = UUID.randomUUID().toString();
-
-            System.out.println("Try to change value of atomic reference with wrong expected value.");
-
-            ref.compareAndSet("WRONG EXPECTED VALUE", newVal); // Won't change.
-
-            // Check atomic reference on all cluster nodes.
-            // Atomic reference value shouldn't be changed.
-            ignite.compute().run(c);
-
-            System.out.println("Try to change value of atomic reference with correct expected value.");
-
-            ref.compareAndSet(val, newVal);
-
-            // Check atomic reference on all cluster nodes.
-            // Atomic reference value should be changed.
-            ignite.compute().run(c);
-        }
-
-        System.out.println();
-        System.out.println("Finished atomic reference example...");
-        System.out.println("Check all nodes for output (this node is also part of the cluster).");
-    }
-
-    /**
-     * Obtains atomic reference.
-     */
-    private static class ReferenceClosure implements IgniteRunnable {
-        /** Reference name. */
-        private final String refName;
-
-        /**
-         * @param refName Reference name.
-         */
-        ReferenceClosure(String refName) {
-            this.refName = refName;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            IgniteAtomicReference<String> ref = Ignition.ignite().atomicReference(refName, null, true);
-
-            System.out.println("Atomic reference value is " + ref.get() + '.');
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicSequenceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicSequenceExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicSequenceExample.java
deleted file mode 100644
index 6507534..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicSequenceExample.java
+++ /dev/null
@@ -1,91 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-/**
- * Demonstrates a simple usage of distributed atomic sequence.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class IgniteAtomicSequenceExample {
-    /** Number of retries */
-    private static final int RETRIES = 20;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Cache atomic sequence example started.");
-
-            // Try increment atomic sequence on all cluster nodes. Note that this node is also part of the cluster.
-            ignite.compute().broadcast(new SequenceClosure("example-sequence"));
-
-            System.out.println();
-            System.out.println("Finished atomic sequence example...");
-            System.out.println("Check all nodes for output (this node is also part of the cluster).");
-            System.out.println();
-        }
-    }
-
-    /**
-     * Obtains atomic sequence.
-     */
-    private static class SequenceClosure implements IgniteRunnable {
-        /** Sequence name. */
-        private final String seqName;
-
-        /**
-         * @param seqName Sequence name.
-         */
-        SequenceClosure(String seqName) {
-            this.seqName = seqName;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            // Create sequence. Only one concurrent call will succeed in creation.
-            // Rest of the callers will get already created instance.
-            IgniteAtomicSequence seq = Ignition.ignite().atomicSequence(seqName, 0, true);
-
-            // First value of atomic sequence on this node.
-            long firstVal = seq.get();
-
-            System.out.println("Sequence initial value on local node: " + firstVal);
-
-            for (int i = 0; i < RETRIES; i++)
-                System.out.println("Sequence [currentValue=" + seq.get() + ", afterIncrement=" +
-                    seq.incrementAndGet() + ']');
-
-            System.out.println("Sequence after incrementing [expected=" + (firstVal + RETRIES) + ", actual=" +
-                seq.get() + ']');
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicStampedExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicStampedExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicStampedExample.java
deleted file mode 100644
index fcd2bf2..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteAtomicStampedExample.java
+++ /dev/null
@@ -1,117 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple usage of distributed atomic stamped.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class IgniteAtomicStampedExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Atomic stamped example started.");
-
-            // Make name of atomic stamped.
-            String stampedName = UUID.randomUUID().toString();
-
-            // Make value of atomic stamped.
-            String val = UUID.randomUUID().toString();
-
-            // Make stamp of atomic stamped.
-            String stamp = UUID.randomUUID().toString();
-
-            // Initialize atomic stamped.
-            IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true);
-
-            System.out.println("Atomic stamped initial [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
-
-            // Make closure for checking atomic stamped.
-            IgniteRunnable c = new StampedUpdateClosure(stampedName);
-
-            // Check atomic stamped on all cluster nodes.
-            ignite.compute().broadcast(c);
-
-            // Make new value of atomic stamped.
-            String newVal = UUID.randomUUID().toString();
-
-            // Make new stamp of atomic stamped.
-            String newStamp = UUID.randomUUID().toString();
-
-            System.out.println("Try to change value and stamp of atomic stamped with wrong expected value and stamp.");
-
-            stamped.compareAndSet("WRONG EXPECTED VALUE", newVal, "WRONG EXPECTED STAMP", newStamp);
-
-            // Check atomic stamped on all cluster nodes.
-            // Atomic stamped value and stamp shouldn't be changed.
-            ignite.compute().run(c);
-
-            System.out.println("Try to change value and stamp of atomic stamped with correct value and stamp.");
-
-            stamped.compareAndSet(val, newVal, stamp, newStamp);
-
-            // Check atomic stamped on all cluster nodes.
-            // Atomic stamped value and stamp should be changed.
-            ignite.compute().run(c);
-        }
-
-        System.out.println();
-        System.out.println("Finished atomic stamped example...");
-        System.out.println("Check all nodes for output (this node is also part of the cluster).");
-    }
-
-    /**
-     * Performs update of on an atomic stamped variable in cache.
-     */
-    private static class StampedUpdateClosure implements IgniteRunnable {
-        /** Atomic stamped variable name. */
-        private final String stampedName;
-
-        /**
-         * @param stampedName Atomic stamped variable name.
-         */
-        StampedUpdateClosure(String stampedName) {
-            this.stampedName = stampedName;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            IgniteAtomicStamped<String, String> stamped = Ignition.ignite().
-                atomicStamped(stampedName, null, null, true);
-
-            System.out.println("Atomic stamped [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']');
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteCountDownLatchExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteCountDownLatchExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteCountDownLatchExample.java
deleted file mode 100644
index feff109..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteCountDownLatchExample.java
+++ /dev/null
@@ -1,95 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Demonstrates a simple usage of distributed count down latch.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public class IgniteCountDownLatchExample {
-    /** Number of latch initial count */
-    private static final int INITIAL_COUNT = 10;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     */
-    public static void main(String[] args) {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Cache atomic countdown latch example started.");
-
-            // Make name of count down latch.
-            final String latchName = UUID.randomUUID().toString();
-
-            // Initialize count down latch.
-            IgniteCountDownLatch latch = ignite.countDownLatch(latchName, INITIAL_COUNT, false, true);
-
-            System.out.println("Latch initial value: " + latch.count());
-
-            // Start waiting on the latch on all cluster nodes.
-            for (int i = 0; i < INITIAL_COUNT; i++)
-                ignite.compute().run(new LatchClosure(latchName));
-
-            // Wait for latch to go down which essentially means that all remote closures completed.
-            latch.await();
-
-            System.out.println("All latch closures have completed.");
-        }
-
-        System.out.println();
-        System.out.println("Finished count down latch example...");
-        System.out.println("Check all nodes for output (this node is also part of the cluster).");
-    }
-
-    /**
-     * Closure which simply waits on the latch on all nodes.
-     */
-    private static class LatchClosure implements IgniteRunnable {
-        /** Latch name. */
-        private final String latchName;
-
-        /**
-         * @param latchName Latch name.
-         */
-        LatchClosure(String latchName) {
-            this.latchName = latchName;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            IgniteCountDownLatch latch = Ignition.ignite().countDownLatch(latchName, 1, false, true);
-
-            int newCnt = latch.countDown();
-
-            System.out.println("Counted down [newCnt=" + newCnt + ", nodeId=" + Ignition.ignite().cluster().localNode().id() + ']');
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteQueueExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteQueueExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteQueueExample.java
deleted file mode 100644
index c052ee2..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteQueueExample.java
+++ /dev/null
@@ -1,215 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cache.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Ignite cache distributed queue example. This example demonstrates {@code FIFO} unbounded
- * cache queue.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public class IgniteQueueExample {
-    /** Cache name. */
-    private static final String CACHE_NAME = IgniteQueueExample.class.getSimpleName();
-
-    /** Number of retries */
-    private static final int RETRIES = 20;
-
-    /** Queue instance. */
-    private static IgniteQueue<String> queue;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Ignite queue example started.");
-
-            CacheConfiguration<Object, Object> cfg = new CacheConfiguration<>();
-
-            cfg.setCacheMode(CacheMode.PARTITIONED);
-            cfg.setName(CACHE_NAME);
-            cfg.setAtomicWriteOrderMode(CacheAtomicWriteOrderMode.PRIMARY);
-
-            try (IgniteCache<Object, Object> cache = ignite.createCache(cfg)) {
-                // Make queue name.
-                String queueName = UUID.randomUUID().toString();
-
-                queue = initializeQueue(ignite, queueName);
-
-                readFromQueue(ignite);
-
-                writeToQueue(ignite);
-
-                clearAndRemoveQueue();
-            }
-        }
-
-        System.out.println("Cache queue example finished.");
-    }
-
-    /**
-     * Initialize queue.
-     *
-     * @param ignite Ignite.
-     * @param queueName Name of queue.
-     * @return Queue.
-     * @throws IgniteException If execution failed.
-     */
-    private static IgniteQueue<String> initializeQueue(Ignite ignite, String queueName) throws IgniteException {
-        CollectionConfiguration colCfg = new CollectionConfiguration();
-
-        colCfg.setCacheName(CACHE_NAME);
-
-        // Initialize new FIFO queue.
-        IgniteQueue<String> queue = ignite.queue(queueName, 0, colCfg);
-
-        // Initialize queue items.
-        // We will be use blocking operation and queue size must be appropriated.
-        for (int i = 0; i < ignite.cluster().nodes().size() * RETRIES * 2; i++)
-            queue.put(Integer.toString(i));
-
-        System.out.println("Queue size after initializing: " + queue.size());
-
-        return queue;
-    }
-
-    /**
-     * Read items from head and tail of queue.
-     *
-     * @param ignite Ignite.
-     * @throws IgniteException If failed.
-     */
-    private static void readFromQueue(Ignite ignite) throws IgniteException {
-        final String queueName = queue.name();
-
-        // Read queue items on each node.
-        ignite.compute().broadcast(new QueueClosure(queueName, false));
-
-        System.out.println("Queue size after reading [expected=0, actual=" + queue.size() + ']');
-    }
-
-    /**
-     * Write items into queue.
-     *
-     * @param ignite Ignite.
-     * @throws IgniteException If failed.
-     */
-    private static void writeToQueue(Ignite ignite) throws IgniteException {
-        final String queueName = queue.name();
-
-        // Write queue items on each node.
-        ignite.compute().broadcast(new QueueClosure(queueName, true));
-
-        System.out.println("Queue size after writing [expected=" + ignite.cluster().nodes().size() * RETRIES +
-            ", actual=" + queue.size() + ']');
-
-        System.out.println("Iterate over queue.");
-
-        // Iterate over queue.
-        for (String item : queue)
-            System.out.println("Queue item: " + item);
-    }
-
-    /**
-     * Clear and remove queue.
-     *
-     * @throws IgniteException If execution failed.
-     */
-    private static void clearAndRemoveQueue() throws IgniteException {
-        System.out.println("Queue size before clearing: " + queue.size());
-
-        // Clear queue.
-        queue.clear();
-
-        System.out.println("Queue size after clearing: " + queue.size());
-
-        // Remove queue.
-        queue.close();
-
-        // Try to work with removed queue.
-        try {
-            queue.poll();
-        }
-        catch (IllegalStateException expected) {
-            System.out.println("Expected exception - " + expected.getMessage());
-        }
-    }
-
-    /**
-     * Closure to populate or poll the queue.
-     */
-    private static class QueueClosure implements IgniteRunnable {
-        /** Queue name. */
-        private final String queueName;
-
-        /** Flag indicating whether to put or poll. */
-        private final boolean put;
-
-        /**
-         * @param queueName Queue name.
-         * @param put Flag indicating whether to put or poll.
-         */
-        QueueClosure(String queueName, boolean put) {
-            this.queueName = queueName;
-            this.put = put;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            IgniteQueue<String> queue = Ignition.ignite().queue(queueName, 0, null);
-
-            if (put) {
-                UUID locId = Ignition.ignite().cluster().localNode().id();
-
-                for (int i = 0; i < RETRIES; i++) {
-                    String item = locId + "_" + Integer.toString(i);
-
-                    queue.put(item);
-
-                    System.out.println("Queue item has been added: " + item);
-                }
-            }
-            else {
-                // Take items from queue head.
-                for (int i = 0; i < RETRIES; i++)
-                    System.out.println("Queue item has been read from queue head: " + queue.take());
-
-                // Take items from queue head once again.
-                for (int i = 0; i < RETRIES; i++)
-                    System.out.println("Queue item has been read from queue head: " + queue.poll());
-            }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteSetExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteSetExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteSetExample.java
deleted file mode 100644
index 9c78591..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/IgniteSetExample.java
+++ /dev/null
@@ -1,197 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cache.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-
-/**
- * Ignite cache distributed set example.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will
- * start node with {@code examples/config/example-ignite.xml} configuration.
- */
-public class IgniteSetExample {
-    /** Cache name. */
-    private static final String CACHE_NAME = IgniteSetExample.class.getSimpleName();
-
-    /** Set instance. */
-    private static IgniteSet<String> set;
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Ignite set example started.");
-
-            CacheConfiguration<Integer, String> cfg = new CacheConfiguration<>();
-
-            cfg.setCacheMode(CacheMode.PARTITIONED);
-            cfg.setName(CACHE_NAME);
-            cfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
-
-            NearCacheConfiguration<Integer, String> nearCacheCfg = new NearCacheConfiguration<>();
-
-            try (IgniteCache<Integer, String> cache = ignite.createCache(cfg, nearCacheCfg)) {
-                // Make set name.
-                String setName = UUID.randomUUID().toString();
-
-                set = initializeSet(ignite, setName);
-
-                writeToSet(ignite);
-
-                clearAndRemoveSet();
-            }
-        }
-
-        System.out.println("Ignite set example finished.");
-    }
-
-    /**
-     * Initialize set.
-     *
-     * @param ignite Ignite.
-     * @param setName Name of set.
-     * @return Set.
-     * @throws IgniteException If execution failed.
-     */
-    private static IgniteSet<String> initializeSet(Ignite ignite, String setName) throws IgniteException {
-        CollectionConfiguration setCfg = new CollectionConfiguration();
-
-        setCfg.setCacheName(CACHE_NAME);
-
-        // Initialize new set.
-        IgniteSet<String> set = ignite.set(setName, setCfg);
-
-        // Initialize set items.
-        for (int i = 0; i < 10; i++)
-            set.add(Integer.toString(i));
-
-        System.out.println("Set size after initializing: " + set.size());
-
-        return set;
-    }
-
-    /**
-     * Write items into set.
-     *
-     * @param ignite Ignite.
-     * @throws IgniteException If failed.
-     */
-    private static void writeToSet(Ignite ignite) throws IgniteException {
-        final String setName = set.name();
-
-        // Write set items on each node.
-        ignite.compute().broadcast(new SetClosure(setName));
-
-        System.out.println("Set size after writing [expected=" + (10 + ignite.cluster().nodes().size() * 5) +
-            ", actual=" + set.size() + ']');
-
-        System.out.println("Iterate over set.");
-
-        // Iterate over set.
-        for (String item : set)
-            System.out.println("Set item: " + item);
-
-        // Set API usage examples.
-        if (!set.contains("0"))
-            throw new RuntimeException("Set should contain '0' among its elements.");
-
-        if (set.add("0"))
-            throw new RuntimeException("Set should not allow duplicates.");
-
-        if (!set.remove("0"))
-            throw new RuntimeException("Set should correctly remove elements.");
-
-        if (set.contains("0"))
-            throw new RuntimeException("Set should not contain '0' among its elements.");
-
-        if (!set.add("0"))
-            throw new RuntimeException("Set should correctly add new elements.");
-    }
-
-    /**
-     * Clear and remove set.
-     *
-     * @throws IgniteException If execution failed.
-     */
-    private static void clearAndRemoveSet() throws IgniteException {
-        System.out.println("Set size before clearing: " + set.size());
-
-        // Clear set.
-        set.clear();
-
-        System.out.println("Set size after clearing: " + set.size());
-
-        // Remove set.
-        set.close();
-
-        System.out.println("Set was removed: " + set.removed());
-
-        // Try to work with removed set.
-        try {
-            set.contains("1");
-        }
-        catch (IllegalStateException expected) {
-            System.out.println("Expected exception - " + expected.getMessage());
-        }
-    }
-
-    /**
-     * Closure to populate the set.
-     */
-    private static class SetClosure implements IgniteRunnable {
-        /** Set name. */
-        private final String setName;
-
-        /**
-         * @param setName Set name.
-         */
-        SetClosure(String setName) {
-            this.setName = setName;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void run() {
-            IgniteSet<String> set = Ignition.ignite().set(setName, null);
-
-            UUID locId = Ignition.ignite().cluster().localNode().id();
-
-            for (int i = 0; i < 5; i++) {
-                String item = locId + "_" + Integer.toString(i);
-
-                set.add(item);
-
-                System.out.println("Set item has been added: " + item);
-            }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/package-info.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/package-info.java b/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/package-info.java
deleted file mode 100644
index 041b0c2..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/datastructures/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Demonstrates using of blocking and non-blocking queues and atomic data structures.
- */
-package org.apache.ignite.examples.java7.datastructures;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/events/EventsExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/events/EventsExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/events/EventsExample.java
deleted file mode 100644
index 612c445..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/events/EventsExample.java
+++ /dev/null
@@ -1,144 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.events;
-
-import org.apache.ignite.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.events.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-
-import static org.apache.ignite.events.EventType.*;
-
-/**
- * Demonstrates event consume API that allows to register event listeners on remote nodes.
- * Note that ignite events are disabled by default and must be specifically enabled,
- * just like in {@code examples/config/example-ignite.xml} file.
- * <p>
- * Remote nodes should always be started with configuration: {@code 'ignite.sh examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start
- * node with {@code examples/config/example-ignite.xml} configuration.
- */
-public class EventsExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            System.out.println();
-            System.out.println(">>> Events API example started.");
-
-            // Listen to events happening on local node.
-            localListen();
-
-            // Listen to events happening on all cluster nodes.
-            remoteListen();
-
-            // Wait for a while while callback is notified about remaining puts.
-            Thread.sleep(1000);
-        }
-    }
-
-    /**
-     * Listen to events that happen only on local node.
-     *
-     * @throws IgniteException If failed.
-     */
-    private static void localListen() throws IgniteException {
-        System.out.println();
-        System.out.println(">>> Local event listener example.");
-
-        Ignite ignite = Ignition.ignite();
-
-        IgnitePredicate<TaskEvent> lsnr = new IgnitePredicate<TaskEvent>() {
-            @Override public boolean apply(TaskEvent evt) {
-                System.out.println("Received task event [evt=" + evt.name() + ", taskName=" + evt.taskName() + ']');
-
-                return true; // Return true to continue listening.
-            }
-        };
-
-        // Register event listener for all local task execution events.
-        ignite.events().localListen(lsnr, EVTS_TASK_EXECUTION);
-
-        // Generate task events.
-        ignite.compute().withName("example-event-task").run(new IgniteRunnable() {
-            @Override public void run() {
-                System.out.println("Executing sample job.");
-            }
-        });
-
-        // Unsubscribe local task event listener.
-        ignite.events().stopLocalListen(lsnr);
-    }
-
-    /**
-     * Listen to events coming from all cluster nodes.
-     *
-     * @throws IgniteException If failed.
-     */
-    private static void remoteListen() throws IgniteException {
-        System.out.println();
-        System.out.println(">>> Remote event listener example.");
-
-        // This optional local callback is called for each event notification
-        // that passed remote predicate listener.
-        IgniteBiPredicate<UUID, TaskEvent> locLsnr = new IgniteBiPredicate<UUID, TaskEvent>() {
-            @Override public boolean apply(UUID nodeId, TaskEvent evt) {
-                // Remote filter only accepts tasks whose name being with "good-task" prefix.
-                assert evt.taskName().startsWith("good-task");
-
-                System.out.println("Received task event [evt=" + evt.name() + ", taskName=" + evt.taskName());
-
-                return true; // Return true to continue listening.
-            }
-        };
-
-        // Remote filter which only accepts tasks whose name begins with "good-task" prefix.
-        IgnitePredicate<TaskEvent> rmtLsnr = new IgnitePredicate<TaskEvent>() {
-            @Override public boolean apply(TaskEvent evt) {
-                return evt.taskName().startsWith("good-task");
-            }
-        };
-
-        Ignite ignite = Ignition.ignite();
-
-        // Register event listeners on all nodes to listen for task events.
-        ignite.events().remoteListen(locLsnr, rmtLsnr, EVTS_TASK_EXECUTION);
-
-        // Generate task events.
-        for (int i = 0; i < 10; i++) {
-            ignite.compute().withName(i < 5 ? "good-task-" + i : "bad-task-" + i).run(new IgniteRunnable() {
-                // Auto-inject task session.
-                @TaskSessionResource
-                private ComputeTaskSession ses;
-
-                @Override public void run() {
-                    System.out.println("Executing sample job for task: " + ses.getTaskName());
-                }
-            });
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/events/package-info.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/events/package-info.java b/examples/src/main/java/org/apache/ignite/examples/java7/events/package-info.java
deleted file mode 100644
index dbd9c27..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/events/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Demonstrates events management API.
- */
-package org.apache.ignite.examples.java7.events;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsExample.java
deleted file mode 100644
index 97d0d83..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsExample.java
+++ /dev/null
@@ -1,278 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.igfs;
-
-import org.apache.ignite.*;
-import org.apache.ignite.igfs.*;
-import org.jetbrains.annotations.*;
-
-import java.io.*;
-import java.util.*;
-
-/**
- * Example that shows usage of {@link org.apache.ignite.IgniteFileSystem} API. It starts a node with {@code IgniteFs}
- * configured and performs several file system operations (create, write, append, read and delete
- * files, create, list and delete directories).
- * <p>
- * Remote nodes should always be started with configuration file which includes
- * IGFS: {@code 'ignite.sh examples/config/filesystem/example-igfs.xml'}.
- * <p>
- * Alternatively you can run {@link IgfsNodeStartup} in another JVM which will start
- * node with {@code examples/config/filesystem/example-igfs.xml} configuration.
- */
-public final class IgfsExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        Ignite ignite = Ignition.start("examples/config/filesystem/example-igfs.xml");
-
-        System.out.println();
-        System.out.println(">>> IGFS example started.");
-
-        try {
-            // Get an instance of Ignite File System.
-            IgniteFileSystem fs = ignite.fileSystem("igfs");
-
-            // Working directory path.
-            IgfsPath workDir = new IgfsPath("/examples/fs");
-
-            // Cleanup working directory.
-            delete(fs, workDir);
-
-            // Create empty working directory.
-            mkdirs(fs, workDir);
-
-            // Print information for working directory.
-            printInfo(fs, workDir);
-
-            // File path.
-            IgfsPath filePath = new IgfsPath(workDir, "file.txt");
-
-            // Create file.
-            create(fs, filePath, new byte[] {1, 2, 3});
-
-            // Print information for file.
-            printInfo(fs, filePath);
-
-            // Append more data to previously created file.
-            append(fs, filePath, new byte[] {4, 5});
-
-            // Print information for file.
-            printInfo(fs, filePath);
-
-            // Read data from file.
-            read(fs, filePath);
-
-            // Delete file.
-            delete(fs, filePath);
-
-            // Print information for file.
-            printInfo(fs, filePath);
-
-            // Create several files.
-            for (int i = 0; i < 5; i++)
-                create(fs, new IgfsPath(workDir, "file-" + i + ".txt"), null);
-
-            list(fs, workDir);
-        }
-        finally {
-            Ignition.stop(false);
-        }
-    }
-
-    /**
-     * Deletes file or directory. If directory
-     * is not empty, it's deleted recursively.
-     *
-     * @param fs IGFS.
-     * @param path File or directory path.
-     * @throws IgniteException In case of error.
-     */
-    private static void delete(IgniteFileSystem fs, IgfsPath path) throws IgniteException {
-        assert fs != null;
-        assert path != null;
-
-        if (fs.exists(path)) {
-            boolean isFile = fs.info(path).isFile();
-
-            try {
-                fs.delete(path, true);
-
-                System.out.println();
-                System.out.println(">>> Deleted " + (isFile ? "file" : "directory") + ": " + path);
-            }
-            catch (IgfsException e) {
-                System.out.println();
-                System.out.println(">>> Failed to delete " + (isFile ? "file" : "directory") + " [path=" + path +
-                    ", msg=" + e.getMessage() + ']');
-            }
-        }
-        else {
-            System.out.println();
-            System.out.println(">>> Won't delete file or directory (doesn't exist): " + path);
-        }
-    }
-
-    /**
-     * Creates directories.
-     *
-     * @param fs IGFS.
-     * @param path Directory path.
-     * @throws IgniteException In case of error.
-     */
-    private static void mkdirs(IgniteFileSystem fs, IgfsPath path) throws IgniteException {
-        assert fs != null;
-        assert path != null;
-
-        try {
-            fs.mkdirs(path);
-
-            System.out.println();
-            System.out.println(">>> Created directory: " + path);
-        }
-        catch (IgfsException e) {
-            System.out.println();
-            System.out.println(">>> Failed to create a directory [path=" + path + ", msg=" + e.getMessage() + ']');
-        }
-
-        System.out.println();
-    }
-
-    /**
-     * Creates file and writes provided data to it.
-     *
-     * @param fs IGFS.
-     * @param path File path.
-     * @param data Data.
-     * @throws IgniteException If file can't be created.
-     * @throws IOException If data can't be written.
-     */
-    private static void create(IgniteFileSystem fs, IgfsPath path, @Nullable byte[] data)
-        throws IgniteException, IOException {
-        assert fs != null;
-        assert path != null;
-
-        try (OutputStream out = fs.create(path, true)) {
-            System.out.println();
-            System.out.println(">>> Created file: " + path);
-
-            if (data != null) {
-                out.write(data);
-
-                System.out.println();
-                System.out.println(">>> Wrote data to file: " + path);
-            }
-        }
-
-        System.out.println();
-    }
-
-    /**
-     * Opens file and appends provided data to it.
-     *
-     * @param fs IGFS.
-     * @param path File path.
-     * @param data Data.
-     * @throws IgniteException If file can't be created.
-     * @throws IOException If data can't be written.
-     */
-    private static void append(IgniteFileSystem fs, IgfsPath path, byte[] data) throws IgniteException, IOException {
-        assert fs != null;
-        assert path != null;
-        assert data != null;
-        assert fs.info(path).isFile();
-
-        try (OutputStream out = fs.append(path, true)) {
-            System.out.println();
-            System.out.println(">>> Opened file: " + path);
-
-            out.write(data);
-        }
-
-        System.out.println();
-        System.out.println(">>> Appended data to file: " + path);
-    }
-
-    /**
-     * Opens file and reads it to byte array.
-     *
-     * @param fs IgniteFs.
-     * @param path File path.
-     * @throws IgniteException If file can't be opened.
-     * @throws IOException If data can't be read.
-     */
-    private static void read(IgniteFileSystem fs, IgfsPath path) throws IgniteException, IOException {
-        assert fs != null;
-        assert path != null;
-        assert fs.info(path).isFile();
-
-        byte[] data = new byte[(int)fs.info(path).length()];
-
-        try (IgfsInputStream in = fs.open(path)) {
-            in.read(data);
-        }
-
-        System.out.println();
-        System.out.println(">>> Read data from " + path + ": " + Arrays.toString(data));
-    }
-
-    /**
-     * Lists files in directory.
-     *
-     * @param fs IGFS.
-     * @param path Directory path.
-     * @throws IgniteException In case of error.
-     */
-    private static void list(IgniteFileSystem fs, IgfsPath path) throws IgniteException {
-        assert fs != null;
-        assert path != null;
-        assert fs.info(path).isDirectory();
-
-        Collection<IgfsPath> files = fs.listPaths(path);
-
-        if (files.isEmpty()) {
-            System.out.println();
-            System.out.println(">>> No files in directory: " + path);
-        }
-        else {
-            System.out.println();
-            System.out.println(">>> List of files in directory: " + path);
-
-            for (IgfsPath f : files)
-                System.out.println(">>>     " + f.name());
-        }
-
-        System.out.println();
-    }
-
-    /**
-     * Prints information for file or directory.
-     *
-     * @param fs IGFS.
-     * @param path File or directory path.
-     * @throws IgniteException In case of error.
-     */
-    private static void printInfo(IgniteFileSystem fs, IgfsPath path) throws IgniteException {
-        System.out.println();
-        System.out.println("Information for " + path + ": " + fs.info(path));
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsMapReduceExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsMapReduceExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsMapReduceExample.java
deleted file mode 100644
index 757d2dd..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsMapReduceExample.java
+++ /dev/null
@@ -1,249 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.igfs;
-
-import org.apache.ignite.*;
-import org.apache.ignite.compute.*;
-import org.apache.ignite.igfs.*;
-import org.apache.ignite.igfs.mapreduce.*;
-import org.apache.ignite.igfs.mapreduce.records.*;
-
-import java.io.*;
-import java.util.*;
-
-/**
- * Example that shows how to use {@link org.apache.ignite.igfs.mapreduce.IgfsTask} to find lines matching particular pattern in the file in pretty
- * the same way as {@code grep} command does.
- * <p>
- * Remote nodes should always be started with configuration file which includes
- * IGFS: {@code 'ignite.sh examples/config/filesystem/example-igfs.xml'}.
- * <p>
- * Alternatively you can run {@link IgfsNodeStartup} in another JVM which will start
- * node with {@code examples/config/filesystem/example-igfs.xml} configuration.
- */
-public class IgfsMapReduceExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments. First argument is file name, second argument is regex to look for.
-     * @throws Exception If failed.
-     */
-    public static void main(String[] args) throws Exception {
-        if (args.length == 0)
-            System.out.println("Please provide file name and regular expression.");
-        else if (args.length == 1)
-            System.out.println("Please provide regular expression.");
-        else {
-            try (Ignite ignite = Ignition.start("examples/config/filesystem/example-igfs.xml")) {
-                System.out.println();
-                System.out.println(">>> IGFS map reduce example started.");
-
-                // Prepare arguments.
-                String fileName = args[0];
-
-                File file = new File(fileName);
-
-                String regexStr = args[1];
-
-                // Get an instance of Ignite File System.
-                IgniteFileSystem fs = ignite.fileSystem("igfs");
-
-                // Working directory path.
-                IgfsPath workDir = new IgfsPath("/examples/fs");
-
-                // Write file to IGFS.
-                IgfsPath fsPath = new IgfsPath(workDir, file.getName());
-
-                writeFile(fs, fsPath, file);
-
-                Collection<Line> lines = fs.execute(new GrepTask(), IgfsNewLineRecordResolver.NEW_LINE,
-                    Collections.singleton(fsPath), regexStr);
-
-                if (lines.isEmpty()) {
-                    System.out.println();
-                    System.out.println("No lines were found.");
-                }
-                else {
-                    for (Line line : lines)
-                        print(line.fileLine());
-                }
-            }
-        }
-    }
-
-    /**
-     * Write file to the Ignite file system.
-     *
-     * @param fs Ignite file system.
-     * @param fsPath Ignite file system path.
-     * @param file File to write.
-     * @throws Exception In case of exception.
-     */
-    private static void writeFile(IgniteFileSystem fs, IgfsPath fsPath, File file) throws Exception {
-        System.out.println();
-        System.out.println("Copying file to IGFS: " + file);
-
-        try (
-            IgfsOutputStream os = fs.create(fsPath, true);
-            FileInputStream fis = new FileInputStream(file)
-        ) {
-            byte[] buf = new byte[2048];
-
-            int read = fis.read(buf);
-
-            while (read != -1) {
-                os.write(buf, 0, read);
-
-                read = fis.read(buf);
-            }
-        }
-    }
-
-    /**
-     * Print particular string.
-     *
-     * @param str String.
-     */
-    private static void print(String str) {
-        System.out.println(">>> " + str);
-    }
-
-    /**
-     * Grep task.
-     */
-    private static class GrepTask extends IgfsTask<String, Collection<Line>> {
-        /** {@inheritDoc} */
-        @Override public IgfsJob createJob(IgfsPath path, IgfsFileRange range,
-            IgfsTaskArgs<String> args) {
-            return new GrepJob(args.userArgument());
-        }
-
-        /** {@inheritDoc} */
-        @Override public Collection<Line> reduce(List<ComputeJobResult> results) {
-            Collection<Line> lines = new TreeSet<>(new Comparator<Line>() {
-                @Override public int compare(Line line1, Line line2) {
-                    return line1.rangePosition() < line2.rangePosition() ? -1 :
-                        line1.rangePosition() > line2.rangePosition() ? 1 : line1.lineIndex() - line2.lineIndex();
-                }
-            });
-
-            for (ComputeJobResult res : results) {
-                if (res.getException() != null)
-                    throw res.getException();
-
-                Collection<Line> line = res.getData();
-
-                if (line != null)
-                    lines.addAll(line);
-            }
-
-            return lines;
-        }
-    }
-
-    /**
-     * Grep job.
-     */
-    private static class GrepJob extends IgfsInputStreamJobAdapter {
-        /** Regex string. */
-        private final String regex;
-
-        /**
-         * Constructor.
-         *
-         * @param regex Regex string.
-         */
-        private GrepJob(String regex) {
-            this.regex = regex;
-        }
-
-        /**  {@inheritDoc} */
-        @Override public Object execute(IgniteFileSystem igfs, IgfsRangeInputStream in) throws IgniteException, IOException {
-            Collection<Line> res = null;
-
-            long start = in.startOffset();
-
-            try (BufferedReader br = new BufferedReader(new InputStreamReader(in))) {
-                int ctr = 0;
-
-                String line = br.readLine();
-
-                while (line != null) {
-                    if (line.matches(".*" + regex + ".*")) {
-                        if (res == null)
-                            res = new HashSet<>();
-
-                        res.add(new Line(start, ctr++, line));
-                    }
-
-                    line = br.readLine();
-                }
-            }
-
-            return res;
-        }
-    }
-
-    /**
-     * Single file line with it's position.
-     */
-    private static class Line {
-        /** Line start position in the file. */
-        private long rangePos;
-
-        /** Matching line index within the range. */
-        private final int lineIdx;
-
-        /** File line. */
-        private String line;
-
-        /**
-         * Constructor.
-         *
-         * @param rangePos Range position.
-         * @param lineIdx Matching line index within the range.
-         * @param line File line.
-         */
-        private Line(long rangePos, int lineIdx, String line) {
-            this.rangePos = rangePos;
-            this.lineIdx = lineIdx;
-            this.line = line;
-        }
-
-        /**
-         * @return Range position.
-         */
-        public long rangePosition() {
-            return rangePos;
-        }
-
-        /**
-         * @return Matching line index within the range.
-         */
-        public int lineIndex() {
-            return lineIdx;
-        }
-
-        /**
-         * @return File line.
-         */
-        public String fileLine() {
-            return line;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsNodeStartup.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsNodeStartup.java
deleted file mode 100644
index d25b6ff..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/IgfsNodeStartup.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.igfs;
-
-import org.apache.ignite.*;
-
-/**
- * Starts up an empty node with IGFS configuration.
- * You can also start a stand-alone Ignite instance by passing the path
- * to configuration file to {@code 'ignite.{sh|bat}'} script, like so:
- * {@code 'ignite.sh examples/config/filesystem/example-igfs.xml'}.
- * <p>
- * The difference is that running this class from IDE adds all example classes to classpath
- * but running from command line doesn't.
- */
-public class IgfsNodeStartup {
-    /**
-     * Start up an empty node with specified cache configuration.
-     *
-     * @param args Command line arguments, none required.
-     * @throws IgniteException If example execution failed.
-     */
-    public static void main(String[] args) throws IgniteException {
-        Ignition.start("examples/config/filesystem/example-igfs.xml");
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/igfs/package-info.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/package-info.java b/examples/src/main/java/org/apache/ignite/examples/java7/igfs/package-info.java
deleted file mode 100644
index b514112..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/igfs/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Demonstrates usage of Ignite File System.
- */
-package org.apache.ignite.examples.java7.igfs;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingExample.java
deleted file mode 100644
index dee2807..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingExample.java
+++ /dev/null
@@ -1,173 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.messaging;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-import java.util.concurrent.*;
-
-/**
- * Example that demonstrates how to exchange messages between nodes. Use such
- * functionality for cases when you need to communicate to other nodes outside
- * of ignite task.
- * <p>
- * To run this example you must have at least one remote node started.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public final class MessagingExample {
-    /** Number of messages. */
-    private static final int MESSAGES_NUM = 10;
-
-    /** Message topics. */
-    private enum TOPIC { ORDERED, UNORDERED }
-
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println(">>> Messaging example started.");
-
-            // Group for remote nodes.
-            ClusterGroup rmts = ignite.cluster().forRemotes();
-
-            // Listen for messages from remote nodes to make sure that they received all the messages.
-            int msgCnt = rmts.nodes().size() * MESSAGES_NUM;
-
-            CountDownLatch orderedLatch = new CountDownLatch(msgCnt);
-            CountDownLatch unorderedLatch = new CountDownLatch(msgCnt);
-
-            localListen(ignite.message(ignite.cluster().forLocal()), orderedLatch, unorderedLatch);
-
-            // Register listeners on all cluster nodes.
-            startListening(ignite.message(rmts));
-
-            // Send unordered messages to all remote nodes.
-            for (int i = 0; i < MESSAGES_NUM; i++)
-                ignite.message(rmts).send(TOPIC.UNORDERED, Integer.toString(i));
-
-            System.out.println(">>> Finished sending unordered messages.");
-
-            // Send ordered messages to all remote nodes.
-            for (int i = 0; i < MESSAGES_NUM; i++)
-                ignite.message(rmts).sendOrdered(TOPIC.ORDERED, Integer.toString(i), 0);
-
-            System.out.println(">>> Finished sending ordered messages.");
-            System.out.println(">>> Check output on all nodes for message printouts.");
-            System.out.println(">>> Will wait for messages acknowledgements from all remote nodes.");
-
-            orderedLatch.await();
-            unorderedLatch.await();
-
-            System.out.println(">>> Messaging example finished.");
-        }
-    }
-
-    /**
-     * Start listening to messages on remote cluster nodes.
-     *
-     * @param msg Ignite messaging.
-     */
-    private static void startListening(IgniteMessaging msg) {
-        // Add ordered message listener.
-        msg.remoteListen(TOPIC.ORDERED, new IgniteBiPredicate<UUID, String>() {
-            @IgniteInstanceResource
-            private Ignite ignite;
-
-            @Override public boolean apply(UUID nodeId, String msg) {
-                System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
-
-                try {
-                    ignite.message(ignite.cluster().forNodeId(nodeId)).send(TOPIC.ORDERED, msg);
-                }
-                catch (IgniteException e) {
-                    e.printStackTrace();
-                }
-
-                return true; // Return true to continue listening.
-            }
-        });
-
-        // Add unordered message listener.
-        msg.remoteListen(TOPIC.UNORDERED, new IgniteBiPredicate<UUID, String>() {
-            @IgniteInstanceResource
-            private Ignite ignite;
-
-            @Override public boolean apply(UUID nodeId, String msg) {
-                System.out.println("Received unordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
-
-                try {
-                    ignite.message(ignite.cluster().forNodeId(nodeId)).send(TOPIC.UNORDERED, msg);
-                }
-                catch (IgniteException e) {
-                    e.printStackTrace();
-                }
-
-                return true; // Return true to continue listening.
-            }
-        });
-    }
-
-    /**
-     * Listen for messages from remote nodes.
-     *
-     * @param msg Ignite messaging.
-     * @param orderedLatch Latch for ordered messages acks.
-     * @param unorderedLatch Latch for unordered messages acks.
-     */
-    private static void localListen(
-        IgniteMessaging msg,
-        final CountDownLatch orderedLatch,
-        final CountDownLatch unorderedLatch
-    ) {
-        msg.localListen(TOPIC.ORDERED, new IgniteBiPredicate<UUID, String>() {
-            @Override public boolean apply(UUID nodeId, String msg) {
-                orderedLatch.countDown();
-
-                // Return true to continue listening, false to stop.
-                return orderedLatch.getCount() > 0;
-            }
-        });
-
-        msg.localListen(TOPIC.UNORDERED, new IgniteBiPredicate<UUID, String>() {
-            @Override public boolean apply(UUID nodeId, String msg) {
-                unorderedLatch.countDown();
-
-                // Return true to continue listening, false to stop.
-                return unorderedLatch.getCount() > 0;
-            }
-        });
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongExample.java
deleted file mode 100644
index cc2d114..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongExample.java
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.messaging;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.internal.util.lang.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.resources.*;
-
-import java.util.*;
-import java.util.concurrent.*;
-
-/**
- * Demonstrates simple message exchange between local and remote nodes.
- * <p>
- * To run this example you must have at least one remote node started.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class MessagingPingPongExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     * @throws Exception If example execution failed.
-     */
-    public static void main(String[] args) throws Exception {
-        // Game is played over the default ignite.
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println(">>> Messaging ping-pong example started.");
-
-            // Pick random remote node as a partner.
-            ClusterGroup nodeB = ignite.cluster().forRemotes().forRandom();
-
-            // Note that both nodeA and nodeB will always point to
-            // same nodes regardless of whether they were implicitly
-            // serialized and deserialized on another node as part of
-            // anonymous closure's state during its remote execution.
-
-            // Set up remote player.
-            ignite.message(nodeB).remoteListen(null, new IgniteBiPredicate<UUID, String>() {
-                /** This will be injected on node listener comes to. */
-                @IgniteInstanceResource
-                private Ignite ignite;
-
-                @Override public boolean apply(UUID nodeId, String rcvMsg) {
-                    System.out.println("Received message [msg=" + rcvMsg + ", sender=" + nodeId + ']');
-
-                    try {
-                        if ("PING".equals(rcvMsg)) {
-                            ignite.message(ignite.cluster().forNodeId(nodeId)).send(null, "PONG");
-
-                            return true; // Continue listening.
-                        }
-
-                        return false; // Unsubscribe.
-                    }
-                    catch (IgniteException e) {
-                        throw new GridClosureException(e);
-                    }
-                }
-            });
-
-            int MAX_PLAYS = 10;
-
-            final CountDownLatch cnt = new CountDownLatch(MAX_PLAYS);
-
-            // Set up local player.
-            ignite.message().localListen(null, new IgniteBiPredicate<UUID, String>() {
-                @Override public boolean apply(UUID nodeId, String rcvMsg) {
-                    System.out.println("Received message [msg=" + rcvMsg + ", sender=" + nodeId + ']');
-
-                    try {
-                        if (cnt.getCount() == 1) {
-                            ignite.message(ignite.cluster().forNodeId(nodeId)).send(null, "STOP");
-
-                            cnt.countDown();
-
-                            return false; // Stop listening.
-                        }
-                        else if ("PONG".equals(rcvMsg))
-                            ignite.message(ignite.cluster().forNodeId(nodeId)).send(null, "PING");
-                        else
-                            throw new RuntimeException("Received unexpected message: " + rcvMsg);
-
-                        cnt.countDown();
-
-                        return true; // Continue listening.
-                    }
-                    catch (IgniteException e) {
-                        throw new GridClosureException(e);
-                    }
-                }
-            });
-
-            // Serve!
-            ignite.message(nodeB).send(null, "PING");
-
-            // Wait til the game is over.
-            try {
-                cnt.await();
-            }
-            catch (InterruptedException e) {
-                System.err.println("Hm... let us finish the game!\n" + e);
-            }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongListenActorExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongListenActorExample.java b/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongListenActorExample.java
deleted file mode 100644
index f5c5514..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/MessagingPingPongListenActorExample.java
+++ /dev/null
@@ -1,106 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.java7.messaging;
-
-import org.apache.ignite.*;
-import org.apache.ignite.cluster.*;
-import org.apache.ignite.examples.java7.*;
-import org.apache.ignite.messaging.*;
-
-import java.util.*;
-import java.util.concurrent.*;
-
-/**
- * Demonstrates messaging with {@link MessagingListenActor} convenience adapter.
- * <p>
- * To run this example you must have at least one remote node started.
- * <p>
- * Remote nodes should always be started with special configuration file which
- * enables P2P class loading: {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in another JVM which will start node
- * with {@code examples/config/example-ignite.xml} configuration.
- */
-public class MessagingPingPongListenActorExample {
-    /**
-     * Executes example.
-     *
-     * @param args Command line arguments, none required.
-     */
-    public static void main(String[] args) {
-        // Game is played over the default ignite.
-        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
-            if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))
-                return;
-
-            System.out.println();
-            System.out.println(">>> Messaging ping-pong listen actor example started.");
-
-            // Pick first remote node as a partner.
-            Collection<ClusterNode> rmtNodes = ignite.cluster().forRemotes().nodes();
-
-            ClusterGroup nodeB = ignite.cluster().forNode(rmtNodes.iterator().next());
-
-            // Note that both nodeA and nodeB will always point to
-            // same nodes regardless of whether they were implicitly
-            // serialized and deserialized on another node as part of
-            // anonymous closure's state during its remote execution.
-
-            // Set up remote player.
-            ignite.message(nodeB).remoteListen(null, new MessagingListenActor<String>() {
-                @Override public void receive(UUID nodeId, String rcvMsg) {
-                    System.out.println(rcvMsg);
-
-                    if ("PING".equals(rcvMsg))
-                        respond("PONG");
-                    else if ("STOP".equals(rcvMsg))
-                        stop();
-                }
-            });
-
-            int MAX_PLAYS = 10;
-
-            final CountDownLatch cnt = new CountDownLatch(MAX_PLAYS);
-
-            // Set up local player.
-            ignite.message().localListen(null, new MessagingListenActor<String>() {
-                @Override protected void receive(UUID nodeId, String rcvMsg) throws IgniteException {
-                    System.out.println(rcvMsg);
-
-                    if (cnt.getCount() == 1)
-                        stop("STOP");
-                    else if ("PONG".equals(rcvMsg))
-                        respond("PING");
-
-                    cnt.countDown();
-                }
-            });
-
-            // Serve!
-            ignite.message(nodeB).send(null, "PING");
-
-            // Wait til the game is over.
-            try {
-                cnt.await();
-            }
-            catch (InterruptedException e) {
-                System.err.println("Hm... let us finish the game!\n" + e);
-            }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b473e309/examples/src/main/java/org/apache/ignite/examples/java7/messaging/package-info.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/package-info.java b/examples/src/main/java/org/apache/ignite/examples/java7/messaging/package-info.java
deleted file mode 100644
index 7947a3b..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/java7/messaging/package-info.java
+++ /dev/null
@@ -1,22 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * <!-- Package description. -->
- * Demonstrates how to exchange messages between nodes.
- */
-package org.apache.ignite.examples.java7.messaging;


Mime
View raw message