all transaction can be send
package para
import (
- "bytes"
"context"
"sync/atomic"
"time"
@@ -52,7 +51,6 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
switch msg.Ty {
case types.EventTx:
mlog.Info("Receive msg from para mempool")
- if bytes.HasPrefix(msg.GetData().(*types.Transaction).Execer, types.ParaKey) {
tx := msg.GetData().(*types.Transaction)
for i := 0; i < retry_times; i++ {
reply, err := mem.mainGrpcCli.SendTransaction(context.Background(), tx)
@@ -66,7 +64,6 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
msg.Reply(client.NewMessage(mem.key, types.EventReply, err))
}
}
- }
default:
msg.Reply(client.NewMessage(mem.key, types.EventReply, types.ErrActionNotSupport))
}
