bugfix:txhandler错投deliver事件修改为投递deliverpre

modified: handler/tx_ack.go
songshubing · Mar 27, 2015 · a660010 · a660010
1 parent 72cbfba
commit a660010
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/handler/tx_ack.go b/handler/tx_ack.go
@@ -49,11 +49,8 @@ func (self *TxAckHandler) Process(ctx *DefaultPipelineContext, event IEvent) err
 		if succ {
 			//发起投递事件
 			//启动异步协程处理分发逻辑
-			deliver := &deliverEvent{}
-			deliver.messageId = h.GetMessageId()
-			deliver.topic = h.GetTopic()
-			deliver.messageType = h.GetMessageType()
-			ctx.SendForward(deliver)
+			preevent := NewDeliverPreEvent(h.GetMessageId(), h, nil)
+			ctx.SendForward(preevent)
 
 		} else {
 			//失败了等待下次recover询问