Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.jacorb.notification.servant;
  
  /*
   *        JacORB - a free Java ORB
   *
   *   Copyright (C) 1997-2012 Gerald Brose / The JacORB Team.
   *
   *   This library is free software; you can redistribute it and/or
   *   modify it under the terms of the GNU Library General Public
  *   License as published by the Free Software Foundation; either
  *   version 2 of the License, or (at your option) any later version.
  *
  *   This library 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
  *   Library General Public License for more details.
  *
  *   You should have received a copy of the GNU Library General Public
  *   License along with this library; if not, write to the Free
  *   Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  */
 

Author(s):
Alphonse Bendt
Jmx.mbean:
extends = "AbstractProxyPushSupplierMBean"
Jboss.xmbean:
 
 
 public class ProxyPushSupplierImpl extends AbstractProxyPushSupplier implements
 {
     private class PushAnyOperation extends MessagePushOperation 
     {
         public PushAnyOperation(Message message) {
             super(message);
         }
 
         public void invokePush() throws Disconnected {
             deliverMessageInternal(message_);
         }
     }
     
     private PushConsumer pushConsumer_;
     
     private long timeSpent_;
 
     // //////////////////////////////////////
 
     public ProxyPushSupplierImpl(IAdmin adminORB orbPOA poaConfiguration conf,
             TaskProcessor taskProcessorPushTaskExecutorFactory pushTaskExecutorFactoryOfferManager offerManager,
             SubscriptionManager subscriptionManagerConsumerAdmin consumerAdmin)
             throws ConfigurationException
     {
         super(adminorbpoaconftaskProcessorpushTaskExecutorFactoryofferManager,
                 subscriptionManagerconsumerAdmin);
     }
 
     public ProxyType MyType()
     {
         return .;
     }
 
     public void disconnect_push_supplier()
     {
         destroy();
     }
 
     protected void disconnectClient()
     {
 
          = null;
     }
 
     private boolean deliverMessageWithRetry(final Message message)
     {
         try
         {
             deliverMessageInternal(message);
             
            return true;
        } catch (Exception e)
        {
            final PushAnyOperation _failedOperation = new PushAnyOperation(message);
            handleFailedPushOperation(_failedOperatione);
            
            return false;
        }
    }
    private void deliverMessageInternal(final Message messagethrows Disconnected
    {
        long now = System.currentTimeMillis();
        .push(message.toAny());
         += (System.currentTimeMillis() - now);
        resetErrorCounter();
    }
    public boolean pushEvent()
    {
        final Message _message = getMessageNoBlock();
        if (_message != null)
        {
            try
            {
                return deliverMessageWithRetry(_message);
            } finally
            {
                _message.dispose();
            }
        }
        return false;
    }
    
    public void connect_any_push_consumer(PushConsumer pushConsumerthrows AlreadyConnected
    {
        checkIsNotConnected();
         = pushConsumer;
        connectClient(pushConsumer);
    }
    protected void connectionResumed()
    {
        scheduleFlush();
    }
    public Servant newServant()
    {
        return new ProxyPushSupplierPOATie(this);
    }
    public long getCost()
    {
        return ;
    }
New to GrepCode? Check out our FAQ X