public class MAPAggregator extends AbstractPhaseInterceptor<Message>
Modifier and Type | Class and Description |
---|---|
protected static class |
MAPAggregator.InterposedMessageObserver |
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_VERIFIED |
static String |
ADDRESSING_DISABLED |
static String |
DECOUPLED_DESTINATION |
static String |
USING_ADDRESSING |
Constructor and Description |
---|
MAPAggregator()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
allowDuplicates()
Indicates if duplicate messageIDs are allowed.
|
protected String |
getActionUri(Message message,
boolean checkMessage) |
MessageIdCache |
getMessageIdCache()
Returns the cache used to enforce duplicate message IDs when
allowDuplicates() returns false . |
void |
handleFault(Message message)
Invoked when unwinding normal interceptor chain when a fault occurred.
|
void |
handleMessage(Message message)
Invoked for normal processing of inbound and outbound messages.
|
boolean |
isAddressingRequired()
Whether the use of addressing is completely required for this endpoint
|
boolean |
isUsingAddressingAdvisory()
Whether the presence of the
|
protected boolean |
mediate(Message message,
boolean isFault)
Mediate message flow.
|
void |
setAddressingRequired(boolean required)
Sets whether the use of addressing is completely required for this endpoint
|
void |
setAddressingResponses(String responses)
Sets Addresing Response
|
void |
setAllowDuplicates(boolean ad)
Allows/disallows duplicate messageIdDs.
|
void |
setMessageIdCache(MessageIdCache messageIdCache)
Sets the cache used to enforce duplicate message IDs when
allowDuplicates() returns false . |
void |
setUsingAddressingAdvisory(boolean advisory)
Controls whether the presence of the
|
addAfter, addAfter, addBefore, addBefore, getAdditionalInterceptors, getAfter, getBefore, getId, getPhase, isGET, isRequestor, setAfter, setBefore
public static final String USING_ADDRESSING
public static final String ADDRESSING_DISABLED
public static final String DECOUPLED_DESTINATION
public static final String ACTION_VERIFIED
public boolean allowDuplicates()
public void setAllowDuplicates(boolean ad)
ad
- whether duplicate messageIDs are allowedpublic boolean isUsingAddressingAdvisory()
public void setUsingAddressingAdvisory(boolean advisory)
advisory
- true if the presence of the public boolean isAddressingRequired()
public void setAddressingRequired(boolean required)
public void setAddressingResponses(String responses)
public MessageIdCache getMessageIdCache()
allowDuplicates()
returns false
.public void setMessageIdCache(MessageIdCache messageIdCache)
allowDuplicates()
returns false
.messageIdCache
- the cache to useNullPointerException
- if messageIdCache
is null
public void handleMessage(Message message)
message
- the current messagepublic void handleFault(Message message)
handleFault
in interface Interceptor<Message>
handleFault
in class AbstractPhaseInterceptor<Message>
message
- the current messageprotected boolean mediate(Message message, boolean isFault)
message
- the current messageisFault
- true if a fault is being mediatedApache CXF