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 = "AbstractProxyConsumerMBean"
Jboss.xmbean:
 
 
 public class ProxyPushConsumerImpl extends AbstractProxyConsumer implements
 {
     private PushSupplier pushSupplier_;
 
     ////////////////////////////////////////
 
     public ProxyPushConsumerImpl(IAdmin adminORB orbPOA poaConfiguration conf,
             TaskProcessor taskProcessorMessageFactory messageFactory,
             SupplierAdmin supplierAdminOfferManager offerManager,
             SubscriptionManager subscriptionManager)
     {
         super(adminorbpoaconftaskProcessormessageFactorysupplierAdminofferManager,
                 subscriptionManager);
     }
 
     public ProxyType MyType()
     {
         return .;
     }
 
     public void disconnect_push_consumer()
     {
         destroy();
     }
 
     protected void disconnectClient()
     {
         if ( != null)
         {
             .disconnect_push_supplier();
              = null;
         }
     }

    
Supplier sends data to the consumer (this object) using this call.
 
     public void push(Any eventthrows Disconnected
     {
         checkStillConnected();
 
         .debug("push Any into the Channel");
 
         Message _mesg = getMessageFactory().newMessage(eventthis);
 
         checkMessageProperties(_mesg);
 
         processMessage(_mesg);
     }
 
     public void connect_any_push_supplier(org.omg.CosEventComm.PushSupplier pushSupplier)
            throws AlreadyConnected
    {
        .info("connect any_push_supplier");
        checkIsNotConnected();
         = pushSupplier;
        connectClient(pushSupplier);
    }
    public Servant newServant()
    {
        return new ProxyPushConsumerPOATie(this);
    }
New to GrepCode? Check out our FAQ X