org.springframework.flex.messaging.integration
Class IntegrationAdapter

java.lang.Object
  flex.management.ManageableComponent
      flex.messaging.services.ServiceAdapter
          flex.messaging.services.messaging.adapters.MessagingAdapter
              org.springframework.flex.messaging.integration.IntegrationAdapter

All Implemented Interfaces:

flex.management.Manageable, flex.messaging.FlexComponent, flex.messaging.FlexConfigurable, flex.messaging.security.MessagingSecurity, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.integration.message.MessageHandler

public class IntegrationAdapter
extends flex.messaging.services.messaging.adapters.MessagingAdapter
implements org.springframework.integration.message.MessageHandler, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanNameAware

A MessagingAdapter implementation that enables sending and receiving messages via Spring Integration Message Channels.

Author:

Mark Fisher

Field Summary

Fields inherited from class flex.messaging.services.ServiceAdapter

LOG_CATEGORY

Fields inherited from class flex.management.ManageableComponent

control, id, managed, NULL_COMPONENT_PROPERTY, parent, PROPERTY_CHANGE_AFTER_STARTUP, started, valid

Constructor Summary

IntegrationAdapter()

Method Summary

void	afterPropertiesSet()
void	handleMessage(org.springframework.integration.core.Message<?> message) Invoked when a Message is received from the Spring Integration channel.
boolean	handlesSubscriptions()
java.lang.Object	invoke(flex.messaging.messages.Message flexMessage) Invoked when a Message is received from a Flex client.
java.lang.Object	manage(flex.messaging.messages.CommandMessage commandMessage)
void	setBeanName(java.lang.String beanName)
void	setExtractPayload(boolean extractPayload) Specify whether the Flex Message body should be extracted to be used as the payload of a Spring Integration Message.
void	setMessageChannel(org.springframework.integration.core.MessageChannel messageChannel) Sets the Spring Integration MessageChannel for sending and receiving messages
void	start()

Methods inherited from class flex.messaging.services.messaging.adapters.MessagingAdapter

allowSend, allowSubscribe, getSecurityConstraintManager, initialize, setSecurityConstraintManager, validate

Methods inherited from class flex.messaging.services.ServiceAdapter

getAdapterState, getDestination, getLogCategory, setAdapterState, setDestination, setupAdapterControl, stop

Methods inherited from class flex.management.ManageableComponent

blockAssignmentWhileStarted, blockNullAssignment, getControl, getId, getParent, invalidate, isManaged, isStarted, isValid, setControl, setId, setManaged, setParent, setStarted, setValid

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegrationAdapter

public IntegrationAdapter()

Method Detail

setExtractPayload

public void setExtractPayload(boolean extractPayload)

Specify whether the Flex Message body should be extracted to be used as the payload of a Spring Integration Message. If this is set to false, the entire Flex Message will be sent as the payload. The default is true.

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

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

handleMessage

public void handleMessage(org.springframework.integration.core.Message<?> message)

Invoked when a Message is received from the Spring Integration channel.

Specified by:

handleMessage in interface org.springframework.integration.message.MessageHandler

handlesSubscriptions

public boolean handlesSubscriptions()

Overrides:

handlesSubscriptions in class flex.messaging.services.ServiceAdapter

invoke

public java.lang.Object invoke(flex.messaging.messages.Message flexMessage)

Invoked when a Message is received from a Flex client.

Specified by:

invoke in class flex.messaging.services.ServiceAdapter

manage

public java.lang.Object manage(flex.messaging.messages.CommandMessage commandMessage)

Overrides:

manage in class flex.messaging.services.ServiceAdapter

setBeanName

public void setBeanName(java.lang.String beanName)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

setMessageChannel

public void setMessageChannel(org.springframework.integration.core.MessageChannel messageChannel)

Sets the Spring Integration MessageChannel for sending and receiving messages

Parameters:

messageChannel - the message channel

start

public void start()

Specified by:

start in interface flex.messaging.FlexComponent

Overrides:

start in class flex.messaging.services.ServiceAdapter