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, setBeforepublic 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 nullpublic 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