Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source.
   * Copyright 2006, Red Hat Middleware LLC, and individual contributors
   * as indicated by the @author tags. See the copyright.txt file in the
   * distribution for a full listing of individual contributors.
   *
   * This is free software; you can redistribute it and/or modify it
   * under the terms of the GNU Lesser General Public License as
   * published by the Free Software Foundation; either version 2.1 of
  * the License, or (at your option) any later version.
  *
  * This software is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  * Lesser General Public License for more details.
  *
  * You should have received a copy of the GNU Lesser General Public
  * License along with this software; if not, write to the Free
  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  */
 package org.jboss.wsf.stack.metro;
 
 
 import java.util.Map;

Author(s):
Heiko Braun
 
 {
    {
       public MessageStreamAdapter createAdapter(String nameString urlPatternWSEndpoint<?> endpoint)
       {         
          return new MessageStreamAdapter(endpoint);
       }
    };
    
    public MessageStreamAdapter(WSEndpoint endpoint)
    {
       super(endpoint);
    }
 
    public void handle(MessageStreamContext contextInputStream inOutputStream out)
    throws IOException
    {
       MessageStreamConnectionImpl connection = new MessageStreamConnectionImpl(contextinout);
 
       StreamToolkit tk = .take();
       try
       {
          tk.handle(connection);
          connection.flush();
       }
       finally
       {
          .recycle(tk);
          connection.close();
       }
    }
 
    protected StreamToolkit createToolkit()
    {
       return new StreamToolkit();
    }
 
    class StreamToolkit extends Adapter.Toolkit implements TransportBackChannel
    {
       private MessageStreamConnectionImpl connection;
 
       private void handle(MessageStreamConnectionImpl connection)
       throws IOException
       {
          this. = connection;
          
          String contentTypeStr = connection.getRequestHeader(.);
          InputStream in = connection.getInputStream();
          Packet packet = new Packet();
          .decode(incontentTypeStrpacket);
 
          try
          {
             packet = .process(packetconnectionthis);
          }
          catch(Exception e)
          {
             e.printStackTrace();
             connection.setStatus(.);
             return;
         }
         contentTypeStr = .getStaticContentType(packet).getContentType();
         if (contentTypeStr == null)
         {
            throw new UnsupportedOperationException();
         }
         else
         {
            Map<StringStringheaders = new HashMap();
            headers.put(.contentTypeStr);
            connection.setResponseHeaders(headers);
            .encode(packetconnection.getOutputStream());
         }
      }
      public void close()
      {         
         .close();
      }
   }
New to GrepCode? Check out our FAQ X