【fix sonar】 BaseRabbiMqHandler.java文件
This commit is contained in:
+1
-1
@@ -12,7 +12,7 @@ public class BaseRabbiMqHandler<T> {
|
|||||||
|
|
||||||
private String token= UserTokenContext.getToken();
|
private String token= UserTokenContext.getToken();
|
||||||
|
|
||||||
public void onMessage(T t, Long deliveryTag, Channel channel, MqListener mqListener) {
|
public void onMessage(T t, Long deliveryTag, Channel channel, MqListener<T> mqListener) {
|
||||||
try {
|
try {
|
||||||
UserTokenContext.setToken(token);
|
UserTokenContext.setToken(token);
|
||||||
mqListener.handler(t, channel);
|
mqListener.handler(t, channel);
|
||||||
|
|||||||
Reference in New Issue
Block a user