Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source
   * Copyright 2010 Red Hat Inc. and/or its affiliates and other
   * contributors as indicated by the @author tags. All rights reserved.
   * See the copyright.txt 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.infinispan.websocket;
 
 
 import  org.json.JSONException;
 import  org.json.JSONObject;

Author(s):
tom.fennelly@gmail.com
 
 public class MockChannel implements Channel {
 
 	private StringWriter writer = new StringWriter();
 
 	/* (non-Javadoc)
 	 * @see org.jboss.netty.channel.Channel#getConfig()
 	 */
 	public ChannelConfig getConfig() {
 		return null;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.jboss.netty.channel.Channel#getLocalAddress()
 	 */
 		return null;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.jboss.netty.channel.Channel#getRemoteAddress()
 	 */
 		return null;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.jboss.netty.channel.Channel#isBound()
 	 */
 	public boolean isBound() {
 		return true;
 	}
 
 	/* (non-Javadoc)
 	 * @see org.jboss.netty.channel.Channel#isConnected()
 	 */
 	public boolean isConnected() {
 		return false;
 	}
 
 
 
    public Object getAttachment() {
       return null;
    }
 
    @Override
    public void setAttachment(Object attachment) {
    }
 
   /* (non-Javadoc)
	 * @see org.jboss.netty.channel.AbstractChannel#write(java.lang.Object)
	 */
	public ChannelFuture write(Object message) {
		if(message instanceof TextWebSocketFrame) {
else {
			throw new IllegalStateException("Expected a TextWebSocketFrame but got " + message);
		}
		return null;
	}
	public JSONObject getJSONPayload() {
		if(.getBuffer().length() == 0) {
			return null;
		}
		return getJSONPayload(0);
	}
	public JSONObject getJSONPayload(long waitTimeout) {
		long start = System.currentTimeMillis();
		while(.getBuffer().length() == 0) {
			if(System.currentTimeMillis() > start + waitTimeout) {
				throw new RuntimeException("Timed out waiting for data to be pushed onto the channel.");
			}
		}
		try {
			return new JSONObject(.toString());
catch (JSONException e) {
			throw new RuntimeException("Invalid JSON payload [" + .toString() + "]."e);
finally {
		}
	}
	public void clear() {
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#bind(java.net.SocketAddress)
	 */
	public ChannelFuture bind(SocketAddress arg0) {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#close()
	 */
	public ChannelFuture close() {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#connect(java.net.SocketAddress)
	 */
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#disconnect()
	 */
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getCloseFuture()
	 */
                new Class[] { ChannelFuture.class },
                new InvocationHandler() {
               public Object invoke(Object proxyMethod method,Object[] argsthrows Throwable {
						return null;
					}
		});
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getFactory()
	 */
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getId()
	 */
	public Integer getId() {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getInterestOps()
	 */
	public int getInterestOps() {
		return 0;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getParent()
	 */
	public Channel getParent() {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#getPipeline()
	 */
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#isOpen()
	 */
	public boolean isOpen() {
		return true;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#isReadable()
	 */
	public boolean isReadable() {
		return false;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#isWritable()
	 */
	public boolean isWritable() {
		return false;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#setInterestOps(int)
	 */
	public ChannelFuture setInterestOps(int arg0) {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#setReadable(boolean)
	 */
	public ChannelFuture setReadable(boolean arg0) {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#unbind()
	 */
	public ChannelFuture unbind() {
		return null;
	}
	/* (non-Javadoc)
	 * @see org.jboss.netty.channel.Channel#write(java.lang.Object, java.net.SocketAddress)
	 */
	public ChannelFuture write(Object arg0SocketAddress arg1) {
		return null;
	}
	/* (non-Javadoc)
	 * @see java.lang.Comparable#compareTo(java.lang.Object)
	 */
	public int compareTo(Channel o) {
		return 0;
	}
New to GrepCode? Check out our FAQ X