org.ofbiz.service.jms
Class JmsServiceEngine
java.lang.Object
org.ofbiz.service.engine.AbstractEngine
org.ofbiz.service.jms.JmsServiceEngine
- All Implemented Interfaces:
- GenericEngine
public class JmsServiceEngine
- extends AbstractEngine
AbstractJMSEngine
Field Summary |
static java.lang.String |
module
|
Method Summary |
protected org.w3c.dom.Element |
getServiceElement(ModelService modelService)
|
protected Message |
makeMessage(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,
org.w3c.dom.Element 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,
org.w3c.dom.Element 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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
module
public static final java.lang.String module
JmsServiceEngine
public JmsServiceEngine(ServiceDispatcher dispatcher)
getServiceElement
protected org.w3c.dom.Element getServiceElement(ModelService modelService)
throws GenericServiceException
- Throws:
GenericServiceException
makeMessage
protected Message makeMessage(Session session,
ModelService modelService,
java.util.Map<java.lang.String,java.lang.Object> context)
throws GenericServiceException,
JMSException
- Throws:
GenericServiceException
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,
org.w3c.dom.Element 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,
org.w3c.dom.Element 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.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.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.ofbiz.service.ModelService, java.util.Map, org.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.ofbiz.service.ModelService, java.util.Map, boolean)