001         package com.croftsoft.core.util.consumer;
002    
003         import com.croftsoft.core.lang.NullArgumentException;
004         import com.croftsoft.core.util.queue.Queue;
005    
006         /*********************************************************************
007         * A Consumer that appends objects to a Queue.
008         *
009         * @version
010         *   2003-06-10
011         * @since
012         *   2003-06-10
013         * @author
014         *   <a href="https://www.croftsoft.com/">David Wallace Croft</a>
015         *********************************************************************/
016    
017         public final class  QueueConsumer
018           implements Consumer
019         //////////////////////////////////////////////////////////////////////
020         //////////////////////////////////////////////////////////////////////
021         {
022    
023         private final Queue  queue;
024    
025         //////////////////////////////////////////////////////////////////////
026         //////////////////////////////////////////////////////////////////////
027    
028         public  QueueConsumer ( Queue  queue )
029         //////////////////////////////////////////////////////////////////////
030         {
031           NullArgumentException.check ( this.queue = queue );
032         }
033    
034         //////////////////////////////////////////////////////////////////////
035         //////////////////////////////////////////////////////////////////////
036    
037         public void  consume ( Object  o )
038         //////////////////////////////////////////////////////////////////////
039         {
040           queue.append ( o );
041         }
042    
043         //////////////////////////////////////////////////////////////////////
044         //////////////////////////////////////////////////////////////////////
045         }