org.springframework.flex.messaging.jms
Class JmsAdapter

java.lang.Object
  flex.management.ManageableComponent
      flex.messaging.services.ServiceAdapter
          flex.messaging.services.messaging.adapters.MessagingAdapter
              org.springframework.flex.messaging.jms.JmsAdapter

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

public class JmsAdapter
extends flex.messaging.services.messaging.adapters.MessagingAdapter
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanNameAware

A MessagingAdapter implementation that enables sending and receiving messages via JMS.

Author:

Mark Fisher, Jeremy Grelle

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

JmsAdapter()

Method Summary

void	afterPropertiesSet()
org.springframework.jms.core.JmsTemplate	getJmsTemplate() Returns the JmsTemplate used by this adapter
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	setConnectionFactory(javax.jms.ConnectionFactory connectionFactory) Sets the ConnectionFactory to use for sending and receiving JMS messages
void	setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver) Sets the DestinationResolver for resolving the JMS destination for this adapter
void	setJmsDestination(javax.jms.Destination destination) Sets the JMS Destination for messages sent and received by this adapter
void	setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter) Sets the MessageConverter for messages sent and received by this adapter.
void	setQueueName(java.lang.String queueName) Sets the JMS queue name for messages sent and received by this adapter.
void	setTopicName(java.lang.String topicName) Sets the JMS topic name for messages sent and received by this adapter.
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) Sets the PlatformTransactionManager to be used when sending and receiving messages
void	start()
void	stop()

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

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

JmsAdapter

public JmsAdapter()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

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

getJmsTemplate

public org.springframework.jms.core.JmsTemplate getJmsTemplate()

Returns the JmsTemplate used by this adapter

Returns:

the jms template

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

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

Sets the ConnectionFactory to use for sending and receiving JMS messages

Parameters:

connectionFactory - the connection factory

setDestinationResolver

public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)

Sets the DestinationResolver for resolving the JMS destination for this adapter

Parameters:

destinationResolver - the destination resolver

setJmsDestination

public void setJmsDestination(javax.jms.Destination destination)

Sets the JMS Destination for messages sent and received by this adapter

Parameters:

destination - the destination

setMessageConverter

public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)

Sets the MessageConverter for messages sent and received by this adapter.

Parameters:

messageConverter - the message converter

setQueueName

public void setQueueName(java.lang.String queueName)

Sets the JMS queue name for messages sent and received by this adapter.

Parameters:

queueName - the JMS queue name

setTopicName

public void setTopicName(java.lang.String topicName)

Sets the JMS topic name for messages sent and received by this adapter.

Parameters:

topicName - the JMS topic name

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

Sets the PlatformTransactionManager to be used when sending and receiving messages

Parameters:

transactionManager - the transaction manager

start

public void start()

Specified by:

start in interface flex.messaging.FlexComponent

Overrides:

start in class flex.messaging.services.ServiceAdapter

stop

public void stop()

Specified by:

stop in interface flex.messaging.FlexComponent

Overrides:

stop in class flex.messaging.services.ServiceAdapter