close

queue_test.go

@@ -1,7 +1,6 @@
 package queue
 
 import (
-	"fmt"
 	"loafle.com/overflow/agent_api/observer"
 	"loafle.com/overflow/agent_api/observer/messages"
 	"log"
@@ -15,7 +14,7 @@ func TestNewQueue(t *testing.T) {
 
 	lq := NewQueue(messages.QUEUE_DATA, 5, senderChanel)
 
-	fmt.Println(lq)
+	log.Println(lq)
 
 	observer.Notify(messages.QUEUE_DATA, "data")
 	observer.Notify(messages.QUEUE_DATA, "data1111")
@@ -48,7 +47,7 @@ func GetItemTest(senderChanel chan interface{}) {
 	for sc := range senderChanel {
 		items := reflect.ValueOf(sc)
 		if items.Kind() != reflect.Slice {
-			fmt.Println("ddddd")
+			log.Println("ddddd")
 		}
 		//log.Println(items.Len())
 		for i := 0; i < items.Len(); i++ {