diff --git a/observer/messages/collector.go b/observer/messages/collector.go
index e373bfe..cf40101 100644
--- a/observer/messages/collector.go
+++ b/observer/messages/collector.go
@@ -1,7 +1,10 @@
 package messages
 
 const (
-	COLLECTED           = "COLLECTED"
-	COLLECTOR_STOPPED   = "COLLECTOR_STOPPED"
-	REMOVE_SENSOR_2_END = "REMOVE_SENSOR_2_END"
+	CLT_READY              = "COLLECTOR_READY"
+	CLT_STOPPED            = "COLLECTOR_STOPPED"
+	CLT_SENSOR_REMOVE_DONE = "COLLECTOR_SENSOR_REMOVE_DONE"
+	CLT_SENSOR_UPDATE_DONE = "COLLECTOR_SENSOR_UPDATE_DONE"
+	CLT_CRM_UPDATE_DONE    = "COLLECTOR_CRAWLER_UPDATE_DONE"
+	CLT_DATA_SEND          = "DATA_SEND"
 )
diff --git a/observer/messages/data_sender.go b/observer/messages/data_sender.go
index 05331dc..9ddc558 100644
--- a/observer/messages/data_sender.go
+++ b/observer/messages/data_sender.go
@@ -1,5 +1,5 @@
 package messages
 
 const (
-	DATA_SENDER_STOPPED = "DATA_SENDER_STOPPED"
+	DATA_SEND = "DATA_SEND"
 )
diff --git a/observer/messages/poller.go b/observer/messages/poller.go
index fcc6031..d331e81 100644
--- a/observer/messages/poller.go
+++ b/observer/messages/poller.go
@@ -1,7 +1,13 @@
 package messages
 
 const (
-	POLLER_STOPPED  = "POLLER_STOPPED"
-	ADD_SENSOR_0    = "ADD_SENSOR_0"
-	REMOVE_SENSOR_0 = "REMOVE_SENSOR_0"
+	TASK_SENSOR_START           = "TASK_SENSOR_START"
+	TASK_SENSOR_STOP            = "TASK_SENSOR_STOP"
+	TASK_SENSOR_ADD             = "TASK_SENSOR_ADD"
+	TASK_SENSOR_REMOVE          = "TASK_SENSOR_REMOVE"
+	TASK_SENSOR_UPDATE          = "TASK_SENSOR_UPDATE"
+	TASK_CRAWLER_UPDATE         = "TASK_CRAWLER_UPDATE"
+	TASK_AGENT_UPDATE           = "TASK_AGENT_UPDATE"
+	TASK_POLLER_INTERVAL_UPDATE = "TASK_POLLER_INTERVAL_UPDATE"
+	TASK_LOG_SEND               = "TASK_LOG_SEND"
 )