Class HazelcastOutboundGateway

java.lang.Object

org.frankframework.management.gateway.HazelcastOutboundGateway

All Implemented Interfaces:

OutboundGateway, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.integration.IntegrationPattern

public class HazelcastOutboundGateway
extends Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, OutboundGateway

Nested Class Summary

Nested classes/interfaces inherited from interface OutboundGateway

OutboundGateway.ClusterMember

Constructor Summary

Constructors

Constructor	Description
HazelcastOutboundGateway()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
@NonNull List<OutboundGateway.ClusterMember>	getMembers()
<I> void	sendAsyncMessage(org.springframework.messaging.Message<I> in)	I in, no reply
<I,O> @NonNull org.springframework.messaging.Message<O>	sendSyncMessage(org.springframework.messaging.Message<I> in)	I in O out.
void	setApplicationContext(@NonNull org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class Object

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

Methods inherited from interface OutboundGateway

getIntegrationPatternType

Constructor Details

HazelcastOutboundGateway

public HazelcastOutboundGateway()

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

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

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