/*
    * Copyright (c) 2005, The K-Wf Grid Consortium
    * Fraunhofer Institute for Computer Architecture and Software Technology
    * See http://www.kwfgrid.eu and http://www.first.fraunhofer.de for more details.
    */
   package net.kwfgrid.gwes.uiproxy;
   
   import java.util.*;
   
  /**
     Abstract implementation of buffer. 
     This buffer supports the following properties:
     <ul>
     <li>Buffer.size</li>
     </ul>
   */
  public abstract class AbstractBuffer implements Buffer {
      public static final int DEFAULT_SIZE = 100;
      public static final String SIZE_PROPERTY_KEY = "Buffer.size";
  
      protected int _size;
      protected String _id;
  
      public AbstractBuffer() {
  	_id = null;
  	_size = DEFAULT_SIZE;
      }
      
      protected void setID(String id) {
  	_id = id;
      }
  
      public String getID() {
  	return _id;
      }
      
      /**
         Size should be set by setting property <code>Buffer.size</code>.
       */
      protected void setSize(int size) throws BufferException {
  	_size = size;
      }
  
      public int getSize() {
  	return _size;
      }
  
      /**
         Generic implementation. Calls <code>setProperty(key, value)</code> for each mapping in the 
         specified properties.
       */
      public void setProperties(Properties props) throws BufferException {
  	Iterator keys = props.keySet().iterator(); while (keys.hasNext()) {
  	    String key = keys.next().toString();
  	    setProperty(key, props.getProperty(key));
  	}
      }
      
      /**
         This implementation only interprets the <code>Buffer.size</code> property.
       */
      public void setProperty(String key, String value) throws BufferException {
  	if (SIZE_PROPERTY_KEY.equals(key)) {
  	    try {
  		int size = Integer.parseInt(value);
  		setSize(size);
  	    } catch (NumberFormatException x) {
  		// LOG
  		// discard
  	    }
  	}
      }
      
      public abstract void handle(Object message);
      
      public abstract Object[] read() throws BufferException;
  }