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 -
Method Summary
Modifier and TypeMethodDescriptionGets the executor used for sending local events asynchronous.protected booleanisForOwnTenant(AbstractEvent event) voidDeprecated, for removal: This API element is subject to removal in a future version.since agesvoidvoidprocessPacket(byte[] message) be aware of the fact that this is running in a different thread!voidvoidsendEvent(AbstractEvent event) Sends the givenAbstractEventdepending on the environment.voidsetExecutor(Executor executor) Sets the executor to use for sending local events asynchronous.voidsetSerializationService(SerializationService serializationService) voidMethods inherited from class de.hybris.platform.servicelayer.event.impl.SpringEventSender
setApplicationContext
-
Constructor Details
-
PlatformClusterEventSender
public PlatformClusterEventSender()
-
-
Method Details
-
sendEvent
Description copied from interface:EventSenderSends the givenAbstractEventdepending on the environment.- Specified by:
sendEventin interfaceEventSender- Overrides:
sendEventin classSpringEventSender- Parameters:
event- the event to be send.
-
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:
processPacketin interfaceBinaryBroadcastListener
-
isForOwnTenant
-
setExecutor
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
Gets the executor used for sending local events asynchronous. Returns null if local events are send synchronous.- Returns:
- executor or null
-
setSerializationService
-
setTenant
-