public class MAPAggregator extends AbstractPhaseInterceptor<Message>
Modifier and Type | Class and Description |
---|---|
static interface |
MAPAggregator.MAPAggregatorLoader |
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_VERIFIED |
static String |
ADDRESSING_DISABLED |
protected boolean |
addressingRequired |
protected WSAddressingFeature.AddressingResponses |
addressingResponses |
protected boolean |
allowDuplicates |
static String |
DECOUPLED_DESTINATION |
protected MessageIdCache |
messageIdCache |
static String |
USING_ADDRESSING |
protected boolean |
usingAddressingAdvisory |
Constructor and Description |
---|
MAPAggregator()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
allowDuplicates()
Indicates if duplicate messageIDs are allowed.
|
Collection<PhaseInterceptor<? extends Message>> |
getAdditionalInterceptors()
Returns a collection of Interceptors that should be added to the chain
whenever this interceptor is added.
|
WSAddressingFeature.AddressingResponses |
getAddressingResponses()
Sets Addressing Response
|
MessageIdCache |
getMessageIdCache()
Returns the cache used to enforce duplicate message IDs when
allowDuplicates() returns false . |
void |
handleFault(Message message)
Called for all interceptors (in reverse order) on which handleMessage
had been successfully invoked, when normal execution of the chain was
aborted for some reason.
|
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
|
void |
setAddressingRequired(boolean required)
Sets whether the use of addressing is completely required for this endpoint
|
void |
setAddressingResponses(WSAddressingFeature.AddressingResponses 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
|
public static final String USING_ADDRESSING
public static final String ADDRESSING_DISABLED
public static final String DECOUPLED_DESTINATION
public static final String ACTION_VERIFIED
protected MessageIdCache messageIdCache
protected boolean usingAddressingAdvisory
protected boolean addressingRequired
protected boolean allowDuplicates
protected WSAddressingFeature.AddressingResponses addressingResponses
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(WSAddressingFeature.AddressingResponses 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 WSAddressingFeature.AddressingResponses getAddressingResponses()
public void handleMessage(Message message)
message
- the current messagepublic void handleFault(Message message)
Interceptor
handleFault
in interface Interceptor<Message>
handleFault
in class AbstractPhaseInterceptor<Message>
public Collection<PhaseInterceptor<? extends Message>> getAdditionalInterceptors()
PhaseInterceptor
getAdditionalInterceptors
in interface PhaseInterceptor<Message>
getAdditionalInterceptors
in class AbstractPhaseInterceptor<Message>
Apache CXF