这是MULE的配置文件.
<?xml version="1.0" encoding="UTF-8"?>
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:spring="http://www.springframework.org/schema/beans"
xmlns:rmi="http://www.mulesoft.org/schema/mule/rmi"
xmlns:vm="http://www.mulesoft.org/schema/mule/vm"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/vm http://www.mulesoft.org/schema/mule/vm/current/mule-vm.xsd
http://www.mulesoft.org/schema/mule/rmi http://www.mulesoft.org/schema/mule/rmi/current/mule-rmi.xsd">
<spring:bean id="jndiFactory" name="jndiFactory" class="org.mule.transport.rmi.MuleRMIFactory"/>
<spring:bean id="jndiContext" name="jndiContext" factory-bean="jndiFactory" factory-method="create">
<spring:constructor-arg><spring:null /></spring:constructor-arg>
</spring:bean>
<rmi:connector name="rmi" jndiContext-ref="jndiContext" />
<vm:connector name="vmQueue"/>
<rmi:endpoint name="Sender" host="localhost" port="1099" object="SimpleMathsUMO"
method="addTen" exchange-pattern="request-response"/>
<endpoint name="Sender2" address="rmi://localhost:1099/MatchingUMO?method=reverseString"
exchange-pattern="request-response"/>
<flow name="TestUMO">
<inbound-endpoint address="vm://query" exchange-pattern="request-response"/>
<outbound-endpoint ref="Sender"/>
</flow>
这是客户端的程序.
import java.util.HashMap;
import java.util.Map;
import org.mule.api.MuleContext;
import org.mule.api.MuleException;
import org.mule.api.MuleMessage;
import org.mule.context.DefaultMuleContextFactory;
import org.mule.module.client.MuleClient;
public class MyMuleClientTest {
public static void main(String[] args) throws MuleException
{
// create mule
MuleContext muleContext;
String config = "Example_RMITest.xml";
muleContext = new DefaultMuleContextFactory().createMuleContext(config);
muleContext.start();
// creat mule client
MuleClient client = new MuleClient(true);
Map map = new HashMap();
// map.put("firstName", "p001");
MuleMessage response = client.send("vm://query", map, null);
System.out.println("response = " + response.getPayload());
}
}
现在我遇到了这个异常:"There is no receiver registered on connector "connector.VM.mule.default" for endpointUri vm://query".
我真的不知道为什么了,请帮帮我,谢谢!
相关推荐
博文链接:https://hideto.iteye.com/blog/65607
利用mule 服务总线代理 cxf发布的服务。其中详细的描述了cxf服务的发布的访问,以及如何使用mule的代理模式代理cxf的服务。步骤详细,有图有真相.
使用MuleEsb同时掉多个webservice,并返回到调用方。开发环境为AnyPoint3.7,将例子中的webservice接口修改成自己的即可运行。
博文链接:https://hideto.iteye.com/blog/65822
Mule ESB 是一个轻量级的基于java的企业服务总线和集成平台, 使得开发人员可以快速,简单的连接多个应用, 使得它们可以交换数据。 Mule ESB 容易集成现有异构系统,包括:JMS, Web Services, JDBC, HTTP, 等. ESB...
利用mule服务总线代理cxf服务源码。
简介了企业服务总线mule的实现基本结构
Mule是一个企业服务总线(ESB)消息框架,而且Mule是一个轻量级且高度可扩展的ESB。
MULE是一款开源的企业服务总线平台,可为企业各应用提供服务集成,支持基于Java的各种远程消息通信协议,如RMI、CORBA、WebService等等。资料含MULE的环境、配置、架构、集成、工具与使用个方面的指南,是应用MULE的...
一份关于Mule和其他Jms消息系统关联的开发文档,涉及系统的集成搭建
关于在tomcat上进行mule多线程数量参数配置
mule号称开源ESB的最好实现,一个以Java为核心的轻量级的消息框架和整合平台。它使得开发人员可以快速,简单的连接多个应用。 目前许多公司都使用了Mule,比如Walmart,HP,Sony,Deutsche Bank 以及 CitiBank等公司。...