Java Code Examples for javax.servlet.ServletOutputStream
The following code examples are extracted from open source projects. You can click 
to
vote up the examples that are useful to you.
Example 1
From project eucalyptus, under directory /clc/modules/www/src/edu/ucsb/eucalyptus/admin/server/.
Source file: Registration.java
@Override protected void doGet(final HttpServletRequest httpServletRequest,final HttpServletResponse httpServletResponse) throws ServletException, IOException {
String uuid=UUID.randomUUID().toString();
String registrationId=getRegistrationId();
ServletOutputStream op=httpServletResponse.getOutputStream();
LOG.info("Using registrationId: " + registrationId);
op.write(getMessage(registrationId,UUID.randomUUID().toString()).getBytes());
op.flush();
}
Example 2
From project Socket.IO-Java, under directory /core/src/main/java/com/glines/socketio/server/transport/.
Source file: HTMLFileTransport.java
protected void startSend(HttpServletResponse response) throws IOException {
response.setContentType("text/html");
response.setHeader("Connection","keep-alive");
response.setHeader("Transfer-Encoding","chunked");
char[] spaces=new char[244];
Arrays.fill(spaces,' ');
ServletOutputStream os=response.getOutputStream();
os.print("<html><body>" + new String(spaces));
response.flushBuffer();
}
Example 3
From project gxa, under directory /atlas-web/src/main/java/uk/ac/ebi/gxa/spring/view/dsv/.
Source file: AbstractDsvView.java
@Override protected void renderMergedOutputModel(Map<String,Object> model,HttpServletRequest request,HttpServletResponse response) throws Exception {
DsvRowIterator<T> doc=buildDsvDocument(model);
response.setHeader("Content-Disposition","attachment;filename=" + generateFileName(request));
ServletOutputStream out=response.getOutputStream();
DsvDocumentWriter writer=new DsvDocumentWriter(getDsvFormat().newWriter(new OutputStreamWriter(out)));
writer.write(doc);
}
Example 4
From project android-joedayz, under directory /Proyectos/spring-rest-cliente/src/main/java/com/mycompany/rest/util/.
Source file: Writer.java
/**
* Writes the report to the output stream
*/
public static void write(HttpServletResponse response,ByteArrayOutputStream bao){
logger.debug("Writing report to the stream");
try {
ServletOutputStream outputStream=response.getOutputStream();
bao.writeTo(outputStream);
outputStream.flush();
outputStream.close();
}
catch ( Exception e) {
logger.error("Unable to write report to the output stream");
}
}
Example 5
From project ANNIS, under directory /annis-gui/src/main/java/annis/gui/servlets/.
Source file: BinaryServlet.java
@Override public void doGet(HttpServletRequest request,HttpServletResponse response) throws ServletException {
Map<String,String[]> binaryParameter=request.getParameterMap();
toplevelCorpusName=binaryParameter.get("toplevelCorpusName")[0];
documentName=binaryParameter.get("documentName")[0];
ServletOutputStream out=null;
try {
out=response.getOutputStream();
String range=request.getHeader("Range");
String annisServiceURL=getServletContext().getInitParameter("AnnisWebService.URL");
if (annisServiceURL == null) {
throw new ServletException("AnnisWebService.URL was not set as init parameter in web.xml");
}
WebResource annisRes=client.resource(annisServiceURL);
WebResource binaryRes=annisRes.path("corpora").path(URLEncoder.encode(toplevelCorpusName,"UTF-8")).path(URLEncoder.encode(documentName,"UTF-8")).path("binary");
if (range != null) {
responseStatus206(binaryRes,out,response,range);
}
else {
responseStatus200(binaryRes,out,response);
}
out.flush();
}
catch ( IOException ex) {
log.debug("IOException in BinaryServlet",ex);
}
catch ( ClientHandlerException ex) {
log.error(null,ex);
response.setStatus(500);
}
catch ( UniformInterfaceException ex) {
log.error(null,ex);
response.setStatus(500);
}
}
Example 6
From project cloudify, under directory /restful/src/main/java/org/cloudifysource/rest/controllers/.
Source file: ServiceController.java
/**
* Exception handler for all of the internal server's exceptions.
* @param response The response object to edit, if not committed yet.
* @param e The exception that occurred, from which data is read for logging and for the response error message.
* @throws IOException Reporting failure to edit the response object
*/
@ExceptionHandler(Exception.class) @ResponseStatus(value=HttpStatus.INTERNAL_SERVER_ERROR) public void resolveDocumentNotFoundException(final HttpServletResponse response,final Exception e) throws IOException {
if (response.isCommitted()) {
logger.log(Level.WARNING,"Caught exception, but response already commited. Not sending error message based on exception",e);
}
else {
final ServletOutputStream outputStream=response.getOutputStream();
final String message="{\"status\":\"error\", \"error\":\"" + e.getMessage() + "\"}";
logger.log(Level.SEVERE,"caught exception. Sending response message " + message,e);
final byte[] messageBytes=message.getBytes();
outputStream.write(messageBytes);
}
}
Example 7
From project codjo-webservices, under directory /codjo-webservices-common/src/main/java/com/tilab/wsig/servlet/.
Source file: WSIGServlet.java
/**
* Fill http response
* @param soapResponse
* @param httpResponse
* @return
*/
private void fillHttpResponse(SOAPMessage soapResponse,HttpServletResponse httpResponse) throws Exception {
byte[] content=null;
ByteArrayOutputStream baos=new ByteArrayOutputStream();
soapResponse.writeTo(baos);
content=baos.toByteArray();
httpResponse.setHeader("Cache-Control","no-store");
httpResponse.setHeader("Pragma","no-cache");
httpResponse.setDateHeader("Expires",0);
httpResponse.setContentType("soap+xml; charset=utf-8");
ServletOutputStream responseOutputStream=httpResponse.getOutputStream();
responseOutputStream.write(content);
responseOutputStream.flush();
responseOutputStream.close();
}
Example 8
From project red5-mavenized, under directory /red5_base/src/main/java/org/red5/server/net/rtmpt/.
Source file: RTMPTServlet.java
/**
* Return raw data to the client.
* @param client RTMP connection
* @param buffer Raw data as byte buffer
* @param resp Servlet response
* @throws IOException I/O exception
*/
protected void returnMessage(RTMPTConnection client,ByteBuffer buffer,HttpServletResponse resp) throws IOException {
resp.setStatus(HttpServletResponse.SC_OK);
resp.setHeader("Connection","Keep-Alive");
resp.setHeader("Cache-Control","no-cache");
resp.setContentType(CONTENT_TYPE);
log.debug("Sending {} bytes",buffer.limit());
resp.setContentLength(buffer.limit() + 1);
ServletOutputStream output=resp.getOutputStream();
output.write(client.getPollingDelay());
ServletUtils.copy(buffer.asInputStream(),output);
buffer.release();
buffer=null;
}
Example 9
From project iJetty, under directory /example-webapps/hello/src/main/java/org/mortbay/ijetty/hello/.
Source file: HelloWorld.java
public void doGet(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {
response.setContentType("text/html");
ServletOutputStream out=response.getOutputStream();
out.println("<html>");
out.println("<h1>Hello From Servlet Land!</h1>");
out.println("Brought to you by: " + proofOfLife);
out.println("</html>");
out.flush();
}
Example 10
From project IPHeatmap, under directory /IPHeatmap/ipheatmap-server/src/main/java/org/trillinux/ipheatmap/server/.
Source file: TileServlet.java
private void createTile(int z,int x,int y,boolean nocache,HttpServletRequest request,HttpServletResponse response) throws IOException {
ServletOutputStream output=response.getOutputStream();
response.setContentType("image/png");
Tile tile=new Tile(ipDir,labelFile,cacheDir);
if (cache && !nocache && tile.tileExists(x,y,z)) {
tile.writeCachedTile(x,y,z,output);
}
else {
tile.generate(x,y,z,output);
}
}
Example 11
From project jbpm-plugin, under directory /jbpm/src/main/java/hudson/jbpm/model/.
Source file: ProcessInstanceAction.java
public void doImage(StaplerRequest req,StaplerResponse rsp) throws IOException, XPathExpressionException, DocumentException {
ProcessInstance processInstance=getProcessInstance();
GPD gpd=getGPD();
ServletOutputStream output=rsp.getOutputStream();
ProcessInstanceRenderer panel=new ProcessInstanceRenderer(processInstance,gpd);
BufferedImage aimg=new BufferedImage(panel.getWidth(),panel.getHeight(),BufferedImage.TYPE_INT_RGB);
Graphics2D g=aimg.createGraphics();
panel.paint(g);
g.dispose();
ImageIO.write(aimg,"png",output);
output.flush();
output.close();
}
Example 12
From project jena-fuseki, under directory /src/main/java/org/apache/jena/fuseki/servlets/.
Source file: ResponseResultSet.java
private static void output(String contentType,String charset,OutputContent proc,HttpServletRequest httpRequest,HttpServletResponse httpResponse){
try {
setHttpResponse(httpRequest,httpResponse,contentType,charset);
httpResponse.setStatus(HttpSC.OK_200);
ServletOutputStream out=httpResponse.getOutputStream();
proc.output(out);
out.flush();
httpResponse.flushBuffer();
}
catch ( IOException ex) {
SPARQL_ServletBase.errorOccurred(ex);
}
}
Example 13
From project jetty-project, under directory /jetty-reverse-http/reverse-http-gateway/src/main/java/org/mortbay/jetty/rhttp/gateway/.
Source file: ConnectorServlet.java
private void flush(ClientDelegate client,HttpServletRequest httpRequest,HttpServletResponse httpResponse) throws IOException {
List<RHTTPRequest> requests=client.process(httpRequest);
if (requests != null) {
if (!client.isClosed()) schedule(client);
ServletOutputStream output=httpResponse.getOutputStream();
for ( RHTTPRequest request : requests) output.write(request.getFrameBytes());
output.flush();
logger.debug("Delivered to device {} requests {} ",client.getTargetId(),requests);
}
}
Example 14
From project ned, under directory /NEDAdminConsole/src/org/ned/server/nedadminconsole/server/.
Source file: NedStatisticsFileServlet.java
private void processRequest(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {
ServletOutputStream outputStream=response.getOutputStream();
ServletContext context=getServletConfig().getServletContext();
String mimetype=context.getMimeType(filename);
PrintWriter writer=new PrintWriter(outputStream);
response.setContentType((mimetype != null) ? mimetype : "application/octet-stream");
response.setHeader("Content-Disposition","attachment; filename=\"" + filename + "\"");
writeStatistics(writer);
writer.close();
outputStream.flush();
outputStream.close();
}
Example 15
From project netnumeri, under directory /src/com/netnumeri/server/servlets/.
Source file: QuotesServlet.java
private void export(HttpServletRequest request,HttpServletResponse response) throws IOException {
String ticker=request.getParameter("name");
Calendar cal=Calendar.getInstance();
cal.add(Calendar.YEAR,-1);
String s=null;
try {
s=YahooUtils.proxyYahooData(ticker,cal.getTime(),new Date());
}
catch ( Exception e) {
}
ServletOutputStream sos=response.getOutputStream();
sos.print(s);
}
Example 16
From project ning-service-skeleton, under directory /utils/src/main/java/com/ning/jetty/utils/filters/.
Source file: PeepingTomResponseWrapper.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (stream == null) {
try {
final ServletOutputStream originalOutputStream=super.getOutputStream();
stream=new OpenableServletOutputStream(originalOutputStream);
}
catch ( IllegalStateException e) {
final PrintWriter originalWriter=super.getWriter();
stream=new OpenableServletOutputStream(originalWriter);
}
}
return stream;
}
Example 17
From project Pitbull, under directory /pitbull-servlet/src/test/java/org/jboss/pitbull/test/.
Source file: BasicTest.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
resp.setContentType("text/plain");
resp.setStatus(200);
ServletOutputStream os=resp.getOutputStream();
os.write("1st Chunk ".getBytes());
os.flush();
os.write("2nd chunk".getBytes());
}
Example 18
From project proxy-servlet, under directory /src/test/java/com/woonoz/proxy/servlet/.
Source file: HttpGetRequestHandlerTest.java
@Test @Ignore public void testGet() throws IOException {
URL targetServer=new URL("http://www.google.com/");
HttpServletRequest request=EasyMock.createMock(HttpServletRequest.class);
HttpServletResponse response=EasyMock.createControl().createMock(HttpServletResponse.class);
HttpClient client=EasyMock.createMock(HttpClient.class);
ServletOutputStream servletOutputStream=EasyMock.createMock(ServletOutputStream.class);
EasyMock.expect(response.getOutputStream()).andReturn(servletOutputStream).anyTimes();
EasyMock.replay(response);
HttpGetRequestHandler httpGetRequestHandler=new HttpGetRequestHandler(request,response,targetServer,client);
httpGetRequestHandler.execute();
EasyMock.verify(response);
}
Example 19
From project Red5, under directory /src/org/red5/server/net/rtmpt/.
Source file: RTMPTServlet.java
/**
* Return raw data to the client.
* @param client RTMP connection
* @param buffer Raw data as byte buffer
* @param resp Servlet response
* @throws IOException I/O exception
*/
protected void returnMessage(RTMPTConnection client,IoBuffer buffer,HttpServletResponse resp) throws IOException {
log.debug("returnMessage {}",buffer);
resp.setStatus(HttpServletResponse.SC_OK);
resp.setHeader("Connection","Keep-Alive");
resp.setHeader("Cache-Control","no-cache");
resp.setContentType(CONTENT_TYPE);
log.debug("Sending {} bytes",buffer.limit());
resp.setContentLength(buffer.limit() + 1);
ServletOutputStream output=resp.getOutputStream();
output.write(client.getPollingDelay());
ServletUtils.copy(buffer.asInputStream(),output);
buffer.free();
buffer=null;
}
Example 20
From project red5-server, under directory /src/org/red5/server/net/rtmpt/.
Source file: RTMPTServlet.java
/**
* Return raw data to the client.
* @param client RTMP connection
* @param buffer Raw data as byte buffer
* @param resp Servlet response
* @throws IOException I/O exception
*/
protected void returnMessage(RTMPTConnection client,IoBuffer buffer,HttpServletResponse resp) throws IOException {
log.debug("returnMessage {}",buffer);
resp.setStatus(HttpServletResponse.SC_OK);
resp.setHeader("Connection","Keep-Alive");
resp.setHeader("Cache-Control","no-cache");
resp.setContentType(CONTENT_TYPE);
log.debug("Sending {} bytes",buffer.limit());
resp.setContentLength(buffer.limit() + 1);
ServletOutputStream output=resp.getOutputStream();
output.write(client.getPollingDelay());
ServletUtils.copy(buffer.asInputStream(),output);
buffer.free();
buffer=null;
}
Example 21
From project repose, under directory /project-set/commons/utilities/src/test/java/com/rackspace/papi/commons/util/servlet/http/.
Source file: MutableHttpServletResponseTest.java
@Test public void shouldWriteResponseMessageBody() throws IOException {
String responseBody="<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>" + "<versions xmlns:ns2=\"http://www.w3.org/2005/Atom\" xmlns=\"http://docs.openstack.org/common/api/v1.0\" xmlns:ns3=\"http://docs.rackspacecloud.com/repose/versioning/v1.0\">" + "<version xsi:type=\"ns3:ServiceVersionMapping\" pp-host-id=\"service-v1\" name=\"Service Version 1\" status=\"DEPRECATED\" id=\"v1\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">"+ "<ns2:link href=\"http://localhost:65000/v1/\" rel=\"self\"/>"+ "</version>"+ "<version xsi:type=\"ns3:ServiceVersionMapping\" pp-host-id=\"service-v2\" name=\"Service Version 2\" status=\"CURRENT\" id=\"v2\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">"+ "<ns2:link href=\"http://localhost:65000/v2/\" rel=\"self\"/>"+ "</version>"+ "</versions>";
HttpServletResponse original=mock(HttpServletResponse.class);
ByteBuffer byteBuffer=new CyclicByteBuffer();
ServletOutputStream outputStream=new ByteBufferServletOutputStream(byteBuffer);
when(original.getOutputStream()).thenReturn(outputStream);
MutableHttpServletResponse response=MutableHttpServletResponse.wrap(mock(HttpServletRequest.class),original);
response.getWriter().write(responseBody);
response.flushBuffer();
InputStream inputStream=response.getBufferedOutputAsInputStream();
InputStreamReader reader=new InputStreamReader(inputStream);
BufferedReader bufReader=new BufferedReader(reader);
assertNotNull(bufReader.readLine());
}
Example 22
From project reverse-proxy, under directory /project/src/main/java/com/tek271/reverseProxy/servlet/.
Source file: ContentUtils.java
public static void copyBinary(HttpEntity entity,ServletResponse response){
try {
InputStream content=entity.getContent();
ServletOutputStream outputStream=response.getOutputStream();
IOUtils.copy(content,outputStream);
}
catch ( IOException e) {
Throwables.propagate(e);
}
}
Example 23
From project spring-security, under directory /web/src/test/java/org/springframework/security/web/context/.
Source file: HttpSessionSecurityContextRepositoryTests.java
@Test public void outputStreamCloseDelegate() throws Exception {
HttpSessionSecurityContextRepository repo=new HttpSessionSecurityContextRepository();
repo.setSpringSecurityContextKey("imTheContext");
MockHttpServletRequest request=new MockHttpServletRequest();
HttpServletResponse response=mock(HttpServletResponse.class);
ServletOutputStream outputstream=mock(ServletOutputStream.class);
when(response.getOutputStream()).thenReturn(outputstream);
HttpRequestResponseHolder holder=new HttpRequestResponseHolder(request,response);
SecurityContextHolder.setContext(repo.loadContext(holder));
SecurityContextHolder.getContext().setAuthentication(testToken);
holder.getResponse().getOutputStream().close();
verify(outputstream).close();
}
Example 24
From project tiles-request, under directory /tiles-request-portlet/src/test/java/org/apache/tiles/request/portlet/.
Source file: PortletRequestTest.java
/**
* Test method for {@link org.apache.tiles.request.portlet.PortletRequest#getOutputStream()}.
* @throws IOException If something goes wrong.
*/
@Test public void testGetOutputStream() throws IOException {
ServletOutputStream os=createMock(ServletOutputStream.class);
expect(responseDelegate.getOutputStream()).andReturn(os);
replay(applicationContext,request,response,os,portletContext,requestDelegate,responseDelegate);
assertEquals(req.getOutputStream(),os);
verify(applicationContext,request,response,os,portletContext,requestDelegate,responseDelegate);
}
Example 25
From project tocollege.net, under directory /src/main/java/com/apress/progwt/server/util/.
Source file: GearsManifestFilter.java
public void doFilter(ServletRequest servletRequest,ServletResponse servletResponse,FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest request=((HttpServletRequest)servletRequest);
String userAgentString=request.getHeader("user-agent");
System.out.println("UserAgent: " + userAgentString);
String userAgent=getUserAgent(userAgentString);
ServletOutputStream out=servletResponse.getOutputStream();
HttpServletResponse response=(HttpServletResponse)servletResponse;
response.setContentType("application/jsonrequest");
out.println((String)_manifestMap.get(userAgent));
}
Example 26
From project Weave, under directory /WeaveServices/src/weave/servlets/.
Source file: GenericServlet.java
private void sendError(HttpServletResponse response,Throwable exception,String moreInfo) throws IOException {
String message=exception.getMessage();
if (moreInfo != null) message+="\n" + moreInfo;
System.out.println("Serializing ErrorMessage: " + message);
ServletOutputStream servletOutputStream=response.getOutputStream();
ErrorMessage errorMessage=new ErrorMessage(new MessageException(message));
errorMessage.faultCode=exception.getClass().getSimpleName();
seriaizeCompressedAmf3(errorMessage,servletOutputStream);
}
Example 27
From project winstone, under directory /src/test/winstone/testApplication/servlets/.
Source file: CountRequestsServlet.java
/**
* Get implementation - increments and shows the access count
*/
protected void doGet(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {
numberOfGets++;
ServletOutputStream out=response.getOutputStream();
out.println("<html><body>This servlet has been accessed via GET " + numberOfGets + " times</body></html>");
out.flush();
}
Example 28
From project aether-core, under directory /aether-connector-asynchttpclient/src/test/java/org/eclipse/aether/connector/async/.
Source file: Generate.java
public boolean execute(HttpServletRequest request,HttpServletResponse response,Map<Object,Object> ctx) throws Exception {
if ("GET".equals(request.getMethod())) {
String path=request.getPathInfo();
Long length=lengths.get(path);
if (length != null) {
response.setContentType("application/octet-stream");
response.setContentLength(length.intValue());
ServletOutputStream out=response.getOutputStream();
for (int i=length.intValue(); i > 0; ) {
int n=Math.min(i,bytes.length);
i-=n;
out.write(bytes,0,n);
}
out.close();
return false;
}
}
return true;
}
Example 29
From project agileBase, under directory /gtpb_server/src/com/gtwm/pb/servlets/.
Source file: ReportDownloader.java
private void serveTemplate(HttpServletRequest request,HttpServletResponse response,BaseReportInfo report,String templateName) throws ServletException {
String rinsedTemplateName=templateName.replaceAll("\\..*$","").replaceAll("\\W","") + ".vm";
try {
AuthManagerInfo authManager=this.databaseDefn.getAuthManager();
if (!authManager.getAuthenticator().loggedInUserAllowedTo(request,PrivilegeType.MANAGE_TABLE,report.getParentTable())) {
throw new DisallowedException(authManager.getLoggedInUser(request),PrivilegeType.MANAGE_TABLE,report.getParentTable());
}
CompanyInfo company=this.databaseDefn.getAuthManager().getCompanyForLoggedInUser(request);
String pathString=this.databaseDefn.getDataManagement().getWebAppRoot() + "WEB-INF/templates/uploads/" + company.getInternalCompanyName()+ "/"+ report.getInternalReportName()+ "/"+ rinsedTemplateName;
FileReader fr=new FileReader(pathString);
BufferedReader br=new BufferedReader(fr);
List<String> lines=new LinkedList<String>();
String s;
while ((s=br.readLine()) != null) {
lines.add(s);
}
fr.close();
response.setHeader("Content-disposition","attachment; filename=" + rinsedTemplateName);
response.setHeader("Cache-Control","no-cache");
response.setContentType("text/html");
ServletOutputStream sos=response.getOutputStream();
for ( String line : lines) {
sos.println(line);
}
sos.flush();
}
catch ( AgileBaseException abex) {
logger.error("Problem serving template: " + abex);
throw new ServletException("Problem serving template: " + abex);
}
catch ( IOException ioex) {
logger.error("Problem serving template: " + ioex);
throw new ServletException("Problem serving template: " + ioex);
}
}
Example 30
From project airlift, under directory /rack/src/test/java/io/airlift/rack/.
Source file: TestRackServlet.java
private String performRequest(String queryString,String path,final String postBody,String method) throws IOException, ServletException {
HttpServletRequest request=mock(HttpServletRequest.class);
when(request.getInputStream()).thenReturn(new ServletInputStream(){
int index=0;
@Override public int read() throws IOException {
if (index < postBody.length()) return postBody.charAt(index++);
return -1;
}
@Override public void reset(){
index=0;
}
}
);
when(request.getScheme()).thenReturn("http");
when(request.getMethod()).thenReturn(method);
when(request.getRequestURI()).thenReturn(path);
when(request.getQueryString()).thenReturn(queryString);
when(request.getServerName()).thenReturn("TestServer");
when(request.getServerPort()).thenReturn(new Random().nextInt());
when(request.getHeaderNames()).thenReturn(Collections.enumeration(ImmutableList.<String>of()));
final StringBuilder outputBuilder=new StringBuilder();
ServletOutputStream outputStream=new ServletOutputStream(){
@Override public void write( int i) throws IOException {
outputBuilder.append(new String(new int[]{i},0,1));
}
}
;
HttpServletResponse response=mock(HttpServletResponse.class);
when(response.getOutputStream()).thenReturn(outputStream);
servlet.service(request,response);
return outputBuilder.toString();
}
Example 31
From project aws-tvm-anonymous, under directory /src/com/amazonaws/tvm/.
Source file: RootServlet.java
public static void sendErrorResponse(int httpResponseCode,HttpServletResponse response) throws Exception {
ServletOutputStream out=null;
try {
response.setStatus(httpResponseCode);
response.setContentType("text/plain; charset=UTF-8");
response.setDateHeader("Expires",System.currentTimeMillis());
out=response.getOutputStream();
out.println(Constants.getMsg(httpResponseCode) + "");
}
finally {
if (null != out) {
try {
out.flush();
out.close();
}
catch ( IOException e) {
log.warning("Error closing ServletOutputStream");
}
}
}
}
Example 32
From project aws-tvm-identity, under directory /src/com/amazonaws/tvm/.
Source file: RootServlet.java
public static void sendErrorResponse(int httpResponseCode,HttpServletResponse response) throws Exception {
ServletOutputStream out=null;
try {
response.setStatus(httpResponseCode);
response.setContentType("text/plain; charset=UTF-8");
response.setDateHeader("Expires",System.currentTimeMillis());
out=response.getOutputStream();
out.println(Constants.getMsg(httpResponseCode) + "");
}
finally {
if (null != out) {
try {
out.flush();
out.close();
}
catch ( IOException e) {
log.warning("Error closing ServletOutputStream");
}
}
}
}
Example 33
From project BeeQueue, under directory /src/org/beequeue/buzz/.
Source file: QueryResourceController.java
@Override public boolean process(BuzzContext ctx){
try {
TransactionContext.push();
Coordiantor c=Singletons.getCoordinator();
ServletOutputStream out=ctx.res.getOutputStream();
ctx.res.setContentType("text/plain");
String prefix=ctx.ancestor.toString();
BuzzPath relativePath=ctx.relativePath();
if (prefix.equals("db")) {
out.println(c.selectAnyTable(relativePath.toString()));
}
else {
String queryTemplate=queries.get(ctx.resoursePath.elementAt(0));
HashMap<String,String> context=new HashMap<String,String>();
for (int i=1; i < relativePath.size; i++) {
context.put("v" + i,relativePath.elementAt(i));
}
String q=new GroovyTemplate(queryTemplate).generate(context);
out.println(c.query(q));
}
return ctx.setHandled();
}
catch ( Exception e) {
throw new BuzzException(500,e);
}
finally {
TransactionContext.pop();
}
}
Example 34
From project candlepin, under directory /src/main/java/org/candlepin/servlet/filter/logging/.
Source file: LoggingResponseWrapper.java
public ServletOutputStream getOutputStream() throws java.io.IOException {
if (outputStream == null) {
outputStream=new ServletOutputStream(){
@Override public void write( int b) throws IOException {
buffer.append((char)b);
realResponse.getOutputStream().write(b);
}
}
;
}
return outputStream;
}
Example 35
From project conf4j, under directory /conf4j-webapp/src/main/java/org/conf4j/webapp/servlet/.
Source file: CheckScopeServlet.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
resp.setContentType("text/plain");
resp.setCharacterEncoding("UTF-8");
final ServletOutputStream os=resp.getOutputStream();
try {
final PrintStream ps=new PrintStream(os);
ps.println("----------------------------------------------------------------------------------------");
ps.println("------------------------------------- CHECK SCOPE --------------------------------------");
ps.println("----------------------------------------------------------------------------------------");
CONF.checkScope(ps);
ps.println("----------------------------------------------------------------------------------------");
}
finally {
os.close();
}
}
Example 36
From project dolphin, under directory /dolphinmaple/src/com/tan/servlet/.
Source file: WikiServlet.java
@Override protected final void doPost(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
String uri=req.getRequestURI();
String type=req.getParameter("type");
ServletOutputStream out=resp.getOutputStream();
if (type != null && type.charAt(0) == '0') {
for (int i=0; i < KEYS.length; i++) {
out.print(KEYS[i]);
}
}
else if (uri != null && uri.trim().length() > 0) {
String wikiKey="wiki/";
String url;
int len=wikiKey.length();
int idx=uri.indexOf("wiki/");
if (idx >= 0) {
idx+=len;
url=uri.substring(idx);
if (url != null) {
url=URLEncoder.encode("http://zh.m.wikipedia.org/wiki?search=" + url.trim(),"utf-8");
resp.sendRedirect("http://dolphinmaple.appspot.com/show.do?url=" + url);
}
}
}
else {
out.println("No wiki information!");
}
}
Example 37
From project EasySOA, under directory /easysoa-registry/easysoa-registry-api/easysoa-registry-api-messaging/src/main/java/org/easysoa/servlet/http/.
Source file: CopyHttpServletResponse.java
public ServletOutputStream getOutputStream() throws IOException {
copyOut=new CopyOutputStream(this.getResponse().getOutputStream());
writer=new PrintWriter(new OutputStreamWriter(copyOut,this.getCharacterEncoding()));
return new ServletOutputStream(){
@Override public void write( int b) throws IOException {
copyOut.write(b);
}
}
;
}
Example 38
From project elasticsearch-jetty, under directory /src/main/java/com/sonian/elasticsearch/http/jetty/.
Source file: JettyHttpServerRestChannel.java
@Override public void sendResponse(RestResponse response){
resp.setContentType(response.contentType());
resp.addHeader("Access-Control-Allow-Origin","*");
if (response.status() != null) {
resp.setStatus(response.status().getStatus());
}
else {
resp.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
}
if (restRequest.method() == RestRequest.Method.OPTIONS) {
resp.addHeader("Access-Control-Max-Age","1728000");
resp.addHeader("Access-Control-Allow-Methods","PUT, DELETE");
resp.addHeader("Access-Control-Allow-Headers","X-Requested-With");
}
try {
int contentLength=response.contentLength();
if (response.prefixContentLength() > 0) {
contentLength+=response.prefixContentLength();
}
if (response.suffixContentLength() > 0) {
contentLength+=response.suffixContentLength();
}
resp.setContentLength(contentLength);
ServletOutputStream out=resp.getOutputStream();
if (response.prefixContent() != null) {
out.write(response.prefixContent(),0,response.prefixContentLength());
}
out.write(response.content(),0,response.contentLength());
if (response.suffixContent() != null) {
out.write(response.suffixContent(),0,response.suffixContentLength());
}
out.close();
}
catch ( IOException e) {
sendFailure=e;
}
finally {
latch.countDown();
}
}
Example 39
From project entando-core-engine, under directory /src/main/java/com/agiletec/plugins/jacms/aps/servlet/.
Source file: ResourceWardenServlet.java
private void createResponse(HttpServletResponse resp,ResourceInterface resource,ResourceInstance instance) throws IOException, ServletException {
resp.setContentType(instance.getMimeType());
resp.setHeader("Content-Disposition","inline; filename=" + instance.getFileName());
ServletOutputStream out=resp.getOutputStream();
try {
File fileTemp=new File(resource.getDiskFolder() + instance.getFileName());
if (fileTemp.exists()) {
InputStream is=new FileInputStream(fileTemp);
byte[] buffer=new byte[8789];
int length=-1;
while ((length=is.read(buffer)) != -1) {
out.write(buffer,0,length);
out.flush();
}
is.close();
}
}
catch ( Throwable t) {
throw new ServletException("Errore in erogazione risorsa protetta",t);
}
finally {
out.close();
}
}
Example 40
From project framework, under directory /impl/extension/jsf/src/test/java/br/gov/frameworkdemoiselle/internal/implementation/.
Source file: FileRendererImplTest.java
@Test public void testRenderBytesSuccess(){
byte[] bytes="Test".getBytes();
String fileName="fileName.pdf";
logger.debug(EasyMock.anyObject(String.class));
EasyMock.expectLastCall().anyTimes();
facesContext.responseComplete();
EasyMock.expectLastCall().times(1);
response.setContentType(ContentType.PDF.getContentType());
EasyMock.expectLastCall().times(1);
response.setContentLength(bytes.length);
EasyMock.expectLastCall().times(1);
response.setHeader("Content-Disposition","filename=\"" + fileName + "\"");
EasyMock.expectLastCall().times(1);
ServletOutputStream stream=PowerMock.createMock(ServletOutputStream.class);
try {
stream.write(bytes,0,bytes.length);
EasyMock.expectLastCall().times(1);
stream.flush();
EasyMock.expectLastCall().times(1);
stream.close();
EasyMock.expectLastCall().times(1);
EasyMock.expect(response.getOutputStream()).andReturn(stream).times(3);
}
catch ( IOException e) {
Assert.fail();
}
PowerMock.replayAll();
renderer.render(bytes,ContentType.PDF,fileName);
PowerMock.verifyAll();
}
Example 41
From project GeoBI, under directory /webapp/src/main/java/com/c2c/controller/.
Source file: GetBaseLayer.java
private void renderMap(HttpServletResponse response,FeatureCollection feat,ReferencedEnvelope bounds,Rectangle imageSize,String format) throws IOException {
MapLayer[] layers={new MapLayer(feat,baseStyle)};
MapContext map=new DefaultMapContext(layers,bounds.getCoordinateReferenceSystem());
try {
GTRenderer renderer=new StreamingRenderer();
renderer.setContext(map);
BufferedImage image=new BufferedImage(imageSize.width,imageSize.height,BufferedImage.TYPE_INT_ARGB);
Graphics2D graphics=image.createGraphics();
graphics.setBackground(new Color(0xd6e4f1));
graphics.clearRect(0,0,imageSize.width,imageSize.height);
try {
if (feat.getSchema().getGeometryDescriptor() == null) {
graphics.setColor(Color.BLACK);
int y=imageSize.height / 2;
Font font=new Font(Font.SERIF,Font.BOLD,14);
graphics.setFont(font);
graphics.drawString("Results have no geometries",10,y - 14);
}
else {
renderer.paint(graphics,imageSize,bounds);
}
ServletOutputStream output=response.getOutputStream();
try {
ImageIO.write(image,format,output);
}
finally {
output.close();
}
}
finally {
graphics.dispose();
}
}
finally {
map.dispose();
}
}
Example 42
From project Guit, under directory /src/main/java/com/guit/server/crawling/.
Source file: CrawlingFilter.java
@Override public void doFilter(ServletRequest request,ServletResponse response,FilterChain chain) throws IOException, ServletException {
HttpServletRequest r=(HttpServletRequest)request;
String query=r.getQueryString();
if (query == null || !query.contains("_escaped_fragment_=")) {
chain.doFilter(request,response);
}
else {
String reqUrl=r.getRequestURL().toString();
String queryString=r.getQueryString();
if (queryString != null) {
reqUrl+="?" + queryString;
}
URL fetchUrl=new URL(snapshootService + "/ajaxcrawler?url=" + URLEncoder.encode(reqUrl,"UTF-8"));
response.setContentType("text/html");
response.setCharacterEncoding("ISO-8859-1");
ServletOutputStream out=response.getOutputStream();
InputStream in=fetchUrl(fetchUrl);
if (in == null) {
out.print("<html><head></head><body></body></html>");
return;
}
final byte[] bytes=new byte[4096];
int bytesRead=in.read(bytes);
while (bytesRead > -1) {
out.write(bytes,0,bytesRead);
bytesRead=in.read(bytes);
}
}
}
Example 43
From project http-testing-harness, under directory /server-provider/src/main/java/org/sonatype/tests/http/server/jetty/behaviour/.
Source file: Deliver.java
public boolean execute(HttpServletRequest request,HttpServletResponse response,Map<Object,Object> ctx) throws Exception {
if (file == null) {
String path=BehaviourHelper.content(request.getPathInfo());
file=new File(path);
}
ServletOutputStream out=response.getOutputStream();
FileInputStream in=null;
try {
response.setContentLength((int)file.length());
in=new FileInputStream(file);
int read=-1;
byte[] buf=new byte[16000];
while ((read=in.read(buf)) != -1) {
out.write(buf,0,read);
}
}
finally {
if (in != null) {
in.close();
}
out.close();
}
return false;
}
Example 44
From project iserve, under directory /iserve-parent/iserve-sal-gwt/src/main/java/uk/ac/open/kmi/iserve/sal/gwt/server/servlets/.
Source file: DownloadFileServlet.java
protected void doPost(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {
String format=request.getParameter("format");
String uri=request.getParameter("uri");
String content="";
try {
if (format.equalsIgnoreCase("xml")) {
content=serviceManager.getService(uri,Syntax.RdfXml);
}
else if (format.equalsIgnoreCase("nt")) {
content=serviceManager.getService(uri,Syntax.Ntriples);
}
else if (format.equalsIgnoreCase("trig")) {
content=serviceManager.getService(uri,Syntax.Trig);
}
else if (format.equalsIgnoreCase("trix")) {
content=serviceManager.getService(uri,Syntax.Trix);
}
else if (format.equalsIgnoreCase("ttl")) {
content=serviceManager.getService(uri,Syntax.Turtle);
}
}
catch ( ServiceException e) {
throw new ServletException(e);
}
ServletOutputStream op=response.getOutputStream();
response.setContentType("application/octet-stream");
response.setHeader("Pragma","public");
response.setHeader("Cache-Control","must-revalidate");
response.setHeader("Content-Disposition","Attachment;Filename=\"" + "export." + format.toLowerCase() + "\"");
op.write(content.getBytes(),0,content.getBytes().length);
op.flush();
op.close();
}
Example 45
From project jagger, under directory /chassis/coordinator.http/src/main/java/com/griddynamics/jagger/coordinator/http/server/.
Source file: ServletUtil.java
public static void sendResponse(HttpServletResponse response,String body){
BufferedWriter bufferedWriter=null;
try {
ServletOutputStream outputStream=response.getOutputStream();
bufferedWriter=new BufferedWriter(new OutputStreamWriter(outputStream));
bufferedWriter.write(body);
}
catch ( IOException e) {
throw Throwables.propagate(e);
}
finally {
if (bufferedWriter != null) {
try {
bufferedWriter.close();
}
catch ( IOException e) {
}
}
}
}
Example 46
From project jahspotify, under directory /web/src/main/java/jahspotify/web/api/.
Source file: HistoryController.java
public void serializeHistoryCursor(Collection<TrackHistory> historyCursor,HttpServletResponse httpServletResponse){
try {
final ServletOutputStream httpOutputStream=httpServletResponse.getOutputStream();
final BufferedWriter outputStream=new BufferedWriter(new OutputStreamWriter(httpOutputStream));
outputStream.write("{");
outputStream.write("\"count\":");
outputStream.write("" + historyCursor.size());
if (historyCursor.size() > 0) {
Gson gson=new Gson();
outputStream.write(",");
outputStream.write("\"tracks\":[");
for (Iterator<TrackHistory> iterator=historyCursor.iterator(); iterator.hasNext(); ) {
TrackHistory next=iterator.next();
outputStream.write(gson.toJson(toWebTrack(next)));
if (iterator.hasNext()) {
outputStream.write(",");
}
outputStream.flush();
}
outputStream.write("]");
}
outputStream.write("}");
outputStream.flush();
outputStream.close();
httpOutputStream.close();
}
catch ( IOException e) {
e.printStackTrace();
}
}
Example 47
From project jAPS2, under directory /src/com/agiletec/plugins/jacms/aps/servlet/.
Source file: ResourceWardenServlet.java
private void createResponse(HttpServletResponse resp,ResourceInterface resource,ResourceInstance instance) throws IOException, ServletException {
resp.setContentType(instance.getMimeType());
resp.setHeader("Content-Disposition","inline; filename=" + instance.getFileName());
ServletOutputStream out=resp.getOutputStream();
try {
File fileTemp=new File(resource.getDiskFolder() + instance.getFileName());
if (fileTemp.exists()) {
InputStream is=new FileInputStream(fileTemp);
byte[] buffer=new byte[8789];
int length=-1;
while ((length=is.read(buffer)) != -1) {
out.write(buffer,0,length);
out.flush();
}
is.close();
}
}
catch ( Throwable t) {
throw new ServletException("Errore in erogazione risorsa protetta",t);
}
finally {
out.close();
}
}
Example 48
From project jboss-servlet-api_spec, under directory /src/main/java/javax/servlet/http/.
Source file: HttpServlet.java
/**
* Called by the server (via the <code>service</code> method) to allow a servlet to handle a TRACE request. A TRACE returns the headers sent with the TRACE request to the client, so that they can be used in debugging. There's no need to override this method.
* @param req the {@link HttpServletRequest} object thatcontains the request the client made of the servlet
* @param resp the {@link HttpServletResponse} object thatcontains the response the servlet returns to the client
* @exception IOException if an input or output error occurswhile the servlet is handling the TRACE request
* @exception ServletException if the request for theTRACE cannot be handled
*/
protected void doTrace(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
int responseLength;
String CRLF="\r\n";
String responseString="TRACE " + req.getRequestURI() + " "+ req.getProtocol();
Enumeration<String> reqHeaderEnum=req.getHeaderNames();
while (reqHeaderEnum.hasMoreElements()) {
String headerName=reqHeaderEnum.nextElement();
responseString+=CRLF + headerName + ": "+ req.getHeader(headerName);
}
responseString+=CRLF;
responseLength=responseString.length();
resp.setContentType("message/http");
resp.setContentLength(responseLength);
ServletOutputStream out=resp.getOutputStream();
out.print(responseString);
}
Example 49
From project jbossportletbridge, under directory /core/portletbridge-impl/src/main/java/org/jboss/portletbridge/context/flash/.
Source file: FlashHttpServletAdapter.java
@Override public ServletOutputStream getOutputStream() throws IOException {
return new ServletOutputStream(){
@Override public void write( int bytes) throws IOException {
if (wrapped instanceof MimeResponse) {
((MimeResponse)wrapped).getPortletOutputStream().write(bytes);
}
}
}
;
}
Example 50
From project jfreechart-plugin, under directory /src/main/java/hudson/util/.
Source file: Graph.java
/**
* Renders a graph.
*/
public void doPng(StaplerRequest req,StaplerResponse rsp) throws IOException {
if (req.checkIfModified(timestamp,rsp)) return;
try {
BufferedImage image=render(req,null);
rsp.setContentType("image/png");
ServletOutputStream os=rsp.getOutputStream();
ImageIO.write(image,"PNG",os);
os.close();
}
catch ( Error e) {
if (e.getMessage().contains("Probable fatal error:No fonts found")) {
rsp.sendRedirect2(req.getContextPath() + "/images/headless.png");
return;
}
throw e;
}
catch ( HeadlessException e) {
rsp.sendRedirect2(req.getContextPath() + "/images/headless.png");
}
}
Example 51
From project jsf-test, under directory /stage/src/main/java/org/jboss/test/faces/staging/.
Source file: StaticServlet.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
InputStream inputStream=getServletContext().getResourceAsStream(req.getPathInfo());
if (null != inputStream) {
String fileName=req.getServletPath();
String mimeType=getServletContext().getMimeType(fileName);
if (null == mimeType) {
mimeType="text/plain";
}
resp.setContentType(mimeType);
ServletOutputStream outputStream=resp.getOutputStream();
int c;
while ((c=inputStream.read()) > 0) {
outputStream.write(c);
}
inputStream.close();
outputStream.close();
}
else {
resp.sendError(404,"not found");
}
}
Example 52
From project Karaf-Tutorial, under directory /cxf/personservice/webui/src/main/java/net/lr/tutorial/karaf/cxf/personservice/webui/.
Source file: PersonServlet.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
ServletOutputStream os=resp.getOutputStream();
Person[] persons=personService.getAll();
os.println("<html><body>");
os.println("<h2>Persons</h2>");
os.println("<table>");
os.println("<tr><th>Id</th><th>Name</th><th>URL</th></tr>");
for ( Person person : persons) {
String url=(person.getUrl() == null) ? "" : person.getUrl();
os.println(String.format("<tr><td>%s</td><td>%s</td><td>%s</td></tr>",person.getId(),person.getName(),url));
}
os.println("</table>");
os.println("<h2>Add Person</h2>");
os.println("<form name='input' action='/personui' method='post'>");
os.println("<table>");
os.println("<tr><td>Id</td><td><input type='text' name='id'/></td></tr>");
os.println("<tr><td>Name</td><td><input type='text' name='name'/></td></tr>");
os.println("<tr><td>Homepage URL</td><td><input type='text' name='url'/></td></tr>");
os.println("<tr><td colspan='2'><input type='submit' value='Add'/></td></tr>");
os.println("</form>");
os.println("</table>");
os.println("</body></html>");
}
Example 53
From project logprocessing, under directory /ui/src/java/com/geminimobile/web/.
Source file: DownloadCSVController.java
@Override protected ModelAndView handleRequestInternal(HttpServletRequest request,HttpServletResponse response) throws Exception {
String msisdn=(String)request.getParameter("msisdn");
String startTime=(String)request.getParameter("starttime");
String endTime=(String)request.getParameter("endtime");
String market=(String)request.getParameter("market");
String type=(String)request.getParameter("type");
Date toDate=SearchCommand.m_sdf.parse(endTime);
Date fromDate=SearchCommand.m_sdf.parse(startTime);
CDRDataAccess cdrAccess=new CDRDataAccess();
Vector<CDREntry> cdrs=cdrAccess.getCDRsByMSISDN(msisdn,fromDate.getTime(),toDate.getTime(),market,type,100000);
StringBuffer sb=new StringBuffer();
sb.append("Date/Time,Market,Type,MSISDN,MO IP address,MT IP Address,Sender Domain,Recipient Domain\n");
for ( CDREntry entry : cdrs) {
sb.append(entry.getDisplayTimestamp() + "," + entry.getMarket()+ ","+ entry.getType()+ ","+ entry.getMsisdn()+ ","+ entry.getMoIPAddress()+ ","+ entry.getMtIPAddress()+ ","+ entry.getSenderDomain()+ ","+ entry.getRecipientDomain()+ "\n");
}
String csvString=sb.toString();
response.setBufferSize(sb.length());
response.setContentLength(sb.length());
response.setContentType("text/plain; charset=UTF-8");
response.setHeader("Content-Disposition","attachment; filename=" + "cdrResults.csv" + ";");
ServletOutputStream os=response.getOutputStream();
os.write(csvString.getBytes());
os.flush();
os.close();
return null;
}
Example 54
From project Mail-Pigeon, under directory /pigeon-web/src/main/java/com/trivago/mail/pigeon/web/.
Source file: TrackingServlet.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
String userId=req.getParameter("user_id");
String newsletterId=req.getParameter("newsletter_id");
if (userId != null && newsletterId != null) {
final GraphDatabaseService database=ConnectionFactory.getDatabase();
Node newsletterNode=ConnectionFactory.getNewsletterIndex().get(IndexTypes.NEWSLETTER_ID,newsletterId).getSingle();
Node userNode=ConnectionFactory.getUserIndex().get(IndexTypes.USER_ID,userId).getSingle();
if (newsletterNode != null && userNode != null) {
final Transaction transaction=database.beginTx();
try {
if (!userNode.hasRelationship(RelationTypes.OPENED,Direction.OUTGOING)) {
userNode.createRelationshipTo(newsletterNode,RelationTypes.OPENED);
}
else {
boolean found=false;
for ( Relationship rel : userNode.getRelationships(RelationTypes.OPENED)) {
if (rel.getEndNode().equals(newsletterNode)) {
found=true;
}
}
if (!found) {
userNode.createRelationshipTo(newsletterNode,RelationTypes.OPENED);
}
}
transaction.success();
}
catch ( Exception e) {
transaction.failure();
}
finally {
transaction.finish();
}
}
}
resp.setContentType("image/gif");
byte[] emptyGif=new byte[]{0x47,0x49,0x46,0x38,0x39,0x61,0x01,0x00,0x01,0x00,(byte)0xf0,0x01,0x00,(byte)0xff,(byte)0xff,(byte)0xff,0x00,0x00,0x00,0x21,(byte)0xf9,0x04,0x01,0x0a,0x00,0x00,0x00,0x2c,0x00,0x00,0x00,0x00,0x01,0x00,0x01,0x00,0x00,0x02,0x02,0x44,0x01,0x00,0x3b};
resp.setContentLength(emptyGif.length);
ServletOutputStream out=resp.getOutputStream();
out.write(emptyGif);
}
Example 55
From project MEditor, under directory /editor-webapp/src/main/java/cz/mzk/editor/server/.
Source file: DownloadFoxmlServlet.java
@Override protected void doPost(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
String uuid=req.getParameterValues(Constants.PARAM_UUID)[0];
String datastream=null;
if (req.getRequestURI().contains(Constants.SERVLET_DOWNLOAD_FOXML_PREFIX)) {
resp.addHeader("Content-Disposition","attachment; ContentType = \"text/xml\"; filename=\"" + uuid + "_local_version.foxml\"");
}
else {
datastream=req.getParameterValues(Constants.PARAM_DATASTREAM)[0];
resp.addHeader("Content-Disposition","attachment; ContentType = \"text/xml\"; filename=\"" + uuid + "_local_version_"+ datastream+ ".xml\"");
}
String xmlContent=URLDecoder.decode(req.getParameterValues(Constants.PARAM_CONTENT)[0],"UTF-8");
InputStream is=new ByteArrayInputStream(xmlContent.getBytes("UTF-8"));
ServletOutputStream os=resp.getOutputStream();
IOUtils.copyStreams(is,os);
os.flush();
}
Example 56
From project mgwt, under directory /src/main/java/com/googlecode/mgwt/linker/server/.
Source file: Html5ManifestServletBase.java
public void serveStringManifest(HttpServletRequest req,HttpServletResponse resp,String manifest) throws ServletException {
resp.setHeader("Cache-Control","no-cache");
resp.setHeader("Pragma","no-cache");
resp.setDateHeader("Expires",new Date().getTime());
resp.setContentType("text/cache-manifest");
try {
InputStream is=new ByteArrayInputStream(manifest.getBytes("UTF-8"));
ServletOutputStream os=resp.getOutputStream();
byte[] buffer=new byte[1024];
int bytesRead;
while ((bytesRead=is.read(buffer)) != -1) {
os.write(buffer,0,bytesRead);
}
return;
}
catch ( UnsupportedEncodingException e) {
log("can not write manifest to output stream",e);
throw new ServletException("can not write manifest to output stream",e);
}
catch ( IOException e) {
log("can not write manifest to output stream",e);
throw new ServletException("can not write manifest to output stream",e);
}
}
Example 57
From project nuxeo-services, under directory /nuxeo-platform-web-common/src/test/java/org/nuxeo/ecm/platform/web/requestcontroller/filter/.
Source file: TestBufferingServletResponse.java
public ResponseProxy(final OutputStream out){
sout=new ServletOutputStream(){
@Override public void write( int b) throws IOException {
out.write(b);
}
}
;
}
Example 58
From project OpenReports, under directory /src/org/efs/openreports/actions/admin/.
Source file: DataExportAction.java
public String execute(){
try {
if (!submitOk) {
reports=reportProvider.getReports();
return SUCCESS;
}
XStream xStream=new XStream();
xStream.omitField(BasicDataSource.class,"logWriter");
xStream.omitField(Report.class,"id");
xStream.omitField(ReportAlert.class,"id");
xStream.omitField(ReportChart.class,"id");
xStream.omitField(ReportParameter.class,"id");
xStream.omitField(ReportExportOption.class,"id");
List<Report> selectedReports=new ArrayList<Report>();
for (int i=0; i < reportIds.length; i++) {
Report report=reportProvider.getReport(new Integer(reportIds[i]));
selectedReports.add(report);
}
HttpServletResponse response=ServletActionContext.getResponse();
response.setHeader("Content-disposition","inline; filename=or-report-export.xml");
response.setContentType("application/xml");
ServletOutputStream outputStream=response.getOutputStream();
xStream.toXML(selectedReports,outputStream);
outputStream.flush();
outputStream.close();
return NONE;
}
catch ( Exception e) {
addActionError(e.toString());
return INPUT;
}
}
Example 59
From project picketbox-http, under directory /src/test/java/org/picketbox/test/http/.
Source file: TestServletResponse.java
public ServletOutputStream getOutputStream() throws IOException {
bos.flush();
return new ServletOutputStream(){
@Override public void write( int b) throws IOException {
bos.write(b);
}
}
;
}
Example 60
From project platform_3, under directory /rack/src/test/java/com/proofpoint/rack/.
Source file: TestRackServlet.java
private String performRequest(String queryString,String path,final String postBody,String method) throws IOException, ServletException {
HttpServletRequest request=mock(HttpServletRequest.class);
when(request.getInputStream()).thenReturn(new ServletInputStream(){
int index=0;
@Override public int read() throws IOException {
if (index < postBody.length()) return postBody.charAt(index++);
return -1;
}
@Override public void reset(){
index=0;
}
}
);
when(request.getScheme()).thenReturn("http");
when(request.getMethod()).thenReturn(method);
when(request.getRequestURI()).thenReturn(path);
when(request.getQueryString()).thenReturn(queryString);
when(request.getServerName()).thenReturn("TestServer");
when(request.getServerPort()).thenReturn(new Random().nextInt());
when(request.getHeaderNames()).thenReturn(Collections.enumeration(ImmutableList.<String>of()));
final StringBuilder outputBuilder=new StringBuilder();
ServletOutputStream outputStream=new ServletOutputStream(){
@Override public void write( int i) throws IOException {
outputBuilder.append(new String(new int[]{i},0,1));
}
}
;
HttpServletResponse response=mock(HttpServletResponse.class);
when(response.getOutputStream()).thenReturn(outputStream);
servlet.service(request,response);
return outputBuilder.toString();
}
Example 61
From project scooter, under directory /source/src/com/scooterframework/web/controller/.
Source file: ContentHandlerHelper.java
/**
* Sends content bytes to the requestor. Default <tt>mimeType</tt> is <tt>application/octet-stream</tt>.
* @param response The HTTP response object.
* @param content The content to be sent.
* @param mimeType The content MIME type.
* @throws IOException
* @throws ServletException
*/
public static void publish(HttpServletResponse response,byte[] content,String mimeType) throws IOException, ServletException {
String encoding=response.getCharacterEncoding();
if (encoding == null) encoding="utf-8";
if (mimeType == null || "".equals(mimeType)) mimeType="application/octet-stream";
mimeType=mimeType.toLowerCase();
if (mimeType.indexOf("charset") == -1) {
response.setContentType(mimeType + "; charset=" + encoding);
}
else {
response.setContentType(mimeType);
}
response.setContentLength(content.length);
response.setStatus(HttpServletResponse.SC_OK);
ServletOutputStream out=response.getOutputStream();
out.write(content);
out.close();
}
Example 62
From project sonatype-aether, under directory /aether-connector-asynchttpclient/src/test/java/org/sonatype/aether/connector/async/.
Source file: Generate.java
public boolean execute(HttpServletRequest request,HttpServletResponse response,Map<Object,Object> ctx) throws Exception {
if ("GET".equals(request.getMethod())) {
String path=request.getPathInfo();
Long length=lengths.get(path);
if (length != null) {
response.setContentType("application/octet-stream");
response.setContentLength(length.intValue());
ServletOutputStream out=response.getOutputStream();
for (int i=length.intValue(); i > 0; ) {
int n=Math.min(i,bytes.length);
i-=n;
out.write(bytes,0,n);
}
out.close();
return false;
}
}
return true;
}
Example 63
From project teatrove, under directory /teaservlet/src/main/java/org/teatrove/teaservlet/.
Source file: TeaServlet.java
/**
* Inserts a plugin to expose parts of the teaservlet via the EngineAccess interface. private void createEngineAccessPlugin(PluginContext context) { Plugin engineAccess = new EngineAccessPlugin(this); context.addPlugin(engineAccess); context.addPluginListener(engineAccess); }
*/
private boolean processResource(ApplicationRequest appRequest,ApplicationResponse appResponse) throws IOException {
String context=appRequest.getContextPath();
String requestURI=appRequest.getRequestURI();
if (requestURI.startsWith(context)) {
requestURI=requestURI.substring(context.length());
}
Asset asset=getEngine().getAssetEngine().getAsset(requestURI);
if (asset == null) {
return false;
}
appResponse.setContentType(asset.getMimeType());
int read=-1;
byte[] contents=new byte[1024];
InputStream input=asset.getInputStream();
ServletOutputStream output=appResponse.getOutputStream();
while ((read=input.read(contents)) >= 0) {
output.write(contents,0,read);
}
appResponse.finish();
return true;
}
Example 64
From project tempo, under directory /ui-fw/src/main/java/org/intalio/tempo/uiframework/export/.
Source file: ExternalTasksServlet.java
@Override protected void doGet(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {
try {
TokenClient tc=Configuration.getInstance().getTokenClient();
String rtoken=request.getParameter("token");
String pToken;
String user;
if (rtoken != null) {
Property[] properties=tc.getTokenProperties(rtoken);
user=PropertyUtils.getProperty(properties,AuthenticationConstants.PROPERTY_USER).getValue().toString();
pToken=rtoken;
}
else {
ApplicationState state=ApplicationState.getCurrentInstance(new HttpServletRequestWrapper(request));
User currentUser=state.getCurrentUser();
pToken=currentUser.getToken();
user=currentUser.getName();
}
TasksCollector collector=new TasksCollector(new HttpServletRequestWrapper(request),user,pToken);
tasks=collector.retrieveTasks();
ServletOutputStream outputStream=response.getOutputStream();
String filename="tasks for " + user + getFileExt();
response.setContentType(getFileMimeType());
response.addHeader("Content-disposition","attachment; filename=\"" + filename + "\"");
generateFile(request,pToken,user,outputStream);
}
catch ( Exception e) {
throw new ServletException(e);
}
}
Example 65
From project tvguide-sample-parent, under directory /tvguide-client/src/main/java/com/acme/gwt/server/.
Source file: HomepageServlet.java
@Override protected void doGet(HttpServletRequest req,HttpServletResponse resp) throws ServletException, IOException {
ServletOutputStream out=resp.getOutputStream();
resp.setDateHeader("Expires",new Date().getTime() + 60);
out.println("<!doctype html>");
out.println("<html>");
out.println("<head>");
out.println("<meta http-equiv=\"content-type\" content=\"text/html; charset=UTF-8\">");
out.println("<title>GWT TV Guide Sample</title>");
out.println("<script type=\"text/javascript\" language=\"javascript\" src=\"tvguide/tvguide.nocache.js\"></script>");
out.println("<script type=\"text/javascript\">var store = '" + auth.getViewerAsJson() + "';</script>");
out.println("<body>");
out.println("<iframe src=\"javascript:''\" id=\"__gwt_historyFrame\" tabIndex='-1' style=\"position:absolute;width:0;height:0;border:0\"></iframe>");
out.println("</body>");
out.println("</html>");
}
Example 66
From project undertow, under directory /servlet/src/main/java/io/undertow/servlet/handlers/.
Source file: DefaultServlet.java
@Override protected void doGet(final HttpServletRequest req,final HttpServletResponse resp) throws ServletException, IOException {
final String path=getPath(req);
if (!isAllowed(path)) {
resp.setStatus(404);
return;
}
ServletOutputStream out=null;
final File resource=deployment.getDeploymentInfo().getResourceLoader().getResource(path);
if (resource == null) {
resp.setStatus(404);
return;
}
else if (resource.isDirectory()) {
handleWelcomePage(req,resp,resource);
}
else {
InputStream in=new BufferedInputStream(new FileInputStream(resource));
try {
int read;
final byte[] buffer=new byte[1024];
out=resp.getOutputStream();
while ((read=in.read(buffer)) != -1) {
out.write(buffer,0,read);
}
}
finally {
if (out != null) {
IoUtils.safeClose(out);
}
IoUtils.safeClose(in);
}
}
}
Example 67
From project visural-common, under directory /src/main/java/com/visural/common/cache/inspector/.
Source file: CacheInspectorFilter.java
public void doFilter(ServletRequest sr,ServletResponse sr1,FilterChain fc) throws IOException, ServletException {
HttpServletRequest req=(HttpServletRequest)sr;
HttpServletResponse res=(HttpServletResponse)sr1;
if (req.getServletPath().startsWith(filterPath)) {
res.setContentType("text/html");
ServletOutputStream out=res.getOutputStream();
if (module == null || module.get() == null) {
out.write("No CacheModule has been registered with CacheInspectorFilter.class".getBytes());
out.close();
}
else {
StringTemplate t=htmlTemplate.getInstanceOf();
Map<String,Map<String,CacheStatsAggregated>> stats=module.get().getStatistics(true);
Map<CacheClass,List<StatEntry>> classes=new HashMap();
for ( Entry<String,Map<String,CacheStatsAggregated>> e : stats.entrySet()) {
List<StatEntry> methods=new ArrayList();
classes.put(new CacheClass(e.getKey()),methods);
for ( Entry<String,CacheStatsAggregated> s : e.getValue().entrySet()) {
String methodName=s.getKey();
Pattern p=Pattern.compile(".+" + Pattern.quote(e.getKey()) + "\\.(.+)\\(");
Matcher m=p.matcher(s.getKey());
if (m.find()) {
methodName=m.group(1);
}
methods.add(new StatEntry(s.getKey().replace(e.getKey() + ".",""),methodName,s.getValue(),methods.size() % 2 == 0 ? "a" : "b"));
}
}
t.setAttribute("classes",classes);
t.setAttribute("server",req.getServerName() + ":" + req.getServerPort()+ req.getContextPath());
out.write(t.toString().getBytes());
out.close();
}
}
else {
fc.doFilter(sr,sr1);
}
}
Example 68
From project vmarket, under directory /src/main/java/org/apache/velocity/servlet/.
Source file: VelocityServlet.java
/**
* merges the template with the context. Only override this if you really, really really need to. (And don't call us with questions if it breaks :)
* @param template template object returned by the handleRequest() method
* @param context context created by the createContext() method
* @param response servlet reponse (use this to get the output stream or Writer
* @throws ResourceNotFoundException
* @throws ParseErrorException
* @throws MethodInvocationException
* @throws IOException
* @throws UnsupportedEncodingException
* @throws Exception
*/
protected void mergeTemplate(Template template,Context context,HttpServletResponse response) throws ResourceNotFoundException, ParseErrorException, MethodInvocationException, IOException, UnsupportedEncodingException, Exception {
ServletOutputStream output=response.getOutputStream();
VelocityWriter vw=null;
String encoding=response.getCharacterEncoding();
try {
vw=(VelocityWriter)writerPool.get();
if (vw == null) {
vw=new VelocityWriter(new OutputStreamWriter(output,encoding),4 * 1024,true);
}
else {
vw.recycle(new OutputStreamWriter(output,encoding));
}
template.merge(context,vw);
}
finally {
if (vw != null) {
try {
vw.flush();
}
catch ( IOException e) {
}
vw.recycle(null);
writerPool.put(vw);
}
}
}
Example 69
From project vraptor, under directory /vraptor-core/src/test/java/br/com/caelum/vraptor/interceptor/download/.
Source file: ByteArrayDownloadTest.java
@Before public void setUp() throws Exception {
MockitoAnnotations.initMocks(this);
bytes=new byte[]{(byte)0};
this.outputStream=new ByteArrayOutputStream();
this.socketStream=new ServletOutputStream(){
public void write( int b) throws IOException {
outputStream.write(b);
}
}
;
when(response.getOutputStream()).thenReturn(socketStream);
}
Example 70
From project zanata, under directory /zanata-war/src/main/java/org/zanata/action/.
Source file: ConfigurationAction.java
public void getData(){
HttpServletResponse response=(HttpServletResponse)FacesContext.getCurrentInstance().getExternalContext().getResponse();
response.setContentType("application/xml");
response.addHeader("Content-disposition","attachment; filename=\"" + this.configurationServiceImpl.getConfigurationFileName() + "\"");
response.setCharacterEncoding("UTF-8");
try {
ServletOutputStream os=response.getOutputStream();
os.write(this.configurationServiceImpl.getConfigurationFileContents(this.projectSlug,this.iterationSlug,null).getBytes());
os.flush();
os.close();
FacesContext.getCurrentInstance().responseComplete();
}
catch ( Exception e) {
log.error("Failure : " + e.toString() + "\n");
}
}
Example 71
From project zen-project, under directory /zen-webservice/src/main/java/com/nominanuda/springmvc/.
Source file: HtmlSaxPageViewResolver.java
public ServletOutputStream getOutputStream() throws IOException {
return new ServletOutputStream(){
public void write( int b) throws IOException {
baos.write(b);
}
public void write( byte[] b, int off, int len) throws IOException {
baos.write(b,off,len);
}
public void write( byte[] b) throws IOException {
baos.write(b);
}
}
;
}
Example 72
From project b3log-latke, under directory /latke/src/main/java/org/b3log/latke/servlet/filter/.
Source file: AbstractGZIPFilter.java
/**
* Creates output stream with GZIP delegation.
* @return servlet output stream
* @throws IOException io exception
*/
private ServletOutputStream createOutputStream() throws IOException {
final ServletResponse servletResponse=this.getResponse();
gzipStream=new GZIPOutputStream(servletResponse.getOutputStream());
return new ServletOutputStream(){
@Override public void write( final int b) throws IOException {
gzipStream.write(b);
}
@Override public void flush() throws IOException {
gzipStream.flush();
}
@Override public void close() throws IOException {
gzipStream.close();
}
@Override public void write( final byte[] b) throws IOException {
gzipStream.write(b);
}
@Override public void write( final byte[] b, final int off, final int len) throws IOException {
gzipStream.write(b,off,len);
}
}
;
}
Example 73
From project Blitz, under directory /src/com/laxser/blitz/web/portal/impl/.
Source file: WindowResponse.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (out == null) {
this.out=new ServletOutputStream(){
ByteArrayOutputStream baos=new ByteArrayOutputStream(getBufferSize());
@Override public void write( int b) throws IOException {
baos.write(b);
}
@Override public void flush() throws IOException {
byte[] bytes=baos.toByteArray();
baos.reset();
window.appendContent(new String(bytes,getCharacterEncoding()));
}
}
;
}
return out;
}
Example 74
From project OpenID-Connect-Java-Spring-Server, under directory /openid-connect-server/src/test/java/org/mitre/openid/connect/view/.
Source file: X509CertificateViewTest.java
/**
* Test method for {@link org.mitre.openid.connect.view.X509CertificateView#renderMergedOutputModel(java.util.Map,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)}.
* @throws IOException
* @throws NoSuchAlgorithmException
* @throws NoSuchFieldException
* @throws SecurityException
* @throws IllegalAccessException
* @throws IllegalArgumentException
*/
@Test public void testRenderMergedOutputModelMapOfStringObjectHttpServletRequestHttpServletResponse() throws IOException, NoSuchAlgorithmException, SecurityException, NoSuchFieldException, IllegalArgumentException, IllegalAccessException {
X509CertificateView view=new X509CertificateView();
Field field=view.getClass().getDeclaredField("config");
field.setAccessible(true);
field.set(view,config);
Map<String,Object> model=createMock(Map.class);
HttpServletRequest request=createMock(HttpServletRequest.class);
HttpServletResponse response=createMock(HttpServletResponse.class);
KeyPairGenerator generator=KeyPairGenerator.getInstance("RSA");
KeyPair kp=generator.generateKeyPair();
RsaSigner rsaSigner=new RsaSigner(JwsAlgorithm.RS256.getJwaName(),kp.getPublic(),kp.getPrivate());
Map<String,JwtSigner> signers=new HashMap<String,JwtSigner>();
signers.put("rsa1",rsaSigner);
expect(model.get("signers")).andReturn(signers);
expect(response.getOutputStream()).andReturn(new ServletOutputStream(){
public void write( int b) throws IOException {
}
}
);
response.setContentType("application/x-pem-file");
expectLastCall();
replay(model);
replay(request);
replay(response);
view.renderMergedOutputModel(model,request,response);
}
Example 75
From project pluto, under directory /pluto-container/src/main/java/org/apache/pluto/container/impl/.
Source file: HttpServletPortletResponseWrapper.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (servletOutputStream == null) {
outputStream=mimeResponse != null ? mimeResponse.getPortletOutputStream() : DummyServletOutputStream.getInstance();
if (outputStream instanceof ServletOutputStream) {
servletOutputStream=(ServletOutputStream)outputStream;
}
else {
servletOutputStream=new ServletOutputStream(){
@Override public void write( int b) throws IOException {
outputStream.write(b);
}
}
;
}
}
return servletOutputStream;
}
Example 76
From project sandbox_2, under directory /wicket-portlet/src/main/java/org/apache/wicket/protocol/http/portlet/.
Source file: WicketResponseState.java
public ServletOutputStream getOutputStream() throws IOException {
if (isStateAwareResponse) {
return null;
}
if (outputStream == null) {
if (printWriter != null) {
throw new IllegalStateException("getWriter() has already been called on this response");
}
byteOutputBuffer=new ByteArrayOutputStream();
outputStream=new ServletOutputStream(){
@Override public void write( int b) throws IOException {
if (!closed) {
byteOutputBuffer.write(b);
if (contentLength > -1 && byteOutputBuffer.size() >= contentLength) {
committed=true;
closed=true;
}
}
}
}
;
}
return outputStream;
}
Example 77
From project skalli, under directory /org.eclipse.skalli.view.test/src/main/java/org/eclipse/skalli/view/internal/servlet/.
Source file: ResourceServletTest.java
@Test public void testDoGet() throws Exception {
HttpServletRequest mockRequest=createMock(HttpServletRequest.class);
HttpServletResponse mockResponse=createMock(HttpServletResponse.class);
Object[] mocks=new Object[]{mockRequest,mockResponse};
ResourceServlet servlet=new ResourceServlet();
reset(mocks);
mockRequest.getPathInfo();
expectLastCall().andReturn("/widgetsets/com.vaadin.terminal.gwt.DefaultWidgetSet/hosted.html");
mockResponse.getOutputStream();
expectLastCall().andReturn(new ServletOutputStream(){
@Override public void write( int b) throws IOException {
written=true;
}
}
);
replay(mocks);
servlet.doGet(mockRequest,mockResponse);
Assert.assertTrue(written);
verify(mocks);
}
Example 78
From project sparsemapcontent, under directory /extensions/proxy/src/test/java/uk/co/tfd/sm/proxy/.
Source file: ProxyServletVivoMan.java
@Test public void testVivoFeed() throws Exception {
when(request.getPathInfo()).thenReturn("/tests/vivo");
when(request.getHeaderNames()).thenReturn(headerNames.elements());
Map<String,String[]> requestParameters=ImmutableMap.of("id",new String[]{"n7934"});
when(request.getParameterMap()).thenReturn(requestParameters);
final ByteArrayOutputStream byteArrayOutputStream=new ByteArrayOutputStream();
when(response.getOutputStream()).thenReturn(new ServletOutputStream(){
@Override public void write( int v) throws IOException {
byteArrayOutputStream.write(v);
}
}
);
long s=System.currentTimeMillis();
servlet.service(request,response);
LOGGER.info("Took {} ",(System.currentTimeMillis() - s));
verify(response,Mockito.atMost(0)).sendError(404);
String output=byteArrayOutputStream.toString("UTF-8");
LOGGER.info("Got Response {} ",output);
}
Example 79
From project spring-security-saml, under directory /saml2-core/src/test/java/org/springframework/security/saml/websso/.
Source file: WebSSOProfileHoKImplTest.java
@Before public void initialize() throws Exception {
String resName="/" + getClass().getName().replace('.','/') + ".xml";
context=new ClassPathXmlApplicationContext(resName);
profile=context.getBean("webSSOprofile",WebSSOProfile.class);
metadata=context.getBean("metadata",MetadataManager.class);
options=new WebSSOProfileOptions(null);
request=createNiceMock(HttpServletRequest.class);
response=createNiceMock(HttpServletResponse.class);
output=new ServletOutputStream(){
public void write( int b) throws IOException {
}
}
;
storage=createMock(SAMLMessageStorage.class);
contextProvider=context.getBean("contextProvider",SAMLContextProviderImpl.class);
((SAMLContextProviderImpl)contextProvider).setStorageFactory(new StorageFactoryTestImpl(storage));
expect(request.getContextPath()).andReturn("/");
replyMock();
samlContext=contextProvider.getLocalAndPeerEntity(request,response);
samlContext.setInboundMessageTransport(new HttpServletRequestAdapter(request));
samlContext.setOutboundMessageTransport(new HttpServletResponseAdapter(response,false));
verifyMock();
expect(response.getOutputStream()).andReturn(output).anyTimes();
}
Example 80
From project waffle, under directory /Source/ThirdParty/tomcat/webapps/examples/WEB-INF/classes/compressionFilters/.
Source file: CompressionServletResponseWrapper.java
/**
* Create and return a ServletOutputStream to write the content associated with this Response.
* @exception IOException if an input/output error occurs
*/
public ServletOutputStream createOutputStream() throws IOException {
if (debug > 1) {
System.out.println("createOutputStream gets called");
}
CompressionResponseStream stream=new CompressionResponseStream(origResponse);
stream.setDebugLevel(debug);
stream.setBuffer(threshold);
return stream;
}
Example 81
From project webutilities, under directory /src/main/java/com/googlecode/webutilities/common/.
Source file: WebUtilitiesResponseWrapper.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (getWriterCalled) {
throw new IllegalStateException("getWriter already called.");
}
getStreamCalled=true;
return this.stream;
}
Example 82
From project 3Dto2DApplet, under directory /src/java/nl/dannyarends/www/http/.
Source file: Webserver.java
public ServletOutputStream getOutputStream(){
synchronized (out) {
if (rout == null) {
if (pw != null) throw new IllegalStateException("Already returned as a writer");
rout=out;
}
}
return rout;
}
Example 83
From project agile, under directory /agile-framework/src/main/java/org/apache/catalina/servlets/.
Source file: DefaultServlet.java
/**
* Copy the contents of the specified input stream to the specified output stream, and ensure that both streams are closed before returning (even in the face of an exception).
* @param resourceInfo The resource information
* @param ostream The output stream to write to
* @exception IOException if an input/output error occurs
*/
protected void copy(CacheEntry cacheEntry,InputStream is,ServletOutputStream ostream) throws IOException {
IOException exception=null;
InputStream resourceInputStream=null;
if (cacheEntry.resource != null) {
byte buffer[]=cacheEntry.resource.getContent();
if (buffer != null) {
ostream.write(buffer,0,buffer.length);
return;
}
resourceInputStream=cacheEntry.resource.streamContent();
}
else {
resourceInputStream=is;
}
InputStream istream=new BufferedInputStream(resourceInputStream,input);
exception=copyRange(istream,ostream);
istream.close();
if (exception != null) throw exception;
}
Example 84
From project arquillian-extension-warp, under directory /impl/src/main/java/org/jboss/arquillian/warp/impl/server/execution/.
Source file: NonWritingPrintWriter.java
void finallyWriteAndClose(ServletOutputStream delegateStream) throws IOException {
this.flush();
baos.flush();
byte[] byteArray=baos.toByteArray();
delegateStream.write(byteArray);
if (wasClosed) {
super.close();
}
}
Example 85
From project core_4, under directory /api/src/main/java/org/ajax4jsf/io/.
Source file: FastBufferWriter.java
public void printTo(ServletOutputStream outputStream) throws IOException {
CharBuffer b=firstBuffer;
while (b != null) {
outputStream.print(new String(b.getChars()));
b=b.getNext();
}
}
Example 86
From project Cours-3eme-ann-e, under directory /Java/tomcat/examples/WEB-INF/classes/compressionFilters/.
Source file: CompressionServletResponseWrapper.java
/**
* Create and return a ServletOutputStream to write the content associated with this Response.
* @exception IOException if an input/output error occurs
*/
public ServletOutputStream createOutputStream() throws IOException {
if (debug > 1) {
System.out.println("createOutputStream gets called");
}
CompressionResponseStream stream=new CompressionResponseStream(origResponse);
stream.setDebugLevel(debug);
stream.setBuffer(threshold);
return stream;
}
Example 87
From project gatein-common, under directory /common/src/main/java/org/gatein/common/servlet/.
Source file: BufferingResponseWrapper.java
public ServletOutputStream getOutputStream() throws IOException {
if (writer != null) {
throw new IllegalStateException("Already obtained a PrintWriter");
}
if (outputStream == null) {
outputStream=new ServletOutputStreamBuffer(500);
}
return outputStream;
}
Example 88
public ServletOutputStream getOutputStream(){
synchronized (out) {
if (rout == null) {
if (pw != null) throw new IllegalStateException("Already returned as a writer");
rout=out;
}
}
return rout;
}
Example 89
From project jboss-as-quickstart, under directory /kitchensink-html5-mobile/src/main/java/org/jboss/as/quickstarts/html5_mobile/util/.
Source file: JSONPRequestFilter.java
@Override public void doFilter(ServletRequest request,ServletResponse response,FilterChain chain) throws IOException, ServletException {
if (!(request instanceof HttpServletRequest)) {
throw new ServletException("Only HttpServletRequest requests are supported");
}
final HttpServletRequest httpRequest=(HttpServletRequest)request;
final HttpServletResponse httpResponse=(HttpServletResponse)response;
String callback=getCallbackMethod(httpRequest);
if (!isJSONPRequest(callback)) {
chain.doFilter(request,response);
}
else {
if (!SAFE_PRN.matcher(callback).matches()) {
throw new ServletException("JSONP Callback method '" + CALLBACK_METHOD + "' parameter not valid function");
}
final ByteArrayOutputStream byteStream=new ByteArrayOutputStream();
HttpServletResponseWrapper responseWrapper=new HttpServletResponseWrapper(httpResponse){
@Override public ServletOutputStream getOutputStream() throws IOException {
return new ServletOutputStream(){
@Override public void write( int b) throws IOException {
byteStream.write(b);
}
}
;
}
@Override public PrintWriter getWriter() throws IOException {
return new PrintWriter(byteStream);
}
}
;
chain.doFilter(request,responseWrapper);
response.setContentType(CONTENT_TYPE);
response.setCharacterEncoding("UTF-8");
response.getOutputStream().write((callback + "(").getBytes());
response.getOutputStream().write(byteStream.toByteArray());
response.getOutputStream().write(");".getBytes());
}
}
Example 90
From project logback, under directory /logback-access/src/main/java/ch/qos/logback/access/servlet/.
Source file: TeeHttpServletResponse.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (teeServletOutputStream == null) {
teeServletOutputStream=new TeeServletOutputStream(this.getResponse());
}
return teeServletOutputStream;
}
Example 91
From project ncDiamond, under directory /src/compressionFilters/.
Source file: CompressionServletResponseWrapper.java
/**
* Create and return a ServletOutputStream to write the content associated with this Response.
* @exception IOException if an input/output error occurs
*/
public ServletOutputStream createOutputStream() throws IOException {
if (debug > 1) {
System.out.println("createOutputStream gets called");
}
CompressionResponseStream stream=new CompressionResponseStream(origResponse);
stream.setDebugLevel(debug);
stream.setBuffer(threshold);
return stream;
}
Example 92
From project nuxeo-opensocial, under directory /nuxeo-opensocial-server/src/main/java/org/apache/shindig/gadgets/servlet/.
Source file: NXConcatProxyServlet.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (errorCode != SC_OK) {
outputStream=new NullServletOutputStream();
}
if (outputStream == null) {
outputStream=super.getOutputStream();
}
return outputStream;
}
Example 93
From project portlet-utils, under directory /portal-rest-api/src/main/java/org/jasig/portlet/utils/rest/.
Source file: SimpleCrossContextRestApiInvoker.java
@Override public ServletOutputStream getOutputStream(){
if (writer != null) {
final String msg="The method HttpServletResponse.getWriter has " + "already been called; call either getOutputStream or " + "getWriter, but not both";
throw new IllegalStateException(msg);
}
outputStream=new ServletOutputStreamImpl();
return outputStream;
}
Example 94
From project remitt, under directory /src/main/java/org/remitt/server/.
Source file: TestHarnessServlet.java
public void parserTest(String parserClass,String input,ServletOutputStream out) throws IOException {
X12Message p=null;
try {
p=(X12Message)Class.forName(parserClass).newInstance();
}
catch ( InstantiationException e) {
log.error(e);
out.println(e.toString());
return;
}
catch ( IllegalAccessException e) {
log.error(e);
out.println(e.toString());
return;
}
catch ( ClassNotFoundException e) {
log.error(e);
out.println(e.toString());
return;
}
try {
p.parse(input);
}
catch ( FormatException e) {
log.error(e);
out.println(e.toString());
return;
}
out.println(p.toString());
}
Example 95
From project rewrite, under directory /impl-servlet/src/main/java/org/ocpsoft/rewrite/servlet/impl/.
Source file: HttpRewriteWrappedResponse.java
@Override public ServletOutputStream getOutputStream(){
if (outputStream == null) {
if (isResponseContentIntercepted()) outputStream=new RewriteServletOutputStream(bufferedResponseContent);
else {
try {
lockStreams();
outputStream=super.getOutputStream();
}
catch ( IOException e) {
throw new RewriteException("Could not get response output stream.",e);
}
}
if (isResponseStreamWrapped()) {
HttpServletRewrite event=new HttpBufferRewriteImpl(request,this);
OutputStream wrapped=outputStream;
for ( ResponseStreamWrapper wrapper : responseStreamWrappers) {
wrapped=wrapper.wrap(event,wrapped);
}
outputStream=new RewriteServletOutputStream(wrapped);
}
}
return outputStream;
}
Example 96
From project riot, under directory /cachius/src/org/riotfamily/cachius/http/.
Source file: CachiusResponse.java
/**
* Returns an ServletOutputStream that writes into the OutputStream provided by the CacheItem. All output is redirected so nothing will be sent to the client.
* @throws IllegalStateException If getWriter() has been called before
* @throws IOException
*/
public ServletOutputStream getOutputStream() throws IOException {
if (writer != null) {
throw new IllegalStateException();
}
if (outputStream == null) {
outputStream=new DelegatingServletOutputStream(new BufferedOutputStream(new FileOutputStream(file)));
}
return outputStream;
}
Example 97
From project rolefen, under directory /dependency/apache-tomcat-6.0.26/webapps/examples/WEB-INF/classes/compressionFilters/.
Source file: CompressionServletResponseWrapper.java
/**
* Create and return a ServletOutputStream to write the content associated with this Response.
* @exception IOException if an input/output error occurs
*/
public ServletOutputStream createOutputStream() throws IOException {
if (debug > 1) {
System.out.println("createOutputStream gets called");
}
CompressionResponseStream stream=new CompressionResponseStream(origResponse);
stream.setDebugLevel(debug);
stream.setBuffer(threshold);
return stream;
}
Example 98
From project rollyourowncbf, under directory /apache-tomcat-6.0.32/webapps/examples/WEB-INF/classes/compressionFilters/.
Source file: CompressionServletResponseWrapper.java
/**
* Create and return a ServletOutputStream to write the content associated with this Response.
* @exception IOException if an input/output error occurs
*/
public ServletOutputStream createOutputStream() throws IOException {
if (debug > 1) {
System.out.println("createOutputStream gets called");
}
CompressionResponseStream stream=new CompressionResponseStream(origResponse);
stream.setDebugLevel(debug);
stream.setBuffer(threshold);
return stream;
}
Example 99
From project sandbox, under directory /xwiki-portlet/src/main/java/org/xwiki/portlet/controller/.
Source file: DispatchedMimeResponse.java
@Override public ServletOutputStream getOutputStream() throws IOException {
if (isOutputIntercepted()) {
if (writerWrapper == null) {
if (outputStreamWrapper == null) {
outputStreamWrapper=new ByteArrayServletOutputStream();
}
return outputStreamWrapper;
}
else {
throw new IllegalStateException();
}
}
else {
outputPreserved=true;
return super.getOutputStream();
}
}
Example 100
From project seamless, under directory /mock/src/main/java/org/seamless/mock/http/.
Source file: MockHttpServletResponse.java
public ServletOutputStream getOutputStream(){
if (!this.outputStreamAccessAllowed) {
throw new IllegalStateException("OutputStream access not allowed");
}
return this.outputStream;
}
Example 101
From project sparqled, under directory /recommendation-servlet/src/main/java/org/sindice/analytics/servlet/.
Source file: BufferedHttpResponseWrapper.java
public ServletOutputStream getOutputStream() throws IOException {
if (this.printWriter != null) {
throw new IllegalStateException("The Servlet API forbids calling getOutputStream( ) after" + " getWriter( ) has been called");
}
if (this.outputStream == null) {
this.outputStream=this.bufferedServletOut;
}
return this.outputStream;
}
