Package org.openwms.common.comm.osip.synq

Class TimesyncServiceActivator

java.lang.Object

org.openwms.common.comm.osip.synq.TimesyncServiceActivator

All Implemented Interfaces:

org.openwms.common.comm.CustomServiceActivator, org.openwms.common.comm.NotRespondingServiceActivator<TimesyncRequest>

@OSIP
@MessageEndpoint
class TimesyncServiceActivator
extends Object
implements org.openwms.common.comm.NotRespondingServiceActivator<TimesyncRequest>

A TimesyncServiceActivator implements the Service Activator pattern and delegates incoming TimesyncRequests to the appropriate handler function.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private final org.springframework.context.ApplicationContext	ctx
private final Function<org.springframework.messaging.support.GenericMessage<TimesyncRequest>,Void>	handler
(package private) static final String	INPUT_CHANNEL_NAME	The name of the MessageChannel used as input-channel of this message processor.

Constructor Summary

Constructors

Constructor	Description
TimesyncServiceActivator(Function<org.springframework.messaging.support.GenericMessage<TimesyncRequest>,Void> handler, org.springframework.context.ApplicationContext ctx)

Method Summary

Modifier and Type	Method	Description
org.springframework.messaging.MessageChannel	getChannel()
String	getChannelName()
void	wakeUp(org.springframework.messaging.support.GenericMessage<TimesyncRequest> message)

Methods inherited from class java.lang.Object

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

Field Details

INPUT_CHANNEL_NAME

static final String INPUT_CHANNEL_NAME

The name of the MessageChannel used as input-channel of this message processor.

See Also:

• Constant Field Values

handler

private final Function<org.springframework.messaging.support.GenericMessage<TimesyncRequest>,Void> handler

ctx

private final org.springframework.context.ApplicationContext ctx

Constructor Details

TimesyncServiceActivator

@Autowired
public TimesyncServiceActivator(Function<org.springframework.messaging.support.GenericMessage<TimesyncRequest>,Void> handler,
 org.springframework.context.ApplicationContext ctx)

Method Details

wakeUp

@OSIP
@Measured
@ServiceActivator(inputChannel="SYNQMessageInputChannel")
public void wakeUp(org.springframework.messaging.support.GenericMessage<TimesyncRequest> message)

Specified by:

wakeUp in interface org.openwms.common.comm.NotRespondingServiceActivator<TimesyncRequest>

getChannel

public org.springframework.messaging.MessageChannel getChannel()

Specified by:

getChannel in interface org.openwms.common.comm.CustomServiceActivator

getChannelName

public String getChannelName()

Specified by:

getChannelName in interface org.openwms.common.comm.CustomServiceActivator