Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-4005 - pluggable lockers; move shared file locker from kahadb package and improve javadocs 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1378917 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2012-08-30 13:00:04 +00:00
parent b080d5fe21
commit f5178cc73f
3 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/main/java/org/apache/activemq/broker/Locker.java
View File

@ -56,7 +56,9 @@ public interface Locker extends Service {
/**
* Configure the locker with the persistence adapter currently used
* Optionally configure the locker with the persistence adapter currently used
* You can use persistence adapter configuration details like, data directory
* datasource, etc. to be used by the locker
*
* @param persistenceAdapter
* @throws IOException

4
activemq-core/src/main/java/org/apache/activemq/store/kahadb/SharedFileLocker.java → activemq-core/src/main/java/org/apache/activemq/store/SharedFileLocker.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.activemq.store.kahadb;
package org.apache.activemq.store;
import org.apache.activemq.broker.AbstractLocker;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.kahadb.MessageDatabase;
import org.apache.activemq.util.ServiceStopper;
import org.apache.kahadb.util.LockFile;
import org.slf4j.Logger;

1
activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java
View File

@ -30,6 +30,7 @@ import org.apache.activemq.protobuf.Buffer;
import org.apache.activemq.broker.Locker;
import org.apache.activemq.store.MessageStore;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.SharedFileLocker;
import org.apache.activemq.store.TopicMessageStore;
import org.apache.activemq.store.TransactionStore;
import org.apache.activemq.store.kahadb.data.KahaLocalTransactionId;