Skip to content

Commit

Permalink
remove heartbeat condition
Browse files Browse the repository at this point in the history
  • Loading branch information
qct authored and qct committed Apr 28, 2018
1 parent 377853e commit d438239
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ public ExecutionChannelHandler(ChannelHandler handler, URL url) {

@Override
public void received(Channel channel, Object message) throws RemotingException {
if (message instanceof Request && !((Request) message).isHeartbeat()) {
if (message instanceof Request) {
try {
executor.execute(new ChannelEventRunnable(channel, handler, ChannelState.RECEIVED, message));
} catch (Throwable t) {
Expand Down

0 comments on commit d438239

Please sign in to comment.