Quellcode durchsuchen

[chore] 생성자 추가

master
extra1563 vor 4 Jahren
Ursprung
Commit
c6349cc21a
1 geänderte Dateien mit 4 neuen und 0 gelöschten Zeilen
  1. 4
    0
      src/broker/modules/init.go

+ 4
- 0
src/broker/modules/init.go Datei anzeigen

@@ -205,11 +205,15 @@ func (moscato *Moscato) Run() {
205 205
 	//모스카토 구조체 변수 초기화
206 206
 	receiver := Receiver{moscato: moscato}
207 207
 	err := moscato.queue.queue_init()
208
+	moscato.SendQueue = make(chan myType)
209
+	moscato.Subscriptionmanager.Initialize()
210
+
208 211
 	if err != nil {
209 212
 		fmt.Println(err)
210 213
 		return
211 214
 	}
212 215
 
216
+
213 217
 	//go routine -> matching 동작
214 218
 	go moscato.Matching()
215 219
 	go moscato.CheckQueue()

Laden…
Abbrechen
Speichern