Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * 
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
   * 
   * Copyright 2007-2008 Sun Microsystems, Inc. All rights reserved.
   * 
   * The contents of this file are subject to the terms of either the GNU
   * General Public License Version 2 only ("GPL") or the Common Development
   * and Distribution License("CDDL") (collectively, the "License").  You
  * may not use this file except in compliance with the License. You can obtain
  * a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html
  * or glassfish/bootstrap/legal/LICENSE.txt.  See the License for the specific
  * language governing permissions and limitations under the License.
  * 
  * When distributing the software, include this License Header Notice in each
  * file and include the License file at glassfish/bootstrap/legal/LICENSE.txt.
  * Sun designates this particular file as subject to the "Classpath" exception
  * as provided by Sun in the GPL Version 2 section of the License file that
  * accompanied this code.  If applicable, add the following below the License
  * Header, with the fields enclosed by brackets [] replaced by your own
  * identifying information: "Portions Copyrighted [year]
  * [name of copyright owner]"
  * 
  * Contributor(s):
  * 
  * If you wish your version of this file to be governed by only the CDDL or
  * only the GPL Version 2, indicate your decision by adding "[Contributor]
  * elects to include this software in this distribution under the [CDDL or GPL
  * Version 2] license."  If you don't indicate a single choice of license, a
  * recipient has the option to distribute your version of this file under
  * either the CDDL, the GPL Version 2 or to extend the choice of license to
  * its licensees as provided above.  However, if you add GPL Version 2 code
  * and therefore, elected the GPL Version 2 license, then the option applies
  * only if the new code is made subject to such option by the copyright
  * holder.
  *
  */
 package com.sun.grizzly.cometd;
 
 import java.util.List;
CometHandler used to support the meta channel Verb Connect and Reconnect. The DataHandler is holding the state of the long polled (Comet) connection.

Author(s):
Jeanfrancois Arcand
TAKAI, Naoto
 
 public class DataHandler implements CometHandler<Object[]>{
     
     private final static Logger logger = SelectorThread.logger();
     
     private CometdRequest req;    
     
     private CometdResponse res
    
     private String clientId;
    
     private Collection<Stringchannels = new ConcurrentLinkedQueue<String>();
 
     private Collection<StringunmodifiableChannels = null;
     
 
     private boolean wasLast = false;
 
     
     public DataHandler(BayeuxCometHandler bayeuxCometHandler){
         this. = bayeuxCometHandler;
     }
     
     
     private void writeEnd() throws IOException {
         if (!) {
              = true;
             .write("]*/");
             .flush();
         }
     }
 
 
     public void attach(Object[] reqRes){
         this. = (CometdRequestreqRes[0];
        this. = (CometdResponsereqRes[1];
         = false;
    }
            
        
    @SuppressWarnings("unchecked")
    public synchronized void onEvent(CometEvent eventthrows IOException
        Object obj = event.attachment();      
        try{                   
            if ("NOTIFY_END".equals(obj)) {
                CometContext cometContext = event.getCometContext();
                if (cometContext.isActive(this)) {
                    writeEnd();
                    cometContext.resumeCometHandler(this);
                }
                return;
            } else if (obj instanceof DeliverResponse){
                DeliverResponse deliverRes = (DeliverResponse)obj;
                String deliverResClientId = deliverRes.getClientId();
                if ((deliverResClientId != null &&
                    deliverResClientId.equals(getClientId()) ||
                    deliverResClientId == null && getClientId() == null)) { 
                    return;
                }
                
                 = deliverRes.isLast();
                .write(deliverRes.toJSON());
                .flush();
            }
        }  catch (Throwable t){
           .log(.,"Data.onEvent",t);
        } 
        
        if (event.getType()  == .){
            CometInputStream is = (CometInputStream)obj;
            
            // XXX This is dangerous...
            byte[] dataStream = new byte[2 * 8192];
            is.setReadTimeout(2000);
            while (is.read(dataStream) > 0){
            }
            String sdata = new String(dataStream).trim();
            
            if (sdata.length() <=1) return;  
            
            try{
                List<Verbverbs = 
                        VerbUtils.parseRequest(JSONParser.parse(sdata));                
                // Notify our listener;
                CometContext cometContext = event.getCometContext();
                for (Verb verb : verbs) {
                    cometContext.notify(
                        BayeuxCometHandler.newCometdContext(,,verb),
                        .,
                        (Integer)cometContext.getAttribute(
                            .));
                }
                event.getCometContext().removeAttribute(this);
            } catch (Throwable t){
                .log(.,"Data.onEvent",t);
            }
        }            
    }
    
    public void onInitialize(CometEvent eventthrows IOException{  
    }
    public void onTerminate(CometEvent eventthrows IOException{
        writeEnd();
    }
    public void onInterrupt(CometEvent eventthrows IOException{       
    }
    public synchronized Collection<StringgetChannels() {
        if ( == null) {
             = Collections.unmodifiableCollection();
        }
        return ;
    }
    public synchronized void addChannel(String channel) {
        if (.contains(channel)) {
            throw new IllegalArgumentException(channel);
        }
         = null;
        .add(channel);
    }
    public synchronized boolean removeChannel(String channel) {
         = null;
        return .remove(channel);
    }
    public String getClientId() {
        return ;
    }
    public void setClientId(String clientId) {
        this. = clientId;
    }
New to GrepCode? Check out our FAQ X