org.hornetq.jms.persistence.impl.journal

Class JMSJournalStorageManagerImpl

java.lang.Object

org.hornetq.jms.persistence.impl.journal.JMSJournalStorageManagerImpl

All Implemented Interfaces:

HornetQComponent, JMSStorageManager

public class JMSJournalStorageManagerImpl
extends Object
implements JMSStorageManager

A JournalJMSStorageManagerImpl

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
JMSJournalStorageManagerImpl(IDGenerator idGenerator, Configuration config, ReplicationManager replicator)

Method Summary

Methods

Modifier and Type	Method and Description
void	addJNDI(PersistedType type, String name, String... address)
void	deleteConnectionFactory(String cfName)
void	deleteDestination(PersistedType type, String name)
void	deleteJNDI(PersistedType type, String name)
void	deleteJNDI(PersistedType type, String name, String address)
void	installReplication(ReplicationEndpoint replicationEndpoint) Add the journal here to the replication endpoint
boolean	isStarted()
void	load()
List<PersistedConnectionFactory>	recoverConnectionFactories()
List<PersistedDestination>	recoverDestinations()
List<PersistedJNDI>	recoverPersistedJNDI()
void	start()
void	stop()
void	storeConnectionFactory(PersistedConnectionFactory connectionFactory)
void	storeDestination(PersistedDestination destination)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSJournalStorageManagerImpl

public JMSJournalStorageManagerImpl(IDGenerator idGenerator,
                            Configuration config,
                            ReplicationManager replicator)

Method Detail

recoverConnectionFactories

public List<PersistedConnectionFactory> recoverConnectionFactories()

Specified by:

recoverConnectionFactories in interface JMSStorageManager

storeConnectionFactory

public void storeConnectionFactory(PersistedConnectionFactory connectionFactory)
                            throws Exception

Specified by:

storeConnectionFactory in interface JMSStorageManager

Throws:

Exception

deleteConnectionFactory

public void deleteConnectionFactory(String cfName)
                             throws Exception

Specified by:

deleteConnectionFactory in interface JMSStorageManager

Throws:

Exception

recoverDestinations

public List<PersistedDestination> recoverDestinations()

Specified by:

recoverDestinations in interface JMSStorageManager

storeDestination

public void storeDestination(PersistedDestination destination)
                      throws Exception

Specified by:

storeDestination in interface JMSStorageManager

Throws:

Exception

recoverPersistedJNDI

public List<PersistedJNDI> recoverPersistedJNDI()
                                         throws Exception

Specified by:

recoverPersistedJNDI in interface JMSStorageManager

Throws:

Exception

addJNDI

public void addJNDI(PersistedType type,
           String name,
           String... address)
             throws Exception

Specified by:

addJNDI in interface JMSStorageManager

Throws:

Exception

deleteJNDI

public void deleteJNDI(PersistedType type,
              String name,
              String address)
                throws Exception

Specified by:

deleteJNDI in interface JMSStorageManager

Throws:

Exception

deleteJNDI

public void deleteJNDI(PersistedType type,
              String name)
                throws Exception

Specified by:

deleteJNDI in interface JMSStorageManager

Throws:

Exception

deleteDestination

public void deleteDestination(PersistedType type,
                     String name)
                       throws Exception

Specified by:

deleteDestination in interface JMSStorageManager

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

installReplication

public void installReplication(ReplicationEndpoint replicationEndpoint)
                        throws Exception

Description copied from interface: JMSStorageManager

Add the journal here to the replication endpoint

Specified by:

installReplication in interface JMSStorageManager

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

load

public void load()
          throws Exception

Specified by:

load in interface JMSStorageManager

Throws:

Exception