package com.l7tech.server.policy.variable;

import com.l7tech.message.MQTTConnectResponseKnob;
import com.l7tech.message.Message;
import com.l7tech.policy.variable.Syntax.SyntaxErrorHandler;

class eh implements MessageSelector.MessageAttributeSelector {
   @Override
   public ExpandVariables.Selector.Selection select(Message var1, String var2, SyntaxErrorHandler var3, boolean var4) {
      MQTTConnectResponseKnob var5 = (MQTTConnectResponseKnob)var1.getKnob(MQTTConnectResponseKnob.class);
      if (var5 == null) {
         String var6 = var3.handleBadVariable(var2);

         try {
            if (var4) {
               throw new IllegalArgumentException(var6);
            } else {
               return null;
            }
         } catch (IllegalArgumentException var7) {
            throw a(var7);
         }
      } else {
         return new ExpandVariables.Selector.Selection(var5.isSessionPresent());
      }
   }

   private static IllegalArgumentException a(IllegalArgumentException var0) {
      return var0;
   }
}