Package com.atlassian.jira.cluster.dbr.transport

Class DefaultDBRTransportManager

java.lang.Object

com.atlassian.jira.cluster.dbr.transport.DefaultDBRTransportManager

All Implemented Interfaces:

DBRTransportManager, InitializingComponent

public class DefaultDBRTransportManager
extends Object
implements DBRTransportManager, InitializingComponent

Constructor Summary

Constructors

Constructor	Description
DefaultDBRTransportManager(ClusterManager clusterManager, com.atlassian.cache.CacheManager cacheManager)

Method Summary

Modifier and Type	Method	Description
void	afterInstantiation()	Called after all the beans are constructed and the ApplicationContext is fully populated.
void	register(Consumer<DBRMessage> consumer)
void	send(DBRMessage message)
void	unregister(Consumer<DBRMessage> consumer)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultDBRTransportManager

public DefaultDBRTransportManager(ClusterManager clusterManager,
 com.atlassian.cache.CacheManager cacheManager)

Method Details

afterInstantiation

public void afterInstantiation()
                        throws Exception

Description copied from interface: InitializingComponent

Called after all the beans are constructed and the ApplicationContext is fully populated. Order of execution is order of bean creation, driven by InitializingComponentProcessor.

Specified by:

afterInstantiation in interface InitializingComponent

Throws:

Exception

send

public void send(DBRMessage message)

Specified by:

send in interface DBRTransportManager

register

public void register(Consumer<DBRMessage> consumer)

Specified by:

register in interface DBRTransportManager

unregister

public void unregister(Consumer<DBRMessage> consumer)

Specified by:

unregister in interface DBRTransportManager