1 18 package org.apache.activemq.store.jdbc.adapter; 19 20 import org.apache.activemq.store.jdbc.Statements; 21 22 26 public class MySqlJDBCAdapter extends DefaultJDBCAdapter { 27 28 public void setStatements(Statements statements) { 29 statements.setLockCreateStatement("LOCK TABLE " + statements.getFullLockTableName() + " WRITE"); 30 statements.setBinaryDataType("LONGBLOB"); 31 super.setStatements(statements); 32 } 33 } 34 | Popular Tags |