message: changes per conversation with nikita.  see
diff: @@ -706,6 +706,8 @@ pub mod tests {
  const NODE_3: &'static str = "n3";
  const NODE_4: &'static str = "n4";
  const SIMPLE_REPLY: &'static str = r#"{"result":{}}"#;
  + const REJECT_REPLY: &'static str = r#"{"op":"REJECT"}"#;
  + const NACK_REPLY: &'static str = r#"{"op":"REQNACK"}"#;
  const POOL: &'static str = "pool1";
  #[derive(Debug)]
  @@ -938,8 +940,35 @@ pub mod tests {
  request_handler.process_event(Some(RequestEvent::CustomConsensusRequest(MESSAGE.to_string(), REQ_ID.to_string())));
  request_handler.process_event(Some(RequestEvent::Reply(Reply::default(), SIMPLE_REPLY.to_string(), NODE.to_string(), REQ_ID.to_string())));
  - request_handler.process_event(Some(RequestEvent::Reject(Response::default(), "{}".to_string(), NODE_2.to_string(), REQ_ID.to_string())));
  - request_handler.process_event(Some(RequestEvent::ReqNACK(Response::default(), "{}".to_string(), NODE_3.to_string(), REQ_ID.to_string())));
  + request_handler.process_event(Some(RequestEvent::Reject(Response::default(), REJECT_REPLY.to_string(), NODE_2.to_string(), REQ_ID.to_string())));
  + request_handler.process_event(Some(RequestEvent::ReqNACK(Response::default(), NACK_REPLY.to_string(), NODE_3.to_string(), REQ_ID.to_string())));
  +
  + // test state is already Finished because already have 2 nodes not in consensus
  + {
  + let request_handler_ref = request_handler.request_wrapper.as_ref().unwrap();
  + assert_match!(RequestState::Finish(_), request_handler_ref.state);
  + }
  +
  + // send one more message to ensure state isn't affected
  + request_handler.process_event(Some(RequestEvent::Reject(Response::default(), "{}".to_string(), NODE_4.to_string(), REQ_ID.to_string())));
  +
  + assert_match!(RequestState::Finish(_), request_handler.request_wrapper.unwrap().state);
  +
  + }
  +
  + // this test is marked ignore until https://jira.hyperledger.org/browse/IS-1137 is resolved
  + #[test]
  + #[ignore]
  + fn request_handler_process_reply_event_from_consensus_state_works_for_consensus_reached_with_0_concensus() {
  +
  + // the test will use 4 nodes, each node replying with a response to the "custom consensus request" message
  + // some nodes accept, some reject and some nack. the end result is consensus should not be reached
  + let mut request_handler = _request_handler(0, 4);
  +
  + request_handler.process_event(Some(RequestEvent::CustomConsensusRequest(MESSAGE.to_string(), REQ_ID.to_string())));
  + request_handler.process_event(Some(RequestEvent::Reply(Reply::default(), SIMPLE_REPLY.to_string(), NODE.to_string(), REQ_ID.to_string())));
  + request_handler.process_event(Some(RequestEvent::Reject(Response::default(), "".to_string(), NODE_2.to_string(), REQ_ID.to_string())));
  + request_handler.process_event(Some(RequestEvent::ReqNACK(Response::default(), "".to_string(), NODE_3.to_string(), REQ_ID.to_string())));
  // test state is already Finished because already have 2 nodes not in consensus
  {
  