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.
  • Constructor Details

    • PlatformClusterEventSender

      public PlatformClusterEventSender()
  • Method Details

    • 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(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 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)