public class JMSJournalStorageManagerImpl extends Object implements JMSStorageManager
Constructor and Description |
---|
JMSJournalStorageManagerImpl(IDGenerator idGenerator,
Configuration config,
ReplicationManager replicator) |
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) |
public JMSJournalStorageManagerImpl(IDGenerator idGenerator, Configuration config, ReplicationManager replicator)
public List<PersistedConnectionFactory> recoverConnectionFactories()
recoverConnectionFactories
in interface JMSStorageManager
public void storeConnectionFactory(PersistedConnectionFactory connectionFactory) throws Exception
storeConnectionFactory
in interface JMSStorageManager
Exception
public void deleteConnectionFactory(String cfName) throws Exception
deleteConnectionFactory
in interface JMSStorageManager
Exception
public List<PersistedDestination> recoverDestinations()
recoverDestinations
in interface JMSStorageManager
public void storeDestination(PersistedDestination destination) throws Exception
storeDestination
in interface JMSStorageManager
Exception
public List<PersistedJNDI> recoverPersistedJNDI() throws Exception
recoverPersistedJNDI
in interface JMSStorageManager
Exception
public void addJNDI(PersistedType type, String name, String... address) throws Exception
addJNDI
in interface JMSStorageManager
Exception
public void deleteJNDI(PersistedType type, String name, String address) throws Exception
deleteJNDI
in interface JMSStorageManager
Exception
public void deleteJNDI(PersistedType type, String name) throws Exception
deleteJNDI
in interface JMSStorageManager
Exception
public void deleteDestination(PersistedType type, String name) throws Exception
deleteDestination
in interface JMSStorageManager
Exception
public boolean isStarted()
isStarted
in interface HornetQComponent
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void installReplication(ReplicationEndpoint replicationEndpoint) throws Exception
JMSStorageManager
installReplication
in interface JMSStorageManager
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public void load() throws Exception
load
in interface JMSStorageManager
Exception
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.