public class org.apache.activemq.store.jdbc.Statements extends java.lang.Object { protected java.lang.String messageTableName; protected java.lang.String durableSubAcksTableName; protected java.lang.String lockTableName; protected java.lang.String binaryDataType; protected java.lang.String containerNameDataType; protected java.lang.String msgIdDataType; protected java.lang.String sequenceDataType; protected java.lang.String longDataType; protected java.lang.String stringIdDataType; protected boolean useExternalMessageReferences; private java.lang.String tablePrefix; private java.lang.String addMessageStatement; private java.lang.String updateMessageStatement; private java.lang.String removeMessageStatement; private java.lang.String findMessageSequenceIdStatement; private java.lang.String findMessageStatement; private java.lang.String findMessageByIdStatement; private java.lang.String findAllMessagesStatement; private java.lang.String findLastSequenceIdInMsgsStatement; private java.lang.String findLastSequenceIdInAcksStatement; private java.lang.String createDurableSubStatement; private java.lang.String findDurableSubStatement; private java.lang.String findAllDurableSubsStatement; private java.lang.String updateLastPriorityAckRowOfDurableSubStatement; private java.lang.String deleteSubscriptionStatement; private java.lang.String findAllDurableSubMessagesStatement; private java.lang.String findDurableSubMessagesStatement; private java.lang.String findDurableSubMessagesByPriorityStatement; private java.lang.String findAllDestinationsStatement; private java.lang.String removeAllMessagesStatement; private java.lang.String removeAllSubscriptionsStatement; private java.lang.String[] createSchemaStatements; private java.lang.String[] createLockSchemaStatements; private java.lang.String[] dropSchemaStatements; private java.lang.String lockCreateStatement; private java.lang.String lockUpdateStatement; private java.lang.String nextDurableSubscriberMessageStatement; private java.lang.String durableSubscriberMessageCountStatement; private java.lang.String lastAckedDurableSubscriberMessageStatement; private java.lang.String destinationMessageCountStatement; private java.lang.String findNextMessagesStatement; private java.lang.String findNextMessagesByPriorityStatement; private boolean useLockCreateWhereClause; private java.lang.String findAllMessageIdsStatement; private java.lang.String lastProducerSequenceIdStatement; private java.lang.String selectDurablePriorityAckStatement; private java.lang.String insertDurablePriorityAckStatement; private java.lang.String updateDurableLastAckStatement; private java.lang.String deleteOldMessagesStatementWithPriority; private java.lang.String durableSubscriberMessageCountStatementWithPriority; private java.lang.String dropAckPKAlterStatementEnd; private java.lang.String updateXidFlagStatement; private java.lang.String findOpsPendingOutcomeStatement; private java.lang.String clearXidFlagStatement; private java.lang.String updateDurableLastAckInTxStatement; private java.lang.String findAcksPendingOutcomeStatement; private java.lang.String clearDurableLastAckInTxStatement; private java.lang.String updateDurableLastAckWithPriorityStatement; private java.lang.String updateDurableLastAckWithPriorityInTxStatement; private java.lang.String findXidByIdStatement; private java.lang.String leaseObtainStatement; private java.lang.String currentDateTimeStatement; private java.lang.String leaseUpdateStatement; private java.lang.String leaseOwnerStatement; public void () { org.apache.activemq.store.jdbc.Statements v; v := @this: org.apache.activemq.store.jdbc.Statements; specialinvoke v.()>(); v. = "ACTIVEMQ_MSGS"; v. = "ACTIVEMQ_ACKS"; v. = "ACTIVEMQ_LOCK"; v. = "BLOB"; v. = "VARCHAR(250)"; v. = "VARCHAR(250)"; v. = "BIGINT"; v. = "BIGINT"; v. = "VARCHAR(250)"; v. = ""; return; } public java.lang.String[] getCreateSchemaStatements() { java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v; org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v, v, v, v, v, v, v, v, v, v; int v, v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = newarray (java.lang.String)[15]; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; if v == 0 goto label; v = v.; goto label; label: v = v.; label: v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v) ("CREATE TABLE \u0001(ID \u NOT NULL, CONTAINER \u NOT NULL, MSGID_PROD \u, MSGID_SEQ \u, EXPIRATION \u, MSG \u, PRIMARY KEY ( ID ) )"); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_MIDX ON \u (MSGID_PROD,MSGID_SEQ)"); v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_CIDX ON \u (CONTAINER)"); v[2] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_EIDX ON \u (EXPIRATION)"); v[3] = v; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v, v) ("CREATE TABLE \u0001(CONTAINER \u NOT NULL, SUB_DEST \u, CLIENT_ID \u NOT NULL, SUB_NAME \u NOT NULL, SELECTOR \u, LAST_ACKED_ID \u, CONSTRAINT PK_\u PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME))"); v[4] = v; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ALTER TABLE \u ADD PRIORITY \u0001"); v[5] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_PIDX ON \u (PRIORITY)"); v[6] = v; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ALTER TABLE \u ADD XID \u0001"); v[7] = v; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ALTER TABLE \u ADD PRIORITY \u DEFAULT 5 NOT NULL"); v[8] = v; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ALTER TABLE \u ADD XID \u0001"); v[9] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ALTER TABLE \u \u0001"); v[10] = v; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("ALTER TABLE \u ADD PRIMARY KEY (CONTAINER, CLIENT_ID, SUB_NAME, PRIORITY)"); v[11] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_XIDX ON \u (XID)"); v[12] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_XIDX ON \u (XID)"); v[13] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CREATE INDEX \u0001_IIDX ON \u (ID ASC, XID, CONTAINER)"); v[14] = v; v. = v; label: virtualinvoke v.(); v = v.; v = lengthof v; v = v.; v = lengthof v; v = v + v; v = newarray (java.lang.String)[v]; v = v.; v = v.; v = lengthof v; staticinvoke (v, 0, v, 0, v); v = v.; v = v.; v = lengthof v; v = v.; v = lengthof v; staticinvoke (v, 0, v, v, v); return v; } public java.lang.String[] getCreateLockSchemaStatements() { org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v, v, v; java.lang.String v, v, v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = newarray (java.lang.String)[2]; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("CREATE TABLE \u0001( ID \u NOT NULL, TIME \u, BROKER_NAME \u, PRIMARY KEY (ID) )"); v[0] = v; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO \u0001(ID) VALUES (1)"); v[1] = v; v. = v; label: v = v.; return v; } public java.lang.String getDropAckPKAlterStatementEnd() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v. = "DROP PRIMARY KEY"; label: v = v.; return v; } public void setDropAckPKAlterStatementEnd(java.lang.String) { org.apache.activemq.store.jdbc.Statements v; java.lang.String v; v := @this: org.apache.activemq.store.jdbc.Statements; v := @parameter: java.lang.String; v. = v; return; } public java.lang.String[] getDropSchemaStatements() { org.apache.activemq.store.jdbc.Statements v; java.lang.String[] v, v, v; java.lang.String v, v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = newarray (java.lang.String)[3]; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DROP TABLE \u0001"); v[0] = v; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DROP TABLE \u0001"); v[1] = v; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DROP TABLE \u0001"); v[2] = v; v. = v; label: v = v.; return v; } public java.lang.String getAddMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO \u0001(ID, MSGID_PROD, MSGID_SEQ, CONTAINER, EXPIRATION, PRIORITY, MSG, XID) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET MSG=? WHERE MSGID_PROD=? AND MSGID_SEQ=? AND CONTAINER=?"); v. = v; label: v = v.; return v; } public java.lang.String getRemoveMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DELETE FROM \u WHERE ID=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindMessageSequenceIdStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT ID, PRIORITY FROM \u WHERE MSGID_PROD=? AND MSGID_SEQ=? AND CONTAINER=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MSG FROM \u WHERE MSGID_PROD=? AND MSGID_SEQ=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindMessageByIdStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MSG FROM \u WHERE ID=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindXidByIdStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT XID FROM \u WHERE ID=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindAllMessagesStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT ID, MSG FROM \u WHERE CONTAINER=? ORDER BY ID"); v. = v; label: v = v.; return v; } public java.lang.String getFindAllMessageIdsStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT ID, MSGID_PROD, MSGID_SEQ FROM \u ORDER BY ID DESC"); v. = v; label: v = v.; return v; } public void setFindAllMessageIdsStatement(java.lang.String) { org.apache.activemq.store.jdbc.Statements v; java.lang.String v; v := @this: org.apache.activemq.store.jdbc.Statements; v := @parameter: java.lang.String; v. = v; return; } public java.lang.String getFindLastSequenceIdInMsgsStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MAX(ID) FROM \u0001"); v. = v; label: v = v.; return v; } public java.lang.String getLastProducerSequenceIdStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MAX(MSGID_SEQ) FROM \u WHERE MSGID_PROD=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindLastSequenceIdInAcksStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MAX(LAST_ACKED_ID) FROM \u0001"); v. = v; label: v = v.; return v; } public java.lang.String getCreateDurableSubStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO \u0001(CONTAINER, CLIENT_ID, SUB_NAME, SELECTOR, LAST_ACKED_ID, SUB_DEST, PRIORITY) VALUES (?, ?, ?, ?, ?, ?, ?)"); v. = v; label: v = v.; return v; } public java.lang.String getFindDurableSubStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT SELECTOR, SUB_DEST FROM \u WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindAllDurableSubsStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT SELECTOR, SUB_NAME, CLIENT_ID, SUB_DEST FROM \u WHERE CONTAINER=? AND PRIORITY=0"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateLastPriorityAckRowOfDurableSubStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET LAST_ACKED_ID=? WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=? AND PRIORITY=?"); v. = v; label: v = v.; return v; } public java.lang.String getDeleteSubscriptionStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DELETE FROM \u WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=?"); v. = v; label: v = v.; return v; } public java.lang.String getFindAllDurableSubMessagesStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT M.ID, M.MSG FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.CONTAINER=D.CONTAINER AND M.ID > D.LAST_ACKED_ID ORDER BY M.PRIORITY DESC, M.ID"); v. = v; label: v = v.; return v; } public java.lang.String getFindDurableSubMessagesStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT M.ID, M.MSG FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.XID IS NULL AND M.CONTAINER=D.CONTAINER AND M.ID > D.LAST_ACKED_ID AND M.ID > ? ORDER BY M.ID"); v. = v; label: v = v.; return v; } public java.lang.String getFindDurableSubMessagesByPriorityStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT M.ID, M.MSG FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.XID IS NULL AND M.CONTAINER=D.CONTAINER AND M.PRIORITY=D.PRIORITY AND M.ID > D.LAST_ACKED_ID AND M.ID > ? AND M.PRIORITY = ? ORDER BY M.ID"); v. = v; label: v = v.; return v; } public java.lang.String getNextDurableSubscriberMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT M.ID, M.MSG FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.CONTAINER=D.CONTAINER AND M.ID > ? ORDER BY M.ID "); v. = v; label: v = v.; return v; } public java.lang.String getDurableSubscriberMessageCountStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("SELECT COUNT(*) FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.CONTAINER=D.CONTAINER AND M.ID > ( SELECT LAST_ACKED_ID FROM \u WHERE CONTAINER=D.CONTAINER AND CLIENT_ID=D.CLIENT_ID AND SUB_NAME=D.SUB_NAME )"); v. = v; label: v = v.; return v; } public java.lang.String getDurableSubscriberMessageCountStatementWithPriority() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT COUNT(*) FROM \u M, \u D WHERE D.CONTAINER=? AND D.CLIENT_ID=? AND D.SUB_NAME=? AND M.CONTAINER=D.CONTAINER AND M.PRIORITY=D.PRIORITY AND M.ID > D.LAST_ACKED_ID"); v. = v; label: v = v.; return v; } public java.lang.String getFindAllDestinationsStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("SELECT DISTINCT CONTAINER FROM \u WHERE CONTAINER IS NOT NULL UNION SELECT DISTINCT CONTAINER FROM \u0001"); v. = v; label: v = v.; return v; } public java.lang.String getRemoveAllMessagesStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DELETE FROM \u WHERE CONTAINER=?"); v. = v; label: v = v.; return v; } public java.lang.String getRemoveAllSubscriptionsStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DELETE FROM \u WHERE CONTAINER=?"); v. = v; label: v = v.; return v; } public java.lang.String getDeleteOldMessagesStatementWithPriority() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v) ("DELETE FROM \u WHERE (PRIORITY=? AND ID <= ( SELECT min(\u.LAST_ACKED_ID) FROM \u WHERE \u.CONTAINER=\u.CONTAINER AND \u.PRIORITY=?) )"); v. = v; label: v = v.; return v; } public java.lang.String getLockCreateStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v, v, v, v, v; boolean v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT * FROM \u0001"); v. = v; v = v.; if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u WHERE ID = 1"); v. = v; label: v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u FOR UPDATE"); v. = v; label: v = v.; return v; } public java.lang.String getLeaseObtainStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET BROKER_NAME=?, TIME=? WHERE (TIME IS NULL OR TIME < ?) AND ID = 1"); v. = v; label: v = v.; return v; } public java.lang.String getCurrentDateTime() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT CURRENT_TIMESTAMP FROM \u0001"); v. = v; label: v = v.; return v; } public java.lang.String getLeaseUpdateStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET BROKER_NAME=?, TIME=? WHERE BROKER_NAME=? AND ID = 1"); v. = v; label: v = v.; return v; } public java.lang.String getLeaseOwnerStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT BROKER_NAME, TIME FROM \u WHERE ID = 1"); v. = v; label: v = v.; return v; } public java.lang.String getLockUpdateStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET TIME = ? WHERE ID = 1"); v. = v; label: v = v.; return v; } public java.lang.String getDestinationMessageCountStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT COUNT(*) FROM \u WHERE CONTAINER=? AND XID IS NULL"); v. = v; label: v = v.; return v; } public java.lang.String getFindNextMessagesStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT ID, MSG FROM \u WHERE CONTAINER=? AND ID < ? AND ID > ? AND XID IS NULL ORDER BY ID"); v. = v; label: v = v.; return v; } public java.lang.String getFindNextMessagesByPriorityStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT ID, MSG FROM \u WHERE CONTAINER=? AND XID IS NULL AND ID < ? AND ( (ID > ? AND PRIORITY = 9) OR (ID > ? AND PRIORITY = 8) OR (ID > ? AND PRIORITY = 7) OR (ID > ? AND PRIORITY = 6) OR (ID > ? AND PRIORITY = 5) OR (ID > ? AND PRIORITY = 4) OR (ID > ? AND PRIORITY = 3) OR (ID > ? AND PRIORITY = 2) OR (ID > ? AND PRIORITY = 1) OR (ID > ? AND PRIORITY = 0) ) ORDER BY PRIORITY DESC, ID"); v. = v; label: v = v.; return v; } public void setFindNextMessagesByPriorityStatement(java.lang.String) { org.apache.activemq.store.jdbc.Statements v; java.lang.String v; v := @this: org.apache.activemq.store.jdbc.Statements; v := @parameter: java.lang.String; v. = v; return; } public java.lang.String getLastAckedDurableSubscriberMessageStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT MAX(LAST_ACKED_ID) FROM \u WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=?"); v. = v; label: v = v.; return v; } public java.lang.String getSelectDurablePriorityAckStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("SELECT LAST_ACKED_ID FROM \u WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=? AND PRIORITY = ?"); v. = v; label: v = v.; return v; } public java.lang.String getInsertDurablePriorityAckStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO \u0001(CONTAINER, CLIENT_ID, SUB_NAME, PRIORITY) VALUES (?, ?, ?, ?)"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateDurableLastAckStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET LAST_ACKED_ID=?, XID = NULL WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=?"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateDurableLastAckInTxStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET XID=? WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=?"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateDurableLastAckWithPriorityStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.; if v != null goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UPDATE \u SET LAST_ACKED_ID=?, XID = NULL WHERE CONTAINER=? AND CLIENT_ID=? AND SUB_NAME=? AND PRIORITY=?"); v. = v; label: v = v.; return v; } public java.lang.String getUpdateDurableLastAckWithPriorityInTxStatement() { org.apache.activemq.store.jdbc.Statements v; java.lang.String v, v, v, v; v := @this: org.apache.activemq.store.jdbc.Statements; v = v.