Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
http://code.google.com/a/apache-extras.org/p/camel-extra This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program 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 General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. http://www.gnu.org/licenses/gpl-2.0-standalone.html /
 
 package org.apacheextras.camel.component.esper;
 
 

Version:
$Revision: 1.1 $
 
 public class EsperPollingConsumer extends PollingConsumerSupport implements UpdateListener {
     private EsperEndpoint endpoint;
     private EPStatement statement;
 
     public EsperPollingConsumer(EsperEndpoint endpointEPStatement statement) {
         super(endpoint);
         this. = endpoint;
         this. = statement;
     }
 
     protected void doStart() throws Exception {
         .addListener(this);
     }
 
     protected void doStop() throws Exception {
         .removeListener(this);
         .removeConsumer();
     }
 
     public void update(EventBean[] arg0EventBean[] arg1) {
         for (EventBean bean : arg0) {
             try {
                 // put the new events to the forwarding queue
                 .put(bean);
             } catch (InterruptedException e) {
                 return;
             }
         }
     }
 
     public Exchange receive() {
         EventBean bean;
         try {
             bean = .take();
         } catch (InterruptedException e) {
             return null;
         }
         if (bean == null) {
             return null;
         }
         return .createExchange(beannull);
     }
 
     public Exchange receiveNoWait() {
         EventBean bean = .poll();
         if (bean == null) {
             return null;
         }
         return .createExchange(beannull);
     }
 
     public Exchange receive(long timeout) {
         EventBean bean;
         try {
             bean = .poll(timeout.);
         } catch (InterruptedException e) {
             return null;
         }
         if (bean == null) {
             return null;
         }
         return .createExchange(beannull);
     }
    
New to GrepCode? Check out our FAQ X