diff --git a/mq/mq.go b/mq/mq.go
index 9b5197b2..3521a165 100644
--- a/mq/mq.go
+++ b/mq/mq.go
@@ -175,5 +175,5 @@ func GetID(topic string) (string, error) {
 		return "", errors.New("invalid topic")
 	}
 	//the last part of the topic will be the node.ID
-	return parts[count], nil
+	return parts[count-1], nil
 }