Class HazelcastOutboundGateway

java.lang.Object
org.frankframework.management.gateway.HazelcastOutboundGateway
All Implemented Interfaces:
OutboundGateway, org.springframework.beans.factory.Aware, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.IntegrationPattern
public class HazelcastOutboundGateway extends Object implements org.springframework.context.ApplicationContextAware, OutboundGateway, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean

  • Constructor Details

    • HazelcastOutboundGateway

      public HazelcastOutboundGateway()

    • HazelcastOutboundGateway

      protected HazelcastOutboundGateway(String requestTopicName)

  • Method Details

    • setApplicationContext

      public void setApplicationContext(@NonNull org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
      Specified by:
      setApplicationContext in interface org.springframework.context.ApplicationContextAware
      Throws:
      org.springframework.beans.BeansException

    • start

      public void start()
      Specified by:
      start in interface org.springframework.context.Lifecycle

    • stop

      public void stop()
      Remove old JWK when no longer needed.
      Specified by:
      stop in interface org.springframework.context.Lifecycle

    • isRunning

      public boolean isRunning()
      Specified by:
      isRunning in interface org.springframework.context.Lifecycle

    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.springframework.beans.factory.DisposableBean

    • sendSyncMessage

      public <I,O> @NonNull org.springframework.messaging.Message<O> sendSyncMessage(org.springframework.messaging.Message<I> in)
      Description copied from interface: OutboundGateway
      I in O out. May not be null.
      Specified by:
      sendSyncMessage in interface OutboundGateway
      Parameters:
      in - Message to send
      Returns:
      Response message

    • getMembers

      public @NonNull List<OutboundGateway.ClusterMember> getMembers()
      Specified by:
      getMembers in interface OutboundGateway

    • sendAsyncMessage

      public <I> void sendAsyncMessage(org.springframework.messaging.Message<I> in)
      Description copied from interface: OutboundGateway
      I in, no reply
      Specified by:
      sendAsyncMessage in interface OutboundGateway
      Parameters:
      in - Message to send