de.hybris.platform.servicelayer.cronjob.impl

Class DefaultRunCronJobMessageCreatorAndSender

java.lang.Object

de.hybris.platform.servicelayer.cronjob.impl.DefaultRunCronJobMessageCreatorAndSender

All Implemented Interfaces:

RunCronJobMessageCreatorAndSender

public class DefaultRunCronJobMessageCreatorAndSender
extends java.lang.Object
implements RunCronJobMessageCreatorAndSender

Creates a literal message as :

 [CRONJOB]START|tenantid|nodeid|cronjob pk.
 

This message will be send (broadcasted) to other nodes in the cluster to start a cronjob.

Constructor Summary

Constructors

Constructor and Description
DefaultRunCronJobMessageCreatorAndSender()

Method Summary

Modifier and Type	Method and Description
void	createAndSendMessage(int remoteClusterId, PK cronJobPK) Creates and sends a new message for performing a CronJob with cronJobPK on remote cluster remoteClusterId
protected java.lang.String	createCronJobBroadcastMessagePrefix()
void	setClusterService(ClusterService clusterService)
void	setLegacyBroadcastHandler(LegacyBroadcastHandler legacyBroadcastHandler)
void	setTenantService(TenantService tenantService)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRunCronJobMessageCreatorAndSender

public DefaultRunCronJobMessageCreatorAndSender()

Method Detail

setTenantService

public void setTenantService(TenantService tenantService)

setClusterService

public void setClusterService(ClusterService clusterService)

setLegacyBroadcastHandler

public void setLegacyBroadcastHandler(LegacyBroadcastHandler legacyBroadcastHandler)

createCronJobBroadcastMessagePrefix

protected java.lang.String createCronJobBroadcastMessagePrefix()

createAndSendMessage

public final void createAndSendMessage(int remoteClusterId,
                                       PK cronJobPK)

Description copied from interface: RunCronJobMessageCreatorAndSender

Creates and sends a new message for performing a CronJob with cronJobPK on remote cluster remoteClusterId

Specified by:

createAndSendMessage in interface RunCronJobMessageCreatorAndSender