Pārlūkot izejas kodu

Merge remote-tracking branch 'origin/master'

master
kidjung 4 gadus atpakaļ
vecāks
revīzija
78a96f438b
1 mainītis faili ar 4 papildinājumiem un 0 dzēšanām
  1. 4
    0
      src/broker/modules/init.go

+ 4
- 0
src/broker/modules/init.go Parādīt failu

@@ -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()

Notiek ielāde…
Atcelt
Saglabāt