diff --git a/debug/org.eclipse.cdt.debug.mi.core/src/org/eclipse/cdt/debug/mi/core/CLIProcessor.java b/debug/org.eclipse.cdt.debug.mi.core/src/org/eclipse/cdt/debug/mi/core/CLIProcessor.java
new file mode 100644
index 00000000000..4229bdcd2e3
--- /dev/null
+++ b/debug/org.eclipse.cdt.debug.mi.core/src/org/eclipse/cdt/debug/mi/core/CLIProcessor.java
@@ -0,0 +1,113 @@
+/*
+ * (c) Copyright QNX Software Systems Ltd. 2002.
+ * All Rights Reserved.
+ */
+
+package org.eclipse.cdt.debug.mi.core;
+ 
+import org.eclipse.cdt.debug.mi.core.command.CLICommand;
+import org.eclipse.cdt.debug.mi.core.event.MIBreakPointChangedEvent;
+import org.eclipse.cdt.debug.mi.core.event.MIEvent;
+import org.eclipse.cdt.debug.mi.core.event.MIRunningEvent;
+
+/**
+ * Transmission command thread blocks on the command Queue
+ * and wake cmd are available and push them to gdb out channel.
+ */
+public class CLIProcessor {
+
+	MISession session;
+
+	public CLIProcessor(MISession s) {
+		session = s;
+	}
+
+	/**
+	 * An attempt to discover the command type and
+	 * fire an event if necessary.
+	 */
+	void process(CLICommand cmd) {
+		String operation = cmd.getOperation().trim();
+		// Get the command name.
+		int indx = operation.indexOf(' ');
+		if (indx != -1) {
+			operation = operation.substring(0, indx).trim();
+		} else {
+			operation = operation.trim();
+		}
+
+		// Check the type of command
+
+		int type = getSteppingOperationKind(operation);
+		if (type != -1) {
+			// if it was a step instruction set state running
+			session.getMIInferior().setRunning();
+			MIEvent event = new MIRunningEvent(cmd.getToken(), type);
+			session.fireEvent(event);
+		} else if (isSettingBreakpoint(operation)) {
+			session.fireEvent(new MIBreakPointChangedEvent(0));
+		} else if (isSettingWatchpoint(operation)) {
+		} else if (isDeletingBreakpoint(operation)) {
+		}
+	}
+
+	int getSteppingOperationKind(String operation) {
+		int type = -1;
+		/* execution commands: n, next, s, step, si, stepi, u, until, finish,
+		   c, continue, fg */
+		if (operation.equals("n") || operation.equals("next")) {
+			type = MIRunningEvent.NEXT;
+		} else if (operation.equals("ni") || operation.equals("nexti")) {
+			type = MIRunningEvent.NEXTI;
+		} else if (operation.equals("s") || operation.equals("step")) {
+			type = MIRunningEvent.STEP;
+		} else if (operation.equals("si") || operation.equals("stepi")) {
+			type = MIRunningEvent.STEPI;
+		} else if (operation.equals("u") ||
+			   (operation.startsWith("unt") &&  "until".indexOf(operation) != -1)) {
+				type = MIRunningEvent.UNTIL;
+		} else if (operation.startsWith("fin") && "finish".indexOf(operation) != -1) {
+			type = MIRunningEvent.FINISH;
+		} else if (operation.equals("c") || operation.equals("fg") ||
+			   (operation.startsWith("cont") && "continue".indexOf(operation) != -1)) {
+			type = MIRunningEvent.CONTINUE;
+		}
+		return type;
+	}
+
+	boolean isSettingBreakpoint(String operation) {
+		boolean isbreak = false;
+		/* breakpoints: b, break, hbreak, tbreak, rbreak, thbreak */
+		/* watchpoints: watch, rwatch, awatch, tbreak, rbreak, thbreak */
+		if ((operation.startsWith("b")   && "break".indexOf(operation)   != -1) ||
+		    (operation.startsWith("tb")  && "tbreak".indexOf(operation)  != -1) ||
+		    (operation.startsWith("hb")  && "hbreak".indexOf(operation)  != -1) ||
+		    (operation.startsWith("thb") && "thbreak".indexOf(operation) != -1) ||
+		    (operation.startsWith("rb")  && "rbreak".indexOf(operation)  != -1)) {
+			isbreak = true;
+		}
+		return isbreak;
+	}
+
+	boolean isSettingWatchpoint(String operation) {
+		boolean isWatch = false;
+		/* watchpoints: watch, rwatch, awatch, tbreak, rbreak, thbreak */
+		if ((operation.startsWith("wa")  && "watch".indexOf(operation)   != -1) ||
+		    (operation.startsWith("rw")  && "rwatch".indexOf(operation)  != -1) ||
+		    (operation.startsWith("aw")  && "awatch".indexOf(operation)  != -1)) {
+			isWatch = true;
+		}
+		return  isWatch;
+	}
+
+	boolean isDeletingBreakpoint(String operation) {
+		boolean isDelete = false;
+		/* deleting breaks: clear, delete */
+		if ((operation.startsWith("cl")  && "clear".indexOf(operation)   != -1) ||
+		    (operation.startsWith("del") && "delete".indexOf(operation)  != -1)) {
+			isDelete = true;
+		}
+		return isDelete;
+	}
+
+}