|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sandesha2.util.FaultManager
public class FaultManager
Has logic to check for possible RM related faults and create it.
Constructor Summary | |
---|---|
FaultManager()
|
Method Summary | |
---|---|
static boolean |
checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext,
SequenceAcknowledgement sequenceAcknowledgement,
StorageManager storageManager,
RMSBean rmsBean,
boolean piggybackedMessage)
Check weather the Acknowledgement is invalid and generate a fault if it is. |
static void |
checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage,
StorageManager storageManager)
Check weather the LastMessage number has been exceeded and generate the fault if it is. |
static RMMsgContext |
checkForMessageNumberRoleover(org.apache.axis2.context.MessageContext messageContext)
|
static boolean |
checkForMessageRolledOver(RMMsgContext rmMessageContext,
java.lang.String sequenceId,
long msgNo)
Checks to see if the message number received is == to the Long.MAX_VALUE Throws and AxisFault, or sends a Fault message if the condition is met. |
static boolean |
checkForSequenceClosed(RMMsgContext referenceRMMessage,
java.lang.String sequenceID,
RMDBean rmdBean,
boolean piggybackedMessage)
|
static boolean |
checkForSequenceTerminated(RMMsgContext referenceRMMessage,
java.lang.String sequenceID,
RMSequenceBean bean,
boolean piggybackedMessage)
Checks if a sequence is terminated and returns a SequenceTerminated fault. |
static boolean |
checkForUnknownSequence(RMMsgContext rmMessageContext,
java.lang.String sequenceID,
StorageManager storageManager,
boolean piggybackedMessage)
Check whether a Sequence message (a) belongs to a unknown sequence (generates an UnknownSequence fault) (b) message number exceeds a predifined limit ( genenrates a Message Number Rollover fault) |
static void |
getOrSendFault(RMMsgContext referenceRMMsgContext,
FaultData data,
boolean throwable)
Adds the necessary Fault elements as properties to the message context. |
static boolean |
isRMFault(java.lang.String faultSubcodeValue)
|
static void |
makeCreateSequenceRefusedFault(RMMsgContext rmMessageContext,
java.lang.String detail,
java.lang.Exception e)
Makes a Create sequence refused fault |
static void |
makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx,
SequenceAcknowledgement sequenceAcknowledgement,
AcknowledgementRange acknowledgementRange,
StorageManager storageManager,
boolean piggybackedMessage)
Makes an InvalidAcknowledgement fault. |
static org.apache.axis2.engine.Handler.InvocationResponse |
processMessagesForFaults(RMMsgContext rmMsgCtx,
StorageManager storageManager)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FaultManager()
Method Detail |
---|
public static void checkForLastMsgNumberExceeded(RMMsgContext applicationRMMessage, StorageManager storageManager) throws org.apache.axis2.AxisFault
msgCtx
-
org.apache.axis2.AxisFault
public static RMMsgContext checkForMessageNumberRoleover(org.apache.axis2.context.MessageContext messageContext)
public static boolean checkForUnknownSequence(RMMsgContext rmMessageContext, java.lang.String sequenceID, StorageManager storageManager, boolean piggybackedMessage) throws org.apache.axis2.AxisFault
msgCtx
-
SandeshaException
org.apache.axis2.AxisFault
public static boolean checkForInvalidAcknowledgement(RMMsgContext ackRMMessageContext, SequenceAcknowledgement sequenceAcknowledgement, StorageManager storageManager, RMSBean rmsBean, boolean piggybackedMessage) throws org.apache.axis2.AxisFault
msgCtx
-
SandeshaException
org.apache.axis2.AxisFault
public static void makeInvalidAcknowledgementFault(RMMsgContext rmMsgCtx, SequenceAcknowledgement sequenceAcknowledgement, AcknowledgementRange acknowledgementRange, StorageManager storageManager, boolean piggybackedMessage) throws org.apache.axis2.AxisFault
rmMsgCtx
- storageManager
- message
-
org.apache.axis2.AxisFault
public static void makeCreateSequenceRefusedFault(RMMsgContext rmMessageContext, java.lang.String detail, java.lang.Exception e) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static boolean checkForSequenceTerminated(RMMsgContext referenceRMMessage, java.lang.String sequenceID, RMSequenceBean bean, boolean piggybackedMessage) throws org.apache.axis2.AxisFault
referenceRMMessage
- sequenceID
- rmdBean
-
org.apache.axis2.AxisFault
public static boolean checkForSequenceClosed(RMMsgContext referenceRMMessage, java.lang.String sequenceID, RMDBean rmdBean, boolean piggybackedMessage) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void getOrSendFault(RMMsgContext referenceRMMsgContext, FaultData data, boolean throwable) throws org.apache.axis2.AxisFault
referenceRMMsgContext
- - Message in reference to which the fault will be generated.data
- - data for the faultthrowable
- - This tells weather or not it is ok to throw the fault out. I.e. this should not be done when processing
piggybacked acks since this will stop the carrier message from being processed.
org.apache.axis2.AxisFault
public static boolean isRMFault(java.lang.String faultSubcodeValue)
public static org.apache.axis2.engine.Handler.InvocationResponse processMessagesForFaults(RMMsgContext rmMsgCtx, StorageManager storageManager) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static boolean checkForMessageRolledOver(RMMsgContext rmMessageContext, java.lang.String sequenceId, long msgNo) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |