main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java
/**
         * Queues up the next reply. If there are no more replies, then it queues up a
         * {@link End2EndContext#DONE} message.
         *
         * @param message the message to which a reply should be sent
         */
Queues up the next reply. If there are no more replies, then it queues up a
End2EndContext#DONE message.

@param message the message to which a reply should be sent
Queues up the next reply . If there are no more replies then it queues up a End2EndContext#DONE message . @param message the message to which a reply should be sent
private void reply(PdpMessage message) {
            PdpStatus status = replies.poll();
            if (status == null) {
                return;
            }
            PdpResponseDetails response = new PdpResponseDetails();
            response.setResponseTo(message.getRequestId());
            status.setResponse(response);
            toPap.add(toJson(status));
            if (replies.isEmpty()) {
                finished = true;
                toPap.add(DONE);
            }
        }
private void reply ( PdpMessage message ) { PdpStatus status = replies . poll ( ) ; if ( status == null ) { return ; } PdpResponseDetails response = new PdpResponseDetails ( ) ; response . setResponseTo ( message . getRequestId ( ) ) ; status . setResponse ( response ) ; toPap . add ( toJson ( status ) ) ; if ( replies . isEmpty ( ) ) { finished = true ; toPap . add ( DONE ) ; } }
Queues up the next reply.
Queues up the next reply .