You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2009/01/21 23:56:43 UTC
svn commit: r736467 - in /ode/branches/restful:
bpel-api/src/main/java/org/apache/ode/bpel/iapi/
bpel-api/src/main/java/org/apache/ode/bpel/rapi/
bpel-dao/src/main/java/org/apache/ode/bpel/dao/
dao-hibernate/src/main/java/org/apache/ode/daohib/ dao-hib...
Author: mriou
Date: Wed Jan 21 14:56:42 2009
New Revision: 736467
URL: http://svn.apache.org/viewvc?rev=736467&view=rev
Log:
Returning a 201 with a Location header when a request creates a new resource.
Modified:
ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/iapi/RESTInMessageExchange.java
ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/rapi/IOContext.java
ode/branches/restful/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/SessionManager.java
ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java
ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java
ode/branches/restful/dao-jpa/src/main/java/org/apache/ode/dao/jpa/MessageExchangeDAOImpl.java
ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java
ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/ODERESTProcess.java
ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/RESTInMessageExchangeImpl.java
ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/memdao/MessageExchangeDAOImpl.java
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OdeInternalInstance.java
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/PICK.java
ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/RuntimeInstanceImpl.java
ode/branches/restful/runtimes/src/test/java/org/apache/ode/bpel/rtrep/v2/CoreBpelTest.java
Modified: ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/iapi/RESTInMessageExchange.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/iapi/RESTInMessageExchange.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/iapi/RESTInMessageExchange.java (original)
+++ ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/iapi/RESTInMessageExchange.java Wed Jan 21 14:56:42 2009
@@ -13,4 +13,6 @@
Status invokeBlocking() throws BpelEngineException, TimeoutException;
void setRequest(Message message);
+
+ boolean isInstantiatingResource();
}
Modified: ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/rapi/IOContext.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/rapi/IOContext.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/rapi/IOContext.java (original)
+++ ode/branches/restful/bpel-api/src/main/java/org/apache/ode/bpel/rapi/IOContext.java Wed Jan 21 14:56:42 2009
@@ -90,6 +90,8 @@
*/
Element getMyRequest(String mexId);
+ void setInstantiatingMex(String mexId);
+
void releasePartnerMex(String mexId);
Element getSourceEPR(String mexId);
Modified: ode/branches/restful/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java (original)
+++ ode/branches/restful/bpel-dao/src/main/java/org/apache/ode/bpel/dao/MessageExchangeDAO.java Wed Jan 21 14:56:42 2009
@@ -284,4 +284,7 @@
void setPipedPID(QName pipedPid);
+ boolean isInstantiatingResource();
+
+ void setInstantiatingResource(boolean inst);
}
Modified: ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/SessionManager.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/SessionManager.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/SessionManager.java (original)
+++ ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/SessionManager.java Wed Jan 21 14:56:42 2009
@@ -100,7 +100,8 @@
.addClass(HVariableProperty.class)
.addClass(HBpelEvent.class)
.addClass(HFaultData.class)
- .addClass(HActivityRecovery.class)
+ .addClass(HActivityRecovery.class)
+ .addClass(HResourceRoute.class)
.addClass(HLargeData.class);
}
Modified: ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java (original)
+++ ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java Wed Jan 21 14:56:42 2009
@@ -395,4 +395,11 @@
return _hself.getResource();
}
+ public boolean isInstantiatingResource() {
+ return _hself.isInstantiatingResource();
+ }
+
+ public void setInstantiatingResource(boolean inst) {
+ _hself.setInstantiatingResource(inst);
+ }
}
Modified: ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java (original)
+++ ode/branches/restful/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/hobj/HMessageExchange.java Wed Jan 21 14:56:42 2009
@@ -89,6 +89,8 @@
private String _pipedPid;
+ private boolean _instantiatingResource;
+
/**
*
*/
@@ -433,4 +435,16 @@
public void setResource(String resource) {
this._resource = resource;
}
+
+ /**
+ * @hibernate.property column="INST_RES"
+ */
+ public boolean isInstantiatingResource() {
+ return _instantiatingResource;
+ }
+
+ public void setInstantiatingResource(boolean inst) {
+ _instantiatingResource = inst;
+ }
+
}
Modified: ode/branches/restful/dao-jpa/src/main/java/org/apache/ode/dao/jpa/MessageExchangeDAOImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/dao-jpa/src/main/java/org/apache/ode/dao/jpa/MessageExchangeDAOImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/dao-jpa/src/main/java/org/apache/ode/dao/jpa/MessageExchangeDAOImpl.java (original)
+++ ode/branches/restful/dao-jpa/src/main/java/org/apache/ode/dao/jpa/MessageExchangeDAOImpl.java Wed Jan 21 14:56:42 2009
@@ -130,6 +130,9 @@
@Basic @Column(name="PIPED_PID")
private String _pipedPid;
+ @Basic @Column(name="INST_RES")
+ private boolean _instantiatingResource;
+
public MessageExchangeDAOImpl() {}
public MessageExchangeDAOImpl(String mexId, char direction){
@@ -413,4 +416,12 @@
public void setResource(String resourceStr) {
_resource = resourceStr;
}
+
+ public boolean isInstantiatingResource() {
+ return _instantiatingResource;
+ }
+
+ public void setInstantiatingResource(boolean inst) {
+ _instantiatingResource = inst;
+ }
}
Modified: ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java (original)
+++ ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java Wed Jan 21 14:56:42 2009
@@ -432,7 +432,7 @@
evt.setPortType(plink.getModel().getMyRolePortType().getQName());
// Get the "my-role" mex from the DB.
- MessageExchangeDAO myrolemex = _dao.getConnection().getMessageExchange(mexId);
+ MessageExchangeDAO myrolemex = getExistingMex(mexId);
Operation operation = plink.getModel().getMyRoleOperation(opName);
if (operation == null || operation.getOutput() == null) throw new NoSuchOperationException();
@@ -467,7 +467,7 @@
evt.setMexId(mexId);
evt.setResource(resource.getName());
- MessageExchangeDAO mex = _dao.getConnection().getMessageExchange(mexId);
+ MessageExchangeDAO mex = getExistingMex(mexId);
MessageDAO message = mex.createMessage(null);
buildOutgoingMessage(message, msg);
mex.setResponse(message);
@@ -779,7 +779,7 @@
__log.debug("<invoke> response for mexid " + mexid + " and channel " + invokeId);
}
- MessageExchangeDAO mex = _dao.getConnection().getMessageExchange(mexid);
+ MessageExchangeDAO mex = getExistingMex(mexid);
ProcessMessageExchangeEvent evt = new ProcessMessageExchangeEvent();
evt.setPortType(mex.getPortType());
@@ -866,18 +866,12 @@
}
public Element getMyRequest(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
- if (dao == null) {
- // this should not happen....
- String msg = "Engine requested non-existent message exchange: " + mexId;
- __log.fatal(msg);
- throw new BpelEngineException(msg);
- }
+ MessageExchangeDAO dao = getExistingMex(mexId);
if (dao.getDirection() != MessageExchangeDAO.DIR_PARTNER_INVOKES_MYROLE) {
// this should not happen....
String msg = "Engine requested my-role request for a partner-role mex: " + mexId;
- __log.fatal(msg);
+ __log.error(msg);
throw new BpelEngineException(msg);
}
@@ -885,13 +879,18 @@
if (request == null) {
// this also should not happen
String msg = "Engine requested request for message exchange that did not have one: " + mexId;
- __log.fatal(msg);
+ __log.error(msg);
throw new BpelEngineException(msg);
}
return mergeHeaders(request);
}
+ public void setInstantiatingMex(String mexId) {
+ MessageExchangeDAO mex = getExistingMex(mexId);
+ mex.setInstantiatingResource(true);
+ }
+
private Element mergeHeaders(MessageDAO msg) {
// Merging header data, it's all stored in the same variable
Element data = msg.getData();
@@ -915,13 +914,7 @@
}
public QName getPartnerFault(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
- if (dao == null) {
- // this should not happen....
- String msg = "Engine requested non-existent message exchange: " + mexId;
- __log.fatal(msg);
- throw new BpelEngineException(msg);
- }
+ MessageExchangeDAO dao = getExistingMex(mexId);
return dao.getFault();
}
@@ -935,13 +928,7 @@
}
private MessageDAO _getPartnerResponse(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
- if (dao == null) {
- // this should not happen....
- String msg = "Engine requested non-existent message exchange: " + mexId;
- __log.fatal(msg);
- throw new BpelEngineException(msg);
- }
+ MessageExchangeDAO dao = getExistingMex(mexId);
if (dao.getDirection() != MessageExchangeDAO.DIR_BPEL_INVOKES_PARTNERROLE) {
// this should not happen....
String msg = "Engine requested partner response for a my-role mex: " + mexId;
@@ -969,13 +956,13 @@
}
public void releasePartnerMex(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
+ MessageExchangeDAO dao = getExistingMex(mexId);
dao.release();
}
public Element getSourceEPR(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
+ MessageExchangeDAO dao = getExistingMex(mexId);
String epr = dao.getProperty(WSMessageExchange.PROPERTY_SEP_PARTNERROLE_EPR);
if (epr == null)
return null;
@@ -989,7 +976,7 @@
}
public String getSourceSessionId(String mexId) {
- MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
+ MessageExchangeDAO dao = getExistingMex(mexId);
return dao.getProperty(WSMessageExchange.PROPERTY_SEP_PARTNERROLE_SESSIONID);
}
@@ -1055,4 +1042,15 @@
return _bpelProcess.getBaseResourceURI();
}
+ private MessageExchangeDAO getExistingMex(String mexId) {
+ MessageExchangeDAO dao = _dao.getConnection().getMessageExchange(mexId);
+ if (dao == null) {
+ // this should not happen....
+ String msg = "Engine requested non-existent message exchange: " + mexId;
+ __log.error(msg);
+ throw new BpelEngineException(msg);
+ }
+ return dao;
+ }
+
}
Modified: ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/ODERESTProcess.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/ODERESTProcess.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/ODERESTProcess.java (original)
+++ ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/ODERESTProcess.java Wed Jan 21 14:56:42 2009
@@ -19,7 +19,7 @@
private ConcurrentHashMap<ResourceModel,String> _staticResources = new ConcurrentHashMap<ResourceModel,String>();
- private ArrayList<Resource> _resources = new ArrayList<Resource>();
+ private ArrayList<Resource> _instantiatingResources = new ArrayList<Resource>();
public ODERESTProcess(BpelServerImpl server, ProcessConf conf, BpelEventListener debugger, IncomingMessageExchangeCache mexCache) {
super(server, conf, debugger, mexCache);
@@ -55,7 +55,7 @@
Resource resource = new Resource(_staticResources.get(resourceModel),
"application/xml", resourceModel.getMethod());
_contexts.bindingContext.activateProvidedResource(resource);
- _resources.add(resource);
+ _instantiatingResources.add(resource);
}
}
@@ -74,10 +74,10 @@
mexdao.setProcess(getProcessDAO());
try {
- Resource instantiatingResource = getResource(mexdao.getResource());
+ boolean instantiatingResource = isInstantiating(mexdao.getResource());
InvocationStyle istyle = mexdao.getInvocationStyle();
- if (instantiatingResource != null) {
+ if (instantiatingResource) {
ProcessInstanceDAO newInstance = getProcessDAO().createInstance(null);
newInstance.setInstantiatingUrl(mexdao.getResource());
@@ -156,6 +156,7 @@
p2pCall(mexdao, old);
} else /* not p2p */{
RESTInMessageExchangeImpl mymex = (RESTInMessageExchangeImpl) _incomingMexCache.get(mexdao, this);
+ mymex.load(mexdao);
mymex.getResource().setUrl(url);
if (old == MessageExchange.Status.ASYNC) {
// Updating url for instantiating mexs so that the created resource url can be returned to the caller
@@ -183,28 +184,21 @@
return new RESTInMessageExchangeImpl(this, mexdao.getMessageExchangeId(), resource);
}
- public Resource getResource(String url, String method) {
- for (Resource resource : _resources) {
- if (resource.getUrl().equals(url) && resource.getMethod().equals(method)) return resource;
- }
- return null;
- }
-
public Resource getResource(String serializedForm) {
int sep = serializedForm.indexOf("~");
String url = serializedForm.substring(0, sep);
String method = serializedForm.substring(sep + 1);
- for (Resource resource : _resources) {
- if (resource.getUrl().equals(url) && resource.getMethod().equals(method)) return resource;
- }
- return null;
+ return new Resource(url, "application/xml", method);
}
public Resource getInstantiatingUrl(ProcessInstanceDAO instanceDao) {
return getResource(instanceDao.getInstantiatingUrl());
}
+ protected boolean isInstantiating(String serialized) {
+ return isInstantiating(getResource(serialized));
+ }
protected boolean isInstantiating(Resource res) {
for (Map.Entry<ResourceModel, String> resourceModel : _staticResources.entrySet()) {
if (resourceModel.getValue().equals(res.getUrl())
Modified: ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/RESTInMessageExchangeImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/RESTInMessageExchangeImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/RESTInMessageExchangeImpl.java (original)
+++ ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/engine/RESTInMessageExchangeImpl.java Wed Jan 21 14:56:42 2009
@@ -17,6 +17,7 @@
private ResponseFuture _future;
private Resource _resource;
+ private boolean _instantiatingResource;
public RESTInMessageExchangeImpl(ODEProcess process, String mexId, Resource resource) {
super(process, null, mexId, null, null, null);
@@ -125,6 +126,7 @@
void save(MessageExchangeDAO dao) {
super.save(dao);
dao.setResource(_resource.getUrl() + "~" + _resource.getMethod());
+ dao.setInstantiatingResource(_instantiatingResource);
if (_changes.contains(Change.REQUEST)) {
_changes.remove(Change.REQUEST);
@@ -139,5 +141,10 @@
void load(MessageExchangeDAO dao) {
super.load(dao);
_resource = ((ODERESTProcess)_process).getResource(dao.getResource());
+ _instantiatingResource = dao.isInstantiatingResource();
+ }
+
+ public boolean isInstantiatingResource() {
+ return _instantiatingResource;
}
}
Modified: ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/memdao/MessageExchangeDAOImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/memdao/MessageExchangeDAOImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/memdao/MessageExchangeDAOImpl.java (original)
+++ ode/branches/restful/engine/src/main/java/org/apache/ode/bpel/memdao/MessageExchangeDAOImpl.java Wed Jan 21 14:56:42 2009
@@ -69,6 +69,7 @@
long _timeout;
AckType _ackType;
QName _pipedPID;
+ boolean _instantiatingResource;
public MessageExchangeDAOImpl(char direction, String messageEchangeId){
this.direction = direction;
@@ -330,4 +331,12 @@
_pipedPID = pipedPid;
}
+
+ public boolean isInstantiatingResource() {
+ return _instantiatingResource;
+ }
+
+ public void setInstantiatingResource(boolean inst) {
+ _instantiatingResource = inst;
+ }
}
Modified: ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OdeInternalInstance.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OdeInternalInstance.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OdeInternalInstance.java (original)
+++ ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/OdeInternalInstance.java Wed Jan 21 14:56:42 2009
@@ -73,6 +73,8 @@
Element getMyRequest(String mexId);
+ void setInstantiatingMex(String mexId);
+
void registerTimer(TimerResponseChannel timerChannel, Date future);
void registerActivityForRecovery(ActivityRecoveryChannel recoveryChannel, long id, String reason, Date dateTime,
Modified: ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/PICK.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/PICK.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/PICK.java (original)
+++ ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/PICK.java Wed Jan 21 14:56:42 2009
@@ -269,6 +269,9 @@
FaultData fault;
initVariable(mexId, onMessage);
try {
+ if (onMessage.isRestful() && onMessage.getResource().isInstantiateResource())
+ getBpelRuntime().setInstantiatingMex(mexId);
+
for (OScope.CorrelationSet cset : onMessage.initCorrelations) {
initializeCorrelation(_scopeFrame.resolve(cset), _scopeFrame.resolve(onMessage.variable));
}
Modified: ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/RuntimeInstanceImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/RuntimeInstanceImpl.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/RuntimeInstanceImpl.java (original)
+++ ode/branches/restful/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/RuntimeInstanceImpl.java Wed Jan 21 14:56:42 2009
@@ -372,6 +372,10 @@
return _brc.getMyRequest(mexId);
}
+ public void setInstantiatingMex(String mexId) {
+ _brc.setInstantiatingMex(mexId);
+ }
+
/**
* Proxy to {@link BpelRuntimeContext# }.
*/
Modified: ode/branches/restful/runtimes/src/test/java/org/apache/ode/bpel/rtrep/v2/CoreBpelTest.java
URL: http://svn.apache.org/viewvc/ode/branches/restful/runtimes/src/test/java/org/apache/ode/bpel/rtrep/v2/CoreBpelTest.java?rev=736467&r1=736466&r2=736467&view=diff
==============================================================================
--- ode/branches/restful/runtimes/src/test/java/org/apache/ode/bpel/rtrep/v2/CoreBpelTest.java (original)
+++ ode/branches/restful/runtimes/src/test/java/org/apache/ode/bpel/rtrep/v2/CoreBpelTest.java Wed Jan 21 14:56:42 2009
@@ -378,6 +378,9 @@
return null;
}
+ public void setInstantiatingMex(String mexId) {
+ }
+
public QName getPartnerFault(String mexId) {
// TODO Auto-generated method stub
return null;