public abstract class AbstractMessageReceiver extends Object implements MessageReceiver
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageReceiver.AsyncMessageReceiverWorker |
static class |
AbstractMessageReceiver.ThreadContextDescriptor |
Modifier and Type | Field and Description |
---|---|
static String |
DO_ASYNC |
protected static org.apache.commons.logging.Log |
log |
static String |
SAVED_MC |
static String |
SAVED_TCCL |
static String |
SCOPE |
protected String |
serviceTCCL |
Constructor and Description |
---|
AbstractMessageReceiver() |
Modifier and Type | Method and Description |
---|---|
org.apache.axiom.soap.SOAPFactory |
getSOAPFactory(MessageContext msgContext) |
protected Object |
getTheImplementationObject(MessageContext msgContext)
Retrieve the implementation object.
|
protected abstract void |
invokeBusinessLogic(MessageContext messageCtx)
Do the actual work of the MessageReceiver.
|
protected Object |
makeNewServiceObject(MessageContext msgContext)
Create a new service object.
|
void |
receive(MessageContext messageCtx) |
protected void |
replicateState(MessageContext messageContext) |
protected void |
restoreThreadContext(AbstractMessageReceiver.ThreadContextDescriptor tc) |
protected AbstractMessageReceiver.ThreadContextDescriptor |
setThreadContext(MessageContext msgContext)
Several pieces of information need to be available to the service
implementation class.
|
protected static final org.apache.commons.logging.Log log
public static final String SCOPE
protected String serviceTCCL
public static final String SAVED_TCCL
public static final String SAVED_MC
public static final String DO_ASYNC
protected void replicateState(MessageContext messageContext) throws ClusteringFault
ClusteringFault
protected abstract void invokeBusinessLogic(MessageContext messageCtx) throws AxisFault
messageCtx
- active MessageContextAxisFault
- if a problem occurredpublic void receive(MessageContext messageCtx) throws AxisFault
receive
in interface MessageReceiver
messageCtx
- active MessageContextAxisFault
- if a problem occurredprotected AbstractMessageReceiver.ThreadContextDescriptor setThreadContext(MessageContext msgContext)
msgContext
- the current MessageContextprotected void restoreThreadContext(AbstractMessageReceiver.ThreadContextDescriptor tc)
protected Object makeNewServiceObject(MessageContext msgContext) throws AxisFault
msgContext
- AxisFault
public org.apache.axiom.soap.SOAPFactory getSOAPFactory(MessageContext msgContext) throws AxisFault
AxisFault
protected Object getTheImplementationObject(MessageContext msgContext) throws AxisFault
msgContext
- the active MessageContextAxisFault
- if there's a problemCopyright © 2004-2013 The Apache Software Foundation. All Rights Reserved.