List of submitResponse() Examples

Examples of submitResponse()

org.apache.http.nio.NHttpServerConnection.submitResponse()
Submits the HTTP response to the client. @param response HTTP response @throws IOException if I/O error occurs while submitting the response @throws HttpException if the HTTP response violates the HTTP protocol.
org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()
Submits the default HTTP response and completed the message exchange. If the response encloses an {@link org.apache.http.HttpEntity} instancethe entity is also expected to implement the {@link org.apache.http.nio.entity.HttpAsyncContentProducer }interface for efficient content streaming to a non-blocking HTTP connection. @throws IllegalStateException if a response has already been submitted.
org.apache.http.nio.protocol.HttpAsyncResponseTrigger.submitResponse()

Examples of org.apache.http.nio.NHttpServerConnection.submitResponse()

        }


        public Void answer(final InvocationOnMock invocation) throws Throwable {
            final Object[] args = invocation.getArguments();
            final NHttpServerConnection conn = (NHttpServerConnection) args[0];
            conn.submitResponse(response);
            return null;
        }
    }


    static class ProduceContentAnswer implements Answer<Void> {

View Full Code Here

Examples of org.apache.http.nio.NHttpServerConnection.submitResponse()


        @Override
        public Void answer(final InvocationOnMock invocation) throws Throwable {
            final Object[] args = invocation.getArguments();
            final NHttpServerConnection conn = (NHttpServerConnection) args[0];
            conn.submitResponse(response);
            return null;
        }
    }


    static class ProduceContentAnswer implements Answer<Void> {

View Full Code Here

Examples of org.apache.http.nio.NHttpServerConnection.submitResponse()

        }


        public Void answer(final InvocationOnMock invocation) throws Throwable {
            final Object[] args = invocation.getArguments();
            final NHttpServerConnection conn = (NHttpServerConnection) args[0];
            conn.submitResponse(response);
            return null;
        }
    };


    static class ProduceContentAnswer implements Answer<Void> {

View Full Code Here

Examples of org.apache.http.nio.NHttpServerConnection.submitResponse()

        }


        public Void answer(final InvocationOnMock invocation) throws Throwable {
            final Object[] args = invocation.getArguments();
            final NHttpServerConnection conn = (NHttpServerConnection) args[0];
            conn.submitResponse(response);
            return null;
        }
    }


    static class ProduceContentAnswer implements Answer<Void> {

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                System.out.println("[proxy<-origin] " + this.httpExchange.getId() + " " + response.getStatusLine());
                this.httpExchange.setResponse(response);
                HttpAsyncExchange responseTrigger = this.httpExchange.getResponseTrigger();
                if (responseTrigger != null && !responseTrigger.isCompleted()) {
                    System.out.println("[client<-proxy] " + this.httpExchange.getId() + " response triggered");
                    responseTrigger.submitResponse(new ProxyResponseProducer(this.httpExchange));
                }
            }
        }


        public void consumeContent(

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                    String message = ex.getMessage();
                    if (message == null) {
                        message = "Unexpected error";
                    }
                    response.setEntity(NStringEntity.create(message, ContentType.DEFAULT_TEXT));
                    responseTrigger.submitResponse(new BasicAsyncResponseProducer(response));
                }
            }
        }


        public boolean cancel() {

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                System.out.println("[proxy<-origin] " + this.httpExchange.getId() + " " + response.getStatusLine());
                this.httpExchange.setResponse(response);
                HttpAsyncExchange responseTrigger = this.httpExchange.getResponseTrigger();
                if (responseTrigger != null && !responseTrigger.isCompleted()) {
                    System.out.println("[client<-proxy] " + this.httpExchange.getId() + " response triggered");
                    responseTrigger.submitResponse(new ProxyResponseProducer(this.httpExchange));
                }
            }
        }


        public void consumeContent(

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                    String message = ex.getMessage();
                    if (message == null) {
                        message = "Unexpected error";
                    }
                    response.setEntity(new NStringEntity(message, ContentType.DEFAULT_TEXT));
                    responseTrigger.submitResponse(new BasicAsyncResponseProducer(response));
                }
            }
        }


        public boolean cancel() {

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                System.out.println("[proxy<-origin] " + this.httpExchange.getId() + " " + response.getStatusLine());
                this.httpExchange.setResponse(response);
                HttpAsyncExchange responseTrigger = this.httpExchange.getResponseTrigger();
                if (responseTrigger != null && !responseTrigger.isCompleted()) {
                    System.out.println("[client<-proxy] " + this.httpExchange.getId() + " response triggered");
                    responseTrigger.submitResponse(new ProxyResponseProducer(this.httpExchange));
                }
            }
        }


        public void consumeContent(

View Full Code Here

Examples of org.apache.http.nio.protocol.HttpAsyncExchange.submitResponse()

                    String message = ex.getMessage();
                    if (message == null) {
                        message = "Unexpected error";
                    }
                    response.setEntity(new NStringEntity(message, ContentType.DEFAULT_TEXT));
                    responseTrigger.submitResponse(new BasicAsyncResponseProducer(response));
                }
            }
        }


        public boolean cancel() {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.