|
|
@ -154,14 +154,13 @@ public class CommandPubSubDecoder extends CommandDecoder {
|
|
|
|
channelName = ((PubSubPatternMessage) result).getPattern();
|
|
|
|
channelName = ((PubSubPatternMessage) result).getPattern();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
PubSubEntry entry = entries.remove(channelName);
|
|
|
|
PubSubEntry entry = entries.remove(channelName);
|
|
|
|
if (config.isKeepAlive()) {
|
|
|
|
if (config.isKeepPubSubOrder()) {
|
|
|
|
enqueueMessage(result, pubSubConnection, entry);
|
|
|
|
enqueueMessage(result, pubSubConnection, entry);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (config.isKeepPubSubOrder()) {
|
|
|
|
if (config.isKeepAlive()) {
|
|
|
|
|
|
|
|
if (result instanceof PubSubPatternMessage) {
|
|
|
|
if (result instanceof PubSubPatternMessage) {
|
|
|
|
channelName = ((PubSubPatternMessage) result).getPattern();
|
|
|
|
channelName = ((PubSubPatternMessage) result).getPattern();
|
|
|
|
}
|
|
|
|
}
|
|
|
|