Package org.openwms.common.comm.osip.router

Class CommonMessageRouter

java.lang.Object

org.openwms.common.comm.osip.router.CommonMessageRouter

@MessageEndpoint("messageRouter")
public class CommonMessageRouter
extends Object

A CommonMessageRouter collects all CustomServiceActivators from the ApplicationContext and tries to find the suitable CustomServiceActivator when an incoming message arrives. If no suitable processor is found, the message will be routed to the default exception channel.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private Map<String,org.openwms.common.comm.CustomServiceActivator>	processorMap
private final List<org.openwms.common.comm.CustomServiceActivator>	processors

Constructor Summary

Constructors

Constructor	Description
CommonMessageRouter(List<org.openwms.common.comm.CustomServiceActivator> processors)

Method Summary

Modifier and Type	Method	Description
(package private) void	onPostConstruct()
org.springframework.messaging.MessageChannel	resolve(org.springframework.messaging.Message<Payload> message)	Routing method, tries to map an incoming Payload to a MessageChannel.

Methods inherited from class java.lang.Object

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

Field Details

processors

private final List<org.openwms.common.comm.CustomServiceActivator> processors

processorMap

private Map<String,org.openwms.common.comm.CustomServiceActivator> processorMap

Constructor Details

CommonMessageRouter

public CommonMessageRouter(@Autowired(required=false)
 List<org.openwms.common.comm.CustomServiceActivator> processors)

Method Details

onPostConstruct

@PostConstruct
void onPostConstruct()

resolve

@Router(inputChannel="transformerOutputChannel",
        defaultOutputChannel="commonExceptionChannel",
        resolutionRequired="false")
public org.springframework.messaging.MessageChannel resolve(org.springframework.messaging.Message<Payload> message)

Routing method, tries to map an incoming Payload to a MessageChannel.

Parameters:

message - The message to process

Returns:

The MessageChannel where to put the message