结合Spring2.0和ActiveMQ进行异步消息调用 - 完善自我,超越自我 - 七杀家园 Web开发者的博客 -

Copy code

<!-- this is the Message Driven POJO (MDP) -->

<bean id=

class=

erAdapter

<constructor-arg>

<bean

class=

/>

</constructor-arg>

<property name=

value=

<property name=

ref=

</bean>

<!-- and this is the attendant message

listener container -->

<bean id=

class=

rContainer

<property name=

ref=

<property name=

value=

<property name=

value=

<property name=

ref=

</bean>

Spring

配置监听器有很多种选择，在这里我选择这回种

MessageListenerA dapter

方法主要是因为这个方法比较灵活。

实现他只要一 个

很普通的

java

类即可，和

JMS

以及

Spr ing

的耦合度最低。

其中方法

onM essage

可以随便修改方法名，只要在配置文件

中对应的修 改就好了。

Mes sageListenerAdapter

还有一个功能就是如果处理方

法

(

我这里是

onMessa ge)

返回一个非空值，

它将自动返回一个

响应消息。

这个消息会返回给

JMS Reply-To< /p>

属性定义的目的

地

(

如果存在

)

，或者是

Messag eListenerAdapter

设置

(

如果配

置了

)

的缺省目的地；

如果没有定义目的地，

那么将产生一个

In validDestinationException

异常

(

此异常将不会只被捕获而不

处理，它将沿着调用堆栈上传

)

。

这样我们的配置就都完成了。接下来我们来实现对应

的

Java

文件

先是接口文件发送消息接口

Copy code

public interface IApmgtMessageProducer {

public abstract void sendMessage(ApmgtMessageData

messageData);

}

接受消息接口

Copy code

public interface IApmgtMessageListener {

public void onMessage(ApmgtMessageData message);

}

发消息的文件

Copy code

public class DefaultApmgtMessageProducer implements

IApmgtMessageProducer {

private JmsTemplate jmsTemplate;

public void

setJmsTemplate(JmsTemplate jmsTemplate) {

plate = jmsTemplate;

}

public void sendMessage(ApmgtMessageData

messageData) {

tAndSend(messageData);

}

}

收消息文件

Copy code

public class DefaultApmgtMessageListener implements

IApmgtMessageListener {

public void onMessage(ApmgtMessageData message) {

n(

监听到消息：

< br>

}

}

消息转换类

Copy code

public class ApmgtMessageConverter implements

MessageConverter {

private Log log =

();

private

SimpleMessageConverter converter;

public void

setConverter(SimpleMessageConverter converter) {

ter = converter;

}

public Object fromMessage(Message message)

throws JMSException, MessageConversionException {

if (message instanceof ObjectMessage) {

ObjectMessage o_message =

(ObjectMessage)message;

MessageHeader header = new MessageHeader();

(gProperty(

eiver(Property(

der(Property(

dPerson(ingProperty(

);

e(Property(

Serializable messageContent =

o_ect();

ApmgtMessageData<Serializable>

messageData = new ApmgtMessageData<Serializable>();

sageContent(messageContent);

sageHeader(header);

return messageData;

}

return null;

}

public Message toMessage(Object object, Session

session) throws JMSException, MessageConversionException {

if (object instanceof ApmgtMessageData) {

ApmgtMessageData data = (ApmgtMessageData)

object;

Message message =

age(sageContent(), session);

gProperty(

sageHeader().getId() );

Property(

sageHeader().getRecei ver());

Property(

sageHea der().getSender());

Property(

sageHeader().getType());

ing Property(

sageHeader().getSendPerson());

(

发送消息

[MessageSender ]:n

message);

return message;

} else {

return null;

}

}}

消息类文件

消息父类：

Copy code

public class ApmgtMessageData<T extends

Serializable>{

protected T messageContent;