public class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter extends java.lang.Object implements org.apache.activemq.store.jdbc.JDBCAdapter { private static final org.slf4j.Logger LOG; public static final int MAX_ROWS; private static final java.lang.String FAILURE_MESSAGE; protected org.apache.activemq.store.jdbc.Statements statements; private boolean batchStatements; protected boolean batchStatments; protected boolean prioritizedMessages; protected int maxRows; char priorityIterator; public void () { org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; specialinvoke v.()>(); v. = 1; v. = 1; v. = 32767; v. = 0; return; } protected void setBinaryData(java.sql.PreparedStatement, int, byte[]) throws java.sql.SQLException { byte[] v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; int v; java.sql.PreparedStatement v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: java.sql.PreparedStatement; v := @parameter: int; v := @parameter: byte[]; interfaceinvoke v.(v, v); return; } protected byte[] getBinaryData(java.sql.ResultSet, int) throws java.sql.SQLException { byte[] v; java.sql.ResultSet v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; int v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: java.sql.ResultSet; v := @parameter: int; v = interfaceinvoke v.(v); return v; } public void doCreateTables(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException { org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v; org.apache.activemq.store.jdbc.TransactionContext v; int v, v; java.lang.String v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; specialinvoke v.(v, v, v); v = v + 1; goto label; label: return; } private boolean messageTableAlreadyExists(org.apache.activemq.store.jdbc.TransactionContext) { java.lang.Throwable v, v; java.sql.Connection v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v; java.sql.DatabaseMetaData v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v = 0; v = null; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "TABLE"; v = interfaceinvoke v.(null, null, v, v); v = interfaceinvoke v.(); label: staticinvoke (v); goto label; label: v := @caughtexception; label: staticinvoke (v); goto label; label: v := @caughtexception; staticinvoke (v); throw v; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void executeStatement(org.apache.activemq.store.jdbc.TransactionContext, java.lang.String, boolean) throws java.io.IOException { java.lang.Throwable v; java.lang.Object[] v, v; java.sql.Connection v; java.lang.Integer v, v; java.sql.SQLException v; org.apache.activemq.store.jdbc.TransactionContext v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; boolean v; org.slf4j.Logger v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.Statement v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: java.lang.String; v := @parameter: boolean; v = null; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Executing SQL: \u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); specialinvoke v.(v); label: specialinvoke v.(v); goto label; label: v := @caughtexception; if v == 0 goto label; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = staticinvoke ("Failure was: %s Message: %s SQLState: %s Vendor code: %s", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not create JDBC tables; The message table already existed. \u0001"); interfaceinvoke v.(v); goto label; label: v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = staticinvoke ("Failure was: %s Message: %s SQLState: %s Vendor code: %s", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not create JDBC tables; they could already exist. \u0001"); interfaceinvoke v.(v); staticinvoke ("Failure details: ", v); label: specialinvoke v.(v); goto label; label: v := @caughtexception; specialinvoke v.(v); throw v; label: return; catch java.sql.SQLException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void closeStatement(java.sql.Statement) { java.sql.Statement v; java.sql.SQLException v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: java.sql.Statement; label: if v == null goto label; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; label: return; catch java.sql.SQLException from label to label with label; } private void commitIfAutoCommitIsDisabled(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException { java.sql.Connection v, v; org.apache.activemq.store.jdbc.TransactionContext v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(); label: return; } public void doDropTables(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v; java.sql.SQLException v; org.apache.activemq.store.jdbc.TransactionContext v; int v, v, v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.Statement v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = 0; label: v = lengthof v; if v >= v goto label; label: v = ; v = v[v]; v = dynamicinvoke "makeConcatWithConstants" (v) ("Executing SQL: \u0001"); interfaceinvoke v.(v); v = v[v]; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Could not drop JDBC tables; they may not exist. Failure was: \u Message: \u SQLState: \u Vendor code: \u0001"); interfaceinvoke v.(v); staticinvoke ("Failure details: ", v); label: v = v + 1; goto label; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; throw v; label: return; catch java.sql.SQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public long doGetLastMessageStoreSequenceId(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v, v; org.apache.activemq.store.jdbc.Statements v, v; long v, v, v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v; boolean v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = 0L; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(1); label: interfaceinvoke v.(); interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = 0L; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(1); label: v = staticinvoke (v, v); label: staticinvoke (v); staticinvoke (v); return v; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; } public byte[] doGetMessageById(org.apache.activemq.store.jdbc.TransactionContext, long) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; long v; java.sql.PreparedStatement v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: long; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.(1, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; label: staticinvoke (v); staticinvoke (v); return null; label: v = virtualinvoke v.(v, 1); label: staticinvoke (v); staticinvoke (v); return v; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void doAddMessage(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.MessageId, org.apache.activemq.command.ActiveMQDestination, byte[], long, byte, org.apache.activemq.command.XATransactionId) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v, v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; long v, v, v; java.sql.SQLException v; byte v; org.apache.activemq.store.jdbc.TransactionContext v; int v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: long; v := @parameter: org.apache.activemq.command.MessageId; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: byte[]; v := @parameter: long; v := @parameter: byte; v := @parameter: org.apache.activemq.command.XATransactionId; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v); label: interfaceinvoke v.(1, v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(2, v); v = virtualinvoke v.(); interfaceinvoke v.(3, v); v = virtualinvoke v.(); interfaceinvoke v.(4, v); interfaceinvoke v.(5, v); interfaceinvoke v.(6, v); virtualinvoke v.(v, 7, v); if v == null goto label; v = virtualinvoke v.(); v[0] = 43; v = staticinvoke (v); interfaceinvoke v.(8, v); goto label; label: interfaceinvoke v.(8, null); label: v = v.; if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 1 goto label; v = new java.sql.SQLException; specialinvoke v.(java.lang.String)>("Failed add a message"); throw v; label: v = v.; if v != 0 goto label; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; if v != 0 goto label; if v == null goto label; interfaceinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doUpdateMessage(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.MessageId, byte[]) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; long v; org.apache.activemq.store.jdbc.TransactionContext v; int v; java.lang.String v, v, v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.io.IOException v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.command.MessageId; v := @parameter: byte[]; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); virtualinvoke v.(v, 1, v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(2, v); v = virtualinvoke v.(); interfaceinvoke v.(3, v); v = virtualinvoke v.(); interfaceinvoke v.(4, v); v = interfaceinvoke v.(); if v == 1 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not update message: \u in \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: staticinvoke (v); goto label; label: v := @caughtexception; staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doAddMessageReference(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.MessageId, org.apache.activemq.command.ActiveMQDestination, long, java.lang.String) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; long v, v, v, v; java.sql.SQLException v; org.apache.activemq.store.jdbc.TransactionContext v; int v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: long; v := @parameter: org.apache.activemq.command.MessageId; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: long; v := @parameter: java.lang.String; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v); label: v = virtualinvoke v.(); interfaceinvoke v.(1, v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(2, v); v = virtualinvoke v.(); interfaceinvoke v.(3, v); v = virtualinvoke v.(); interfaceinvoke v.(4, v); interfaceinvoke v.(5, v); interfaceinvoke v.(6, v); v = v.; if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 1 goto label; v = new java.sql.SQLException; specialinvoke v.(java.lang.String)>("Failed add a message"); throw v; label: v = v.; if v != 0 goto label; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; if v != 0 goto label; interfaceinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public long[] getStoreSequenceId(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.MessageId) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; long v, v, v; long[] v, v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v, v; boolean v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.command.MessageId; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(1, v); v = virtualinvoke v.(); interfaceinvoke v.(2, v); v = virtualinvoke v.(); interfaceinvoke v.(3, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = newarray (long)[2]; v[0] = 0L; v[1] = 0L; label: staticinvoke (v); staticinvoke (v); return v; label: v = newarray (long)[2]; v = interfaceinvoke v.(1); v[0] = v; v = interfaceinvoke v.(2); v[1] = v; label: staticinvoke (v); staticinvoke (v); return v; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public byte[] doGetMessage(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.MessageId) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; long v; java.sql.PreparedStatement v; org.apache.activemq.command.ProducerId v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.MessageId; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(1, v); v = virtualinvoke v.(); interfaceinvoke v.(2, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; label: staticinvoke (v); staticinvoke (v); return null; label: v = virtualinvoke v.(v, 1); label: staticinvoke (v); staticinvoke (v); return v; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public java.lang.String doGetMessageReference(org.apache.activemq.store.jdbc.TransactionContext, long) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; long v; java.sql.PreparedStatement v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v; boolean v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: long; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.(1, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; label: staticinvoke (v); staticinvoke (v); return null; label: v = interfaceinvoke v.(1); label: staticinvoke (v); staticinvoke (v); return v; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void doRemoveMessage(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.XATransactionId) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v, v; long v; java.sql.SQLException v; org.apache.activemq.store.jdbc.TransactionContext v; int v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v, v; boolean v, v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: long; v := @parameter: org.apache.activemq.command.XATransactionId; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v); label: if v != null goto label; interfaceinvoke v.(1, v); goto label; label: v = virtualinvoke v.(); v[0] = 45; v = staticinvoke (v); interfaceinvoke v.(1, v); interfaceinvoke v.(2, v); label: v = v.; if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 1 goto label; v = new java.sql.SQLException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to remove message seq: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != 0 goto label; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; if v != 0 goto label; if v == null goto label; interfaceinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doRecover(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v, v; long v; org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v, v; boolean v, v, v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(1, v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(2); v = interfaceinvoke v.(v); if v != 0 goto label; goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(1); v = virtualinvoke v.(v, 2); v = interfaceinvoke v.(v, v); if v != 0 goto label; label: staticinvoke (v); staticinvoke (v); goto label; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doMessageIdScan(org.apache.activemq.store.jdbc.TransactionContext, int, org.apache.activemq.store.jdbc.JDBCMessageIdScanListener) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v; long v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; int v, v; java.lang.String v, v, v; java.util.LinkedList v; boolean v, v, v; org.apache.activemq.store.jdbc.JDBCMessageIdScanListener v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.command.MessageId v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; java.lang.Object v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: int; v := @parameter: org.apache.activemq.store.jdbc.JDBCMessageIdScanListener; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new java.util.LinkedList; specialinvoke v.()>(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.command.MessageId; v = interfaceinvoke v.(2); v = interfaceinvoke v.(3); specialinvoke v.(java.lang.String,long)>(v, v); virtualinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("messageIdScan with limit (\u), resulted in: \u ids"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: staticinvoke (v); staticinvoke (v); goto label; label: v := @caughtexception; staticinvoke (v); staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doSetLastAckWithPriority(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.XATransactionId, java.lang.String, java.lang.String, long, long) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v, v; long v, v; java.sql.SQLException v; org.apache.activemq.store.jdbc.TransactionContext v; int v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.command.XATransactionId; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: long; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v); label: if v == null goto label; v = specialinvoke v.(v, v, v); v = staticinvoke (v); interfaceinvoke v.(1, v); goto label; label: interfaceinvoke v.(1, v); label: v = virtualinvoke v.(); interfaceinvoke v.(2, v); interfaceinvoke v.(3, v); interfaceinvoke v.(4, v); interfaceinvoke v.(5, v); v = v.; if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 1 goto label; v = new java.sql.SQLException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed update last ack with priority: \u, for sub: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != 0 goto label; staticinvoke (v); goto label; label: v := @caughtexception; v = v.; if v != 0 goto label; staticinvoke (v); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doSetLastAck(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.XATransactionId, java.lang.String, java.lang.String, long, long) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v, v; long v, v; org.apache.activemq.store.jdbc.TransactionContext v; int v; org.apache.activemq.command.XATransactionId v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.io.IOException v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: org.apache.activemq.command.XATransactionId; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: long; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v); label: if v == null goto label; v = specialinvoke v.(v, v, v); v = staticinvoke (v); interfaceinvoke v.(1, v); goto label; label: interfaceinvoke v.(1, v); label: v = virtualinvoke v.(); interfaceinvoke v.(2, v); interfaceinvoke v.(3, v); interfaceinvoke v.(4, v); v = v.; if v == 0 goto label; interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); if v == 1 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not update last ack seq : \u, for sub: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != 0 goto label; staticinvoke (v); goto label; label: v := @caughtexception; v = v.; if v != 0 goto label; staticinvoke (v); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } private byte[] encodeXid(org.apache.activemq.command.XATransactionId, long, long) { byte[] v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; long v, v; byte v; java.lang.Long v; org.apache.activemq.util.DataByteArrayOutputStream v; org.apache.activemq.command.XATransactionId v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.command.XATransactionId; v := @parameter: long; v := @parameter: long; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1); virtualinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); return v; } public void doClearLastAck(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, byte, java.lang.String, java.lang.String) throws java.sql.SQLException, java.io.IOException { java.lang.Throwable v; java.sql.Connection v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; org.apache.activemq.store.jdbc.Statements v; java.io.IOException v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; byte v; org.apache.activemq.store.jdbc.TransactionContext v; int v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: byte; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(1, v); interfaceinvoke v.(2, v); interfaceinvoke v.(3, v); interfaceinvoke v.(4, v); v = interfaceinvoke v.(); if v == 1 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not remove prepared transaction state from message ack for: \u0001:\u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: staticinvoke (v); goto label; label: v := @caughtexception; staticinvoke (v); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void doRecoverSubscription(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception { java.lang.Throwable v; byte[] v; java.sql.Connection v; org.apache.activemq.store.jdbc.Statements v, v; long v; org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener v; org.apache.activemq.store.jdbc.TransactionContext v; java.sql.ResultSet v; java.lang.String v, v, v, v, v; boolean v, v, v, v, v; org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter v; java.sql.PreparedStatement v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter; v := @parameter: org.apache.activemq.store.jdbc.TransactionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener; v = null; v = null; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(1, v); interfaceinvoke v.(2, v); interfaceinvoke v.(3, v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(2); v = interfaceinvoke v.(v); if v != 0 goto label; goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(1); v = virtualinvoke v.