public class HibernateConsumerRegistry extends AbstractConsumerRegistry
AbstractConsumerRegistry.InMemoryConsumerCache, AbstractConsumerRegistry.ProducerInfoIteratorconsumerCache, log| Constructor and Description |
|---|
HibernateConsumerRegistry() |
| Modifier and Type | Method and Description |
|---|---|
void |
delete(ProducerInfo info) |
Collection<String> |
getConfiguredConsumersIds() |
Iterator<ProducerInfo> |
getProducerInfosFromStorage() |
String |
getSessionFactoryJNDIName() |
protected void |
initConsumerCache() |
ProducerInfo |
loadProducerInfo(String id) |
void |
save(ProducerInfo info,
String messageOnError) |
void |
setSessionFactoryJNDIName(String sessionFactoryJNDIName) |
void |
start() |
void |
stop() |
String |
update(ProducerInfo producerInfo)
Updates the given ProducerInfo
|
activateConsumer, activateConsumerWith, containsConsumer, createConsumer, createConsumerFrom, deactivateConsumer, deactivateConsumerWith, deregisterWithFederatingPortletInvoker, destroyConsumer, getConfiguredConsumerNumber, getConfiguredConsumers, getConsumer, getConsumers, getFederatingPortletInvoker, getMigrationService, getPersistedLastModifiedForProducerInfoWith, getSessionRegistry, registerOrDeregisterConsumerWith, registerWithFederatingPortletInvoker, reloadConsumers, setConsumerCache, setFederatingPortletInvoker, setMigrationService, setSessionEventBroadcaster, setSessionRegistry, updateProducerInfopublic void save(ProducerInfo info, String messageOnError)
public void delete(ProducerInfo info)
public String getSessionFactoryJNDIName()
public void setSessionFactoryJNDIName(String sessionFactoryJNDIName)
public String update(ProducerInfo producerInfo)
producerInfo - the ProducerInfo to updatenull if the id hasn't
been modifiedpublic Iterator<ProducerInfo> getProducerInfosFromStorage()
public ProducerInfo loadProducerInfo(String id)
public void start()
throws Exception
start in interface ConsumerRegistrySPIstart in class AbstractConsumerRegistryExceptionpublic void stop()
throws Exception
stop in interface ConsumerRegistrySPIstop in class AbstractConsumerRegistryExceptionpublic Collection<String> getConfiguredConsumersIds()
protected void initConsumerCache()
initConsumerCache in class AbstractConsumerRegistryCopyright © 2006-2014 GateIn. All Rights Reserved.