com.atlassian.confluence.plugins.upgraderesource.amq

Class AmqPtlUpgradeMessageRunner

java.lang.Object

com.atlassian.confluence.plugins.upgraderesource.amq.AmqPtlUpgradeMessageRunner

All Implemented Interfaces:

com.atlassian.messagequeue.registry.MessageRunner, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

@Component(value="amqPtlUpgradeMessageRunner")
public class AmqPtlUpgradeMessageRunner
extends Object
implements com.atlassian.messagequeue.registry.MessageRunner, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

This is a MessageRunner implementation which listens to UpgradeRequests coming from Per Tenant loop via ConfluenceNewUpgradeTasksResource delivered by AMQ.

Look at processMessage(MessageContext) for main implementation part

See Also:

processMessage(MessageContext)

Field Summary

Fields

Modifier and Type	Field and Description
static com.atlassian.messagequeue.MessageRunnerKey	AMQ_PTL_UPGRADE_MESSAGE_RUNNER_KEY

Constructor Summary

Constructors

Constructor and Description
AmqPtlUpgradeMessageRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService, com.atlassian.beehive.ClusterLockService clusterLockService, UpgradeTaskRunner upgradeTaskRunner, AsapTokenGenerator asapTokenGenerator)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
void	processMessage(com.atlassian.messagequeue.registry.MessageContext messageContext)

Methods inherited from class java.lang.Object

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

Field Detail

AMQ_PTL_UPGRADE_MESSAGE_RUNNER_KEY

public static final com.atlassian.messagequeue.MessageRunnerKey AMQ_PTL_UPGRADE_MESSAGE_RUNNER_KEY

Constructor Detail

AmqPtlUpgradeMessageRunner

@Autowired
public AmqPtlUpgradeMessageRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService,
                                             com.atlassian.beehive.ClusterLockService clusterLockService,
                                             UpgradeTaskRunner upgradeTaskRunner,
                                             AsapTokenGenerator asapTokenGenerator)

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

processMessage

public void processMessage(com.atlassian.messagequeue.registry.MessageContext messageContext)

Specified by:

processMessage in interface com.atlassian.messagequeue.registry.MessageRunner