package org.apache.ignite.examples;
<BUG>import org.apache.ignite.*;
public final class MessagingExample {</BUG>
private static final int MESSAGES_NUM = 10;
private enum TOPIC { ORDERED, UNORDERED }
public static void main(String[] args) throws Exception {

package org.apache.ignite.examples;
import org.apache.ignite.*;
import org.apache.ignite.cluster.*;
import java.util.concurrent.*;
public final class MessagingExample {
private static final int MESSAGES_NUM = 10;
private enum TOPIC { ORDERED, UNORDERED }
public static void main(String[] args) throws Exception {
