@Test public void testProcessPPSAck() throws Exception{ IncomingMessageHandler handler = sfrmProcessor.getIncomingMessageHandler(); SFRMMessageDVO mDVO = SFRMProcessor.getInstance().getMessageHandler().retrieveMessage("testProcessPPSAck", SFRMConstant.MSGBOX_IN); String responseContent = handler.processPPSAck(mDVO); SFRMAcknowledgementParser responseParser = new SFRMAcknowledgementParser(responseContent); SFRMMessageDAO dao = (SFRMMessageDAO) sfrmProcessor.getDAOFactory().createDAO(SFRMMessageDAO.class); SFRMMessageDVO dvo = (SFRMMessageDVO) dao.createDVO(); dvo.setMessageId(getName()); dvo.setMessageBox(SFRMConstant.MSGBOX_IN); assertTrue("Message ID 'testProcessPPSAck' should not be deleted", dao.retrieve(dvo)); assertEquals("Message status should changed to PS", SFRMConstant.MSGS_PROCESSED, dvo.getStatus()); assertNotNull("Message Completed timestamp should not be null", dvo.getCompletedTimestamp()); assertEquals("Message status in response ack should be PS", SFRMConstant.MSGS_PROCESSED, responseParser.getMessageStatus(getName())); }
public String processPPSAck(SFRMMessageDVO mDVO) throws DAOException{ getLogger().debug("Message PPS Ack received"); return changeAckStaus(mDVO, SFRMConstant.MSGS_PROCESSED); }
IncomingMessageHandler extends SFRMComponent { public String processPPSAck(SFRMMessageDVO mDVO) throws DAOException{ getLogger().debug("Message PPS Ack received"); return changeAckStaus(mDVO, SFRMConstant.MSGS_PROCESSED); } }
IncomingMessageHandler extends SFRMComponent { public String processPPSAck(SFRMMessageDVO mDVO) throws DAOException{ getLogger().debug("Message PPS Ack received"); return changeAckStaus(mDVO, SFRMConstant.MSGS_PROCESSED); }  }
IncomingMessageHandler extends SFRMComponent { public String processPPSAck(SFRMMessageDVO mDVO) throws DAOException{ getLogger().debug("Message PPS Ack received"); return changeAckStaus(mDVO, SFRMConstant.MSGS_PROCESSED); }  static IncomingMessageHandler getInstance(); SFRMPartnershipDVO extractPartnership(SFRMMessage incomingMessage); boolean isDuplicateSegment(SFRMMessage incomingMessage); boolean isProcessingMessage(SFRMMessage incomingMessage); boolean isNotEnoughRoom(SFRMMessage incomingMessage, long threshold); void unpackIncomingMessage(SFRMMessage message, SFRMPartnershipDVO partnershipDVO); boolean initGuardForSegment(final SFRMMessage incomingMessage); boolean resolveGuardOwnerForSegment(final SFRMMessage incomingMessage); boolean releaseGuardForSegment(final SFRMMessage incomingMessage); SFRMMessage processIncomingMessage(SFRMMessage incomingMessage, final Object[] params); SFRMMessage processHandshakingMessage(
			SFRMMessage 		rawMessage,
			final Object[] 		params); SFRMMessage processMetaMessage(
			SFRMMessage 		inputMessage,
			SFRMPartnershipDVO 	partnershipDVO, 
			final Object[] 		params); SFRMMessage processSegmentMessage(SFRMMessage rawMessage, final Object[] params); SFRMMessage processAcknowledgement(SFRMMessage msg, SFRMPartnershipDVO pDVO); String processPRAck(SFRMMessageDVO mDVO, SFRMAcknowledgementParser parser); String processPDFAck(SFRMMessageDVO mDVO); String processPPSAck(SFRMMessageDVO mDVO); String processPSDAck(SFRMMessageDVO mDVO); String processPRSAck(SFRMMessageDVO mDVO); }
IncomingMessageHandler extends SFRMComponent { public String processPPSAck(SFRMMessageDVO mDVO) throws DAOException{ getLogger().debug("Message PPS Ack received"); return changeAckStaus(mDVO, SFRMConstant.MSGS_PROCESSED); }  static IncomingMessageHandler getInstance(); SFRMPartnershipDVO extractPartnership(SFRMMessage incomingMessage); boolean isDuplicateSegment(SFRMMessage incomingMessage); boolean isProcessingMessage(SFRMMessage incomingMessage); boolean isNotEnoughRoom(SFRMMessage incomingMessage, long threshold); void unpackIncomingMessage(SFRMMessage message, SFRMPartnershipDVO partnershipDVO); boolean initGuardForSegment(final SFRMMessage incomingMessage); boolean resolveGuardOwnerForSegment(final SFRMMessage incomingMessage); boolean releaseGuardForSegment(final SFRMMessage incomingMessage); SFRMMessage processIncomingMessage(SFRMMessage incomingMessage, final Object[] params); SFRMMessage processHandshakingMessage(
			SFRMMessage 		rawMessage,
			final Object[] 		params); SFRMMessage processMetaMessage(
			SFRMMessage 		inputMessage,
			SFRMPartnershipDVO 	partnershipDVO, 
			final Object[] 		params); SFRMMessage processSegmentMessage(SFRMMessage rawMessage, final Object[] params); SFRMMessage processAcknowledgement(SFRMMessage msg, SFRMPartnershipDVO pDVO); String processPRAck(SFRMMessageDVO mDVO, SFRMAcknowledgementParser parser); String processPDFAck(SFRMMessageDVO mDVO); String processPPSAck(SFRMMessageDVO mDVO); String processPSDAck(SFRMMessageDVO mDVO); String processPRSAck(SFRMMessageDVO mDVO);  }