Skip to content

Commit

Permalink
build: xx
Browse files Browse the repository at this point in the history
  • Loading branch information
@shuigedeng
shuigedeng committed Jun 29, 2024
1 parent f9447b1 commit 10dbe69
Show file tree
Hide file tree
Showing 17 changed files with 21 additions and 21 deletions.
2 changes: 1 addition & 1 deletion ...oud-mq/taotao-cloud-mq-broker/src/main/java/com/taotao/cloud/mq/broker/core/MqBroker.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
*/
public class MqBroker extends Thread implements IMqBroker {

private static final Logger LOG = LoggerFactory.getLogger(MqBroker.class);
private static final Logger log = LoggerFactory.getLogger(MqBroker.class);

/**
* 端口号
Expand Down
2 changes: 1 addition & 1 deletion ...tao-cloud-mq-broker/src/main/java/com/taotao/cloud/mq/broker/handler/MqBrokerHandler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
*/
public class MqBrokerHandler extends SimpleChannelInboundHandler {

private static final Logger LOG = LoggerFactory.getLogger(MqBrokerHandler.class);
private static final Logger log = LoggerFactory.getLogger(MqBrokerHandler.class);

/**
* 调用管理类
Expand Down
2 changes: 1 addition & 1 deletion ...ud-mq-broker/src/main/java/com/taotao/cloud/mq/broker/support/push/BrokerPushService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
*/
public class BrokerPushService implements IBrokerPushService {

private static final Logger LOG = LoggerFactory.getLogger(BrokerPushService.class);
private static final Logger log = LoggerFactory.getLogger(BrokerPushService.class);

private static final ExecutorService EXECUTOR_SERVICE = Executors.newSingleThreadExecutor();

Expand Down
2 changes: 1 addition & 1 deletion ...loud-mq-client/src/main/java/com/taotao/cloud/mq/client/consumer/core/MqConsumerPush.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
*/
public class MqConsumerPush extends Thread implements IMqConsumer {

private static final Logger LOG = LoggerFactory.getLogger(MqConsumerPush.class);
private static final Logger log = LoggerFactory.getLogger(MqConsumerPush.class);

/**
* 组名称
Expand Down
2 changes: 1 addition & 1 deletion ...q-client/src/main/java/com/taotao/cloud/mq/client/consumer/handler/MqConsumerHandler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
*/
public class MqConsumerHandler extends SimpleChannelInboundHandler {

private static final Logger LOG = LoggerFactory.getLogger(MqConsumerHandler.class);
private static final Logger log = LoggerFactory.getLogger(MqConsumerHandler.class);

/**
* 调用管理类
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/com/taotao/cloud/mq/client/consumer/support/broker/ConsumerBrokerService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@
*/
public class ConsumerBrokerService implements IConsumerBrokerService {

private static final Logger LOG = LoggerFactory.getLogger(ConsumerBrokerService.class);
private static final Logger log = LoggerFactory.getLogger(ConsumerBrokerService.class);

/**
* 分组名称
Expand Down
2 changes: 1 addition & 1 deletion ...ao-cloud-mq-client/src/main/java/com/taotao/cloud/mq/client/producer/core/MqProducer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
*/
public class MqProducer extends Thread implements IMqProducer {

private static final Logger LOG = LoggerFactory.getLogger(MqProducer.class);
private static final Logger log = LoggerFactory.getLogger(MqProducer.class);

/**
* 分组名称
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/com/taotao/cloud/mq/client/producer/support/broker/ProducerBrokerService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
*/
public class ProducerBrokerService implements IProducerBrokerService {

private static final Logger LOG = LoggerFactory.getLogger(ProducerBrokerService.class);
private static final Logger log = LoggerFactory.getLogger(ProducerBrokerService.class);

/**
* 分组名称
Expand Down
2 changes: 1 addition & 1 deletion ...-mq-common/src/main/java/com/taotao/cloud/mq/common/support/hook/DefaultShutdownHook.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ public class DefaultShutdownHook extends AbstractShutdownHook {
/**
* DefaultShutdownHook logger
*/
private static final Log logger = LogFactory.getLog(DefaultShutdownHook.class);
private static final Logger logger = LoggerFactory.getLogger(DefaultShutdownHook.class);

/**
* 调用管理类
Expand Down
2 changes: 1 addition & 1 deletion ...mq-common/src/main/java/com/taotao/cloud/mq/common/support/invoke/impl/InvokeService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
*/
public class InvokeService implements IInvokeService {

private static final Log logger = LogFactory.getLog(InvokeService.class);
private static final Logger logger = LoggerFactory.getLogger(InvokeService.class);

/**
* 请求序列号 map （1）这里后期如果要添加超时检测，可以添加对应的超时时间。 可以把这里调整为 map
Expand Down
2 changes: 1 addition & 1 deletion ...tao-cloud-mq-common/src/main/java/com/taotao/cloud/mq/common/util/ChannelFutureUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ protected void initChannel(Channel ch) throws Exception {
list.add(rpcChannelFuture);
}
catch (Exception exception) {
log.error("注册到 broker 服务端异常", exception);
LOG.error("注册到 broker 服务端异常", exception);
if (check) {
throw new MqException(MqCommonRespCode.REGISTER_TO_BROKER_FAILED);
}
Expand Down
2 changes: 1 addition & 1 deletion ...otao-cloud-rpc-client/src/main/java/com/taotao/cloud/rpc/client/client/core/ClientBs.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ public T reference() {
reference = referenceProxy.proxy();
}
else {
log.info("[Client] generic reference proxy created.");
LOG.info("[Client] generic reference proxy created.");
reference = (T) new GenericReferenceProxy(proxyContext, remoteInvokeService);
}
proxyContext.statusManager().status(StatusEnum.ENABLE.code());
Expand Down
2 changes: 1 addition & 1 deletion ...om/taotao/cloud/rpc/client/client/support/register/impl/DefaultClientRegisterManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
*/
public class DefaultClientRegisterManager implements ClientRegisterManager {

private static final Logger LOG = LoggerFactory.getLogger(DefaultClientRegisterManager.class);
private static final Logger log = LoggerFactory.getLogger(DefaultClientRegisterManager.class);

/**
* 服务调用信息管理类
Expand Down
2 changes: 1 addition & 1 deletion ...on/src/main/java/com/taotao/cloud/rpc/common/common/support/delay/DelayQueueExecutor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ public void run() {
runnable.run();
// log.info("完成获取延迟 {}ms 的可运行对象", delayInMills);
} catch (InterruptedException e) {
log.error("延迟任务执行遇到异常", e);
//log.error("延迟任务执行遇到异常", e);
}
}
}
Expand Down
4 changes: 2 additions & 2 deletions ...rpc-server/src/main/java/com/taotao/cloud/rpc/server/server/handler/RpcServerHandler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ public RpcServerHandler(InvokeManager invokeManager, StatusManager statusManager
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
final String id = ctx.channel().id().asLongText();
log.info("[Server] channel {} connected " + id);
LOG.info("[Server] channel {} connected " + id);
}

@Override
Expand Down Expand Up @@ -83,7 +83,7 @@ protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Except

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
log.error("[Server] meet ex: ", cause);
LOG.error("[Server] meet ex: ", cause);
ctx.close();
}

Expand Down
8 changes: 4 additions & 4 deletions ...om/taotao/cloud/rpc/server/server/support/register/DefaultServerRegisterLocalManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ private class HeartbeatThread implements Runnable {
@Override
public void run() {
//1. 每 2 秒钟，向 channel 发送请求信息
log.debug(("[HEARTBEAT] 开始定时执行心跳"));
LOG.debug(("[HEARTBEAT] 开始定时执行心跳"));
// String currentIp = NetUtil.getLocalIp();
ServerHeartbeatBody body = new ServerHeartbeatBody();
body.ip("currentIp");
Expand All @@ -78,7 +78,7 @@ public void run() {
for (Channel channel : registerCenterChannelMap.values()) {
channel.writeAndFlush(notifyMessage);
}
log.debug("[HEARTBEAT] 完成定时执行心跳");
LOG.debug("[HEARTBEAT] 完成定时执行心跳");
}
}

Expand Down Expand Up @@ -181,9 +181,9 @@ public void removeRegisterChannel(RpcAddress rpcAddress) {

@Override
public void clearRegisterChannel() {
log.info("[Rpc Server] 开始清空对应的注册中心 channel future");
LOG.info("[Rpc Server] 开始清空对应的注册中心 channel future");
this.registerCenterChannelMap.clear();
log.info("[Rpc Server] 完成清空对应的注册中心 channel future");
LOG.info("[Rpc Server] 完成清空对应的注册中心 channel future");
}

/**
Expand Down
2 changes: 1 addition & 1 deletion ...taotao-cloud-tx-server/src/main/java/com/taotao/cloud/tx/server/TxManagerApplication.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
public class TxManagerApplication {

public static void main(String[] args) {
SpringApplication.run(TxManagerApplication.class, args);
// SpringApplication.run(TxManagerApplication.class, args);
}

}

0 comments on commit 10dbe69

Please sign in to comment.