rewrite pubsub recv messages
fix pubsub recv reply
add pubsub test case
rename transaction connection field name
transaction use new connection
change active to close connection
fix pubsub test goroutine sched