Package org.apache.ofbiz.service.jms
Class JmsServiceEngine
- java.lang.Object
-
- org.apache.ofbiz.service.engine.AbstractEngine
-
- org.apache.ofbiz.service.jms.JmsServiceEngine
-
- All Implemented Interfaces:
GenericEngine
public class JmsServiceEngine extends AbstractEngine
AbstractJMSEngine
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
module
-
Fields inherited from class org.apache.ofbiz.service.engine.AbstractEngine
dispatcher, locationMap
-
Fields inherited from interface org.apache.ofbiz.service.engine.GenericEngine
ASYNC_MODE, SYNC_MODE
-
-
Constructor Summary
Constructors Constructor Description JmsServiceEngine(ServiceDispatcher dispatcher)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected JmsService
getServiceElement(ModelService modelService)
protected javax.jms.Message
makeMessage(javax.jms.Session session, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context)
protected java.util.Map<java.lang.String,java.lang.Object>
run(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context)
void
runAsync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, boolean persist)
Run the service asynchronously and IGNORE the result.void
runAsync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, GenericRequester requester, boolean persist)
Run the service asynchronously, passing an instance of GenericRequester that will receive the result.protected java.util.Map<java.lang.String,java.lang.Object>
runQueue(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, Server server)
java.util.Map<java.lang.String,java.lang.Object>
runSync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context)
Run the service synchronously and return the result.void
runSyncIgnore(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context)
Run the service synchronously and IGNORE the result.protected java.util.Map<java.lang.String,java.lang.Object>
runTopic(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, Server server)
protected java.util.Map<java.lang.String,java.lang.Object>
runXaQueue(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, org.w3c.dom.Element server)
protected java.util.List<? extends org.w3c.dom.Element>
serverList(org.w3c.dom.Element serviceElement)
-
Methods inherited from class org.apache.ofbiz.service.engine.AbstractEngine
allowCallbacks, createLocationMap, getLocation, sendCallbacks, sendCallbacks, sendCallbacks
-
-
-
-
Constructor Detail
-
JmsServiceEngine
public JmsServiceEngine(ServiceDispatcher dispatcher)
-
-
Method Detail
-
getServiceElement
protected JmsService getServiceElement(ModelService modelService) throws GenericServiceException
- Throws:
GenericServiceException
-
makeMessage
protected javax.jms.Message makeMessage(javax.jms.Session session, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context) throws GenericServiceException, javax.jms.JMSException
- Throws:
GenericServiceException
javax.jms.JMSException
-
serverList
protected java.util.List<? extends org.w3c.dom.Element> serverList(org.w3c.dom.Element serviceElement) throws GenericServiceException
- Throws:
GenericServiceException
-
runTopic
protected java.util.Map<java.lang.String,java.lang.Object> runTopic(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, Server server) throws GenericServiceException
- Throws:
GenericServiceException
-
runQueue
protected java.util.Map<java.lang.String,java.lang.Object> runQueue(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, Server server) throws GenericServiceException
- Throws:
GenericServiceException
-
runXaQueue
protected java.util.Map<java.lang.String,java.lang.Object> runXaQueue(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, org.w3c.dom.Element server) throws GenericServiceException
- Throws:
GenericServiceException
-
run
protected java.util.Map<java.lang.String,java.lang.Object> run(ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context) throws GenericServiceException
- Throws:
GenericServiceException
-
runSync
public java.util.Map<java.lang.String,java.lang.Object> runSync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context) throws GenericServiceException
Description copied from interface:GenericEngine
Run the service synchronously and return the result.- Parameters:
localName
- Name of the LocalDispatcher.modelService
- Service model object.context
- Map of name, value pairs composing the context.- Returns:
- Map of name, value pairs composing the result.
- Throws:
GenericServiceException
- See Also:
GenericEngine.runSync(java.lang.String, org.apache.ofbiz.service.ModelService, java.util.Map)
-
runSyncIgnore
public void runSyncIgnore(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context) throws GenericServiceException
Description copied from interface:GenericEngine
Run the service synchronously and IGNORE the result.- Parameters:
localName
- Name of the LocalDispatcher.modelService
- Service model object.context
- Map of name, value pairs composing the context.- Throws:
GenericServiceException
- See Also:
GenericEngine.runSyncIgnore(java.lang.String, org.apache.ofbiz.service.ModelService, java.util.Map)
-
runAsync
public void runAsync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, GenericRequester requester, boolean persist) throws GenericServiceException
Description copied from interface:GenericEngine
Run the service asynchronously, passing an instance of GenericRequester that will receive the result.- Parameters:
localName
- Name of the LocalDispatcher.modelService
- Service model object.context
- Map of name, value pairs composing the context.requester
- Object implementing GenericRequester interface which will receive the result.persist
- True for store/run; False for run.- Throws:
GenericServiceException
- See Also:
GenericEngine.runAsync(java.lang.String, org.apache.ofbiz.service.ModelService, java.util.Map, org.apache.ofbiz.service.GenericRequester, boolean)
-
runAsync
public void runAsync(java.lang.String localName, ModelService modelService, java.util.Map<java.lang.String,java.lang.Object> context, boolean persist) throws GenericServiceException
Description copied from interface:GenericEngine
Run the service asynchronously and IGNORE the result.- Parameters:
localName
- Name of the LocalDispatcher.modelService
- Service model object.context
- Map of name, value pairs composing the context.persist
- True for store/run; False for run.- Throws:
GenericServiceException
- See Also:
GenericEngine.runAsync(java.lang.String, org.apache.ofbiz.service.ModelService, java.util.Map, boolean)
-
-