diff --git a/4bytes_db_update_test.go b/4bytes_db_update_test.go
index ad1b278..e0f8dc4 100644
--- a/4bytes_db_update_test.go
+++ b/4bytes_db_update_test.go
@@ -38,6 +38,8 @@ func TestUpdate4Bytes(t *testing.T) {
 	assert.Equal(util.GetMethodNameFromMethodId("0xe8e33700"), "addLiquidity")
 	assert.Equal(util.GetMethodNameFromMethodId("0x42842e0e"), "safeTransferFrom")
 	assert.Equal(util.GetMethodNameFromMethodId("0xecd5ff33"), "setProgramTime")
+	assert.Equal(util.GetMethodNameFromMethodId("0xbe739356"), "sendReward")
+	assert.Equal(util.GetMethodNameFromMethodId("0x743cec2d"), "exchangeWithValue")
 
 	data := "0q7S1gAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABgAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAGSWzhIAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAoAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAACcAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAQVbZvQpCuU8VUVDSeyAd243bdr5ljiPA3bK7aUm/VuQVdhajtudaHAI7ltLe1GHQeZchiXxaXAq2Ez+6ErCpJRscAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=="
 	signature := util.GetMethodNameFromData(data)
diff --git a/infrastructure/kafka/consumer/worker/internal_txs_consumer.go b/infrastructure/kafka/consumer/worker/internal_txs_consumer.go
index 4e7e736..39b2a1d 100644
--- a/infrastructure/kafka/consumer/worker/internal_txs_consumer.go
+++ b/infrastructure/kafka/consumer/worker/internal_txs_consumer.go
@@ -27,10 +27,10 @@ import (
 )
 
 var rewardType = map[string]bool{
-	"sendReward":        true,
-	"redeemReward":      true,
-	"exchange":          true,
-	"exchangeWithValue": true,
+	"sendReward": true,
+	//"redeemReward":      true,
+	//"exchange":          true,
+	//"exchangeWithValue": true,
 }
 
 func RunInternalTxsConsumer(rdbHandle *rdb.Handle, config *config.Config, logger applogger.Logger, evmUtil evm.EvmUtils, sigchan chan os.Signal) error {