现在是想用redis-queue 做两个服务之间的消息传递,结果发现如果在项目A发送消息1,在项目B中可以收到消息1,但是redis里还是存在,会一直重试然后到异常里。如果只在项目A中使用则正常,是我使用不对吗?
是因为订阅里有错误所以无法执行成功... subscribe里面加上异常捕捉就好.. try { .... } catch (\Throwable $aErr) { print_r($aErr); }
是因为订阅里有错误所以无法执行成功...
subscribe里面加上异常捕捉就好..
try {
....
} catch (\Throwable $aErr) {
print_r($aErr);
}