Package de.hybris.platform.servicelayer.event.impl

Class PlatformClusterEventSender

java.lang.Object

de.hybris.platform.servicelayer.event.impl.SpringEventSender

de.hybris.platform.servicelayer.event.impl.PlatformClusterEventSender

All Implemented Interfaces:

BinaryBroadcastListener, EventSender, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class PlatformClusterEventSender
extends SpringEventSender
implements BinaryBroadcastListener

Extends the class SpringEventSender and sends the AbstractEvents in the sendEvent(AbstractEvent) as UDP packets in a cluster system. The packet will be de~/serialized.

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.event.impl.SpringEventSender

applicationContext

Constructor Summary

Constructors

Constructor	Description
PlatformClusterEventSender()

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.Executor	getExecutor()	Gets the executor used for sending local events asynchronous.
protected boolean	isForOwnTenant(AbstractEvent event)
void	postConstruct()	Deprecated, for removal: This API element is subject to removal in a future version. since ages
void	preDestroy()
void	processPacket(byte[] message)	be aware of the fact that this is running in a different thread!
void	registerBinaryListenerHook()
void	sendEvent(AbstractEvent event)	Sends the given AbstractEvent depending on the environment.
void	setExecutor(java.util.concurrent.Executor executor)	Sets the executor to use for sending local events asynchronous.
void	setSerializationService(SerializationService serializationService)
void	setTenant(Tenant tenant)

Methods inherited from class de.hybris.platform.servicelayer.event.impl.SpringEventSender

setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

PlatformClusterEventSender

public PlatformClusterEventSender()

Method Detail

sendEvent

public void sendEvent(AbstractEvent event)

Description copied from interface: EventSender

Sends the given AbstractEvent depending on the environment.

Specified by:

sendEvent in interface EventSender

Overrides:

sendEvent in class SpringEventSender

Parameters:

event - the event to be send.

postConstruct

@Deprecated(since="ages",
            forRemoval=true)
@PostConstruct
public void postConstruct()

Deprecated, for removal: This API element is subject to removal in a future version.

since ages

registerBinaryListenerHook

public void registerBinaryListenerHook()

preDestroy

@PreDestroy
public void preDestroy()

processPacket

public void processPacket(byte[] message)

be aware of the fact that this is running in a different thread!

Specified by:

processPacket in interface BinaryBroadcastListener

isForOwnTenant

protected boolean isForOwnTenant(AbstractEvent event)

setExecutor

public void setExecutor(java.util.concurrent.Executor executor)

Sets the executor to use for sending local events asynchronous. If this property is set, ALL(!!) local events will be sent asynchronously by the specified Executor.

Parameters:

executor - executor to use or null for synchronous sending

getExecutor

public java.util.concurrent.Executor getExecutor()

Gets the executor used for sending local events asynchronous. Returns null if local events are send synchronous.

Returns:

executor or null

setSerializationService

public void setSerializationService(SerializationService serializationService)

setTenant

public void setTenant(Tenant tenant)