package com.l7tech.server.transport.jms2;

import com.l7tech.gateway.common.transport.jms.JmsConnection;
import com.l7tech.server.transport.jms.JmsBag;
import com.l7tech.server.transport.jms.JmsRuntimeException;
import com.l7tech.server.transport.jms2.asynch.JmsTask;
import javax.jms.JMSException;
import javax.naming.NamingException;

class a implements Runnable {
   final AbstractJmsEndpointListener this$0;
   private static final String[] a;

   private a(AbstractJmsEndpointListener var1) {
      this.this$0 = var1;
      var1.g = new Thread(this, this.toString());
      var1.g.setDaemon(true);
   }

   private void a() throws NamingException, JmsRuntimeException, JMSException, JmsConnectionMaxWaitException {
      int var1 = 1;
      String var2 = this.this$0._endpointCfg.getConnection().properties().getProperty(JmsConnection.PROP_DEDICATED_CONSUMER_SIZE);
      if (var2 != null) {
         var1 = Integer.parseInt(var2);
      }

      if (var1 < 1) {
         var1 = 1;
      }

      for (int var3 = 0; var3 < var1; var3++) {
         JmsBag var4 = this.this$0.resourceManager.borrowJmsBag(this.this$0._endpointCfg);

         try {
            var4.getMessageConsumer().setMessageListener(new JmsTask(this.this$0._endpointCfg, var4));
            this.this$0.receivers.add(var4);
            if (var4.getConnection() != null) {
               var4.getConnection().setExceptionListener(this.this$0);
            }
         } catch (NamingException var5) {
            throw a(var5);
         }
      }
   }

   @Override
   public final void run() {
      // $VF: Couldn't be decompiled
      // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!)
      // java.lang.RuntimeException: parsing failure!
      //   at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211)
      //   at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174)
      //
      // Bytecode:
      // 000: bipush 1
      // 001: newarray 10
      // 003: dup
      // 004: bipush 0
      // 005: bipush 0
      // 006: iastore
      // 007: astore 1
      // 008: aload 0
      // 009: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 00c: getstatic java/util/logging/Level.INFO Ljava/util/logging/Level;
      // 00f: getstatic com/l7tech/server/transport/jms2/a.a [Ljava/lang/String;
      // 012: astore 4
      // 014: aload 4
      // 016: bipush 1
      // 017: aaload
      // 018: aload 0
      // 019: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 01c: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.a ()Ljava/lang/String;
      // 01f: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 022: aload 0
      // 023: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 026: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.isStop ()Z
      // 029: ifne 10d
      // 02c: aload 0
      // 02d: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 030: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._endpointCfg Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;
      // 033: invokevirtual com/l7tech/server/transport/jms2/JmsEndpointConfig.getEndpoint ()Lcom/l7tech/gateway/common/transport/jms/JmsEndpoint;
      // 036: invokevirtual com/l7tech/gateway/common/transport/jms/JmsEndpoint.isQueue ()Z
      // 039: ifeq 087
      // 03c: aload 0
      // 03d: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 040: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 043: ifnonnull 07e
      // 046: goto 04d
      // 049: invokestatic com/l7tech/server/transport/jms2/a.a (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // 04c: athrow
      // 04d: aload 0
      // 04e: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 051: aload 0
      // 052: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 055: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.resourceManager Lcom/l7tech/server/transport/jms2/JmsResourceManager;
      // 058: aload 0
      // 059: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 05c: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._endpointCfg Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;
      // 05f: invokevirtual com/l7tech/server/transport/jms2/JmsResourceManager.borrowJmsBag (Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;)Lcom/l7tech/server/transport/jms/JmsBag;
      // 062: putfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 065: aload 0
      // 066: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 069: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 06c: invokevirtual com/l7tech/server/transport/jms/JmsBag.closeSession ()V
      // 06f: aload 0
      // 070: invokevirtual com/l7tech/server/transport/jms2/a.a ()V
      // 073: aload 1
      // 074: bipush 0
      // 075: bipush 0
      // 076: iastore
      // 077: goto 0fd
      // 07a: invokestatic com/l7tech/server/transport/jms2/a.a (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // 07d: athrow
      // 07e: ldc2_w 5000
      // 081: invokestatic java/lang/Thread.sleep (J)V
      // 084: goto 0fd
      // 087: aload 0
      // 088: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 08b: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 08e: ifnonnull 0f7
      // 091: aload 0
      // 092: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 095: aload 0
      // 096: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 099: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.resourceManager Lcom/l7tech/server/transport/jms2/JmsResourceManager;
      // 09c: aload 0
      // 09d: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0a0: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._endpointCfg Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;
      // 0a3: invokevirtual com/l7tech/server/transport/jms2/JmsResourceManager.borrowJmsBag (Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;)Lcom/l7tech/server/transport/jms/JmsBag;
      // 0a6: putfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 0a9: aload 0
      // 0aa: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0ad: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.ensureConnectionStarted ()V
      // 0b0: aload 0
      // 0b1: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0b4: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 0b7: invokevirtual com/l7tech/server/transport/jms/JmsBag.getMessageConsumer ()Ljavax/jms/MessageConsumer;
      // 0ba: new com/l7tech/server/transport/jms2/asynch/JmsTask
      // 0bd: dup
      // 0be: aload 0
      // 0bf: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0c2: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._endpointCfg Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;
      // 0c5: aload 0
      // 0c6: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0c9: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 0cc: invokespecial com/l7tech/server/transport/jms2/asynch/JmsTask.<init> (Lcom/l7tech/server/transport/jms2/JmsEndpointConfig;Lcom/l7tech/server/transport/jms/JmsBag;)V
      // 0cf: invokeinterface javax/jms/MessageConsumer.setMessageListener (Ljavax/jms/MessageListener;)V 2
      // 0d4: aload 0
      // 0d5: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 0d8: getfield com/l7tech/server/transport/jms2/AbstractJmsEndpointListener._jmsBag Lcom/l7tech/server/transport/jms/JmsBag;
      // 0db: invokevirtual com/l7tech/server/transport/jms/JmsBag.getConnection ()Ljavax/jms/Connection;
      // 0de: new com/l7tech/server/transport/jms2/b
      // 0e1: dup
      // 0e2: aload 0
      // 0e3: aload 1
      // 0e4: invokespecial com/l7tech/server/transport/jms2/b.<init> (Lcom/l7tech/server/transport/jms2/a;[I)V
      // 0e7: invokeinterface javax/jms/Connection.setExceptionListener (Ljavax/jms/ExceptionListener;)V 2
      // 0ec: aload 1
      // 0ed: bipush 0
      // 0ee: bipush 0
      // 0ef: iastore
      // 0f0: goto 0fd
      // 0f3: invokestatic com/l7tech/server/transport/jms2/a.a (Ljava/lang/Throwable;)Ljava/lang/Throwable;
      // 0f6: athrow
      // 0f7: ldc2_w 5000
      // 0fa: invokestatic java/lang/Thread.sleep (J)V
      // 0fd: goto 022
      // 100: astore 2
      // 101: aload 0
      // 102: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 105: aload 2
      // 106: aload 1
      // 107: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.handleError (Ljava/lang/Throwable;[I)V
      // 10a: goto 022
      // 10d: aload 0
      // 10e: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 111: getstatic java/util/logging/Level.INFO Ljava/util/logging/Level;
      // 114: getstatic com/l7tech/server/transport/jms2/a.a [Ljava/lang/String;
      // 117: astore 4
      // 119: aload 4
      // 11b: bipush 0
      // 11c: aaload
      // 11d: aload 0
      // 11e: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 121: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.a ()Ljava/lang/String;
      // 124: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 127: aload 0
      // 128: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 12b: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.cleanup ()V
      // 12e: goto 151
      // 131: astore 3
      // 132: aload 0
      // 133: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 136: getstatic java/util/logging/Level.INFO Ljava/util/logging/Level;
      // 139: getstatic com/l7tech/server/transport/jms2/a.a [Ljava/lang/String;
      // 13c: bipush 2
      // 13d: aaload
      // 13e: aload 0
      // 13f: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 142: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.a ()Ljava/lang/String;
      // 145: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Object;)V
      // 148: aload 0
      // 149: getfield com/l7tech/server/transport/jms2/a.this$0 Lcom/l7tech/server/transport/jms2/AbstractJmsEndpointListener;
      // 14c: invokevirtual com/l7tech/server/transport/jms2/AbstractJmsEndpointListener.cleanup ()V
      // 14f: aload 3
      // 150: athrow
      // 151: return
      // try (62 -> 108): 108 java/lang/Throwable
      // try (29 -> 57): 57 java/lang/Throwable
      // try (23 -> 33): 34 java/lang/Throwable
      // try (23 -> 112): 113 java/lang/Throwable
      // try (19 -> 120): 136 null
   }

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

   static {
      String[] var5 = new String[3];
      int var3 = 0;
      String var2 = "Vs\u000bP^\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S\u001aVs\u0005RZ\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S\u001aVs\u000bP^\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S";
      int var4 = "Vs\u000bP^\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S\u001aVs\u0005RZ\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S\u001aVs\u000bP^\u0014nb'.m}]pjk\bE\\]ok'\u001f\u0010S"
         .length();
      char var1 = 26;
      int var0 = -1;

      while (true) {
         String var10002 = a(109, a(var2.substring(++var0, var0 + var1)));
         byte var10001 = -1;
         var5[var3++] = var10002;
         if ((var0 += var1) >= var4) {
            a = var5;
            return;
         }

         var1 = var2.charAt(var0);
      }
   }

   private static char[] a(String var0) {
      char[] var10000 = var0.toCharArray();
      if (var10000.length < 2) {
         var10000[0] = (char)(var10000[0] ^ 109);
      }

      return var10000;
   }

   private static String a(int var0, char[] var1) {
      int var10003 = var1.length;
      int var10002 = var0;
      char[] var10001 = var1;
      int var10000 = var10003;

      for (int var2 = 0; var10000 > var2; var2++) {
         var10001[var2] = (char)(var10001[var2] ^ var10002 ^ switch (var2 % 7) {
            case 0 -> 104;
            case 1 -> 106;
            case 2 -> 9;
            case 3 -> 77;
            case 4 -> 67;
            case 5 -> 16;
            default -> 109;
         });
      }

      return new String(var10001).intern();
   }
}