Commitd634e16

committed

updates

1 parentb4472c8 commitd634e16Copy full SHA for d634e16

File tree

-3

lines changed

src/main/java/com/owl/kafka/push/server
- biz/service
  - PullRequestHoldService.java
- transport/handler
  - ViewReqMessageHandler.java

-3

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ private boolean executeWhenWakeup(PullRequest request, Packet result){`
`79`	`79`	`request.getConnection().send(result);`
`80`	`80`	`execute =true;`
`81`	`81`	`}elseif(System.currentTimeMillis() > (request.getSuspendTimestamp() +request.getTimeoutMs())){`
`82`		`-request.getConnection().send(Packets.noNewMsg(request.getPacket().getOpaque()));`
	`82`	`+request.getConnection().send(Packets.noNewMsgResp(request.getPacket().getOpaque()));`
`83`	`83`	`execute =true;`
`84`	`84`	`}`
`85`	`85`	`}catch (ChannelInactiveExceptione) {`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,6 @@`
`9`	`9`	`importcom.owl.kafka.client.util.Packets;`
`10`	`10`	`importcom.owl.kafka.consumer.Record;`
`11`	`11`	`importcom.owl.kafka.push.server.biz.service.InstanceHolder;`
`12`		`-importcom.owl.kafka.serializer.SerializerImpl;`
`13`	`12`	`importorg.slf4j.Logger;`
`14`	`13`	`importorg.slf4j.LoggerFactory;`
`15`	`14`
`@@ -27,7 +26,9 @@ public void handle(Connection connection, Packet packet) throws Exception {`
`27`	`26`	`Headerheader =message.getHeader();`
`28`	`27`	`Record<byte[],byte[]>record =InstanceHolder.I.getDLQService().view(header.getMsgId());`
`29`	`28`	`if(record !=null){`
`30`		`-connection.send(Packets.toViewPacket(header.getMsgId(),record));`
	`29`	`+connection.send(Packets.viewResp(packet.getOpaque(),header.getMsgId(),record));`
	`30`	`+ }else{`
	`31`	`+connection.send(Packets.noViewMsgResp(packet.getOpaque()));`
`31`	`32`	`}`
`32`	`33`	`}`
`33`	`34`

Comments

(0)