1 package org.jacorb.notification.servant; 2 3 22 23 import org.apache.avalon.framework.configuration.Configuration; 24 import org.apache.avalon.framework.configuration.ConfigurationException; 25 import org.jacorb.notification.OfferManager; 26 import org.jacorb.notification.SubscriptionManager; 27 import org.jacorb.notification.engine.TaskProcessor; 28 import org.omg.CORBA.ORB ; 29 import org.omg.CosEventChannelAdmin.AlreadyConnected; 30 import org.omg.CosEventChannelAdmin.ProxyPullSupplierHelper; 31 import org.omg.CosEventChannelAdmin.ProxyPullSupplierOperations; 32 import org.omg.CosEventChannelAdmin.ProxyPullSupplierPOATie; 33 import org.omg.CosEventComm.PullConsumer; 34 import org.omg.CosNotifyChannelAdmin.ConsumerAdmin; 35 import org.omg.PortableServer.POA ; 36 import org.omg.PortableServer.Servant ; 37 38 42 43 public class ECProxyPullSupplierImpl extends ProxyPullSupplierImpl implements 44 ProxyPullSupplierOperations 45 { 46 private static final ConsumerAdmin NO_ADMIN = null; 47 48 public ECProxyPullSupplierImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, 49 TaskProcessor taskProcessor) throws ConfigurationException 50 { 51 super(admin, orb, poa, conf, taskProcessor, OfferManager.NULL_MANAGER, SubscriptionManager.NULL_MANAGER, NO_ADMIN); 52 } 53 54 public void connect_pull_consumer(PullConsumer pullConsumer) throws AlreadyConnected 55 { 56 connect_any_pull_consumer(pullConsumer); 57 } 58 59 public synchronized Servant getServant() 60 { 61 if (thisServant_ == null) 62 { 63 thisServant_ = new ProxyPullSupplierPOATie(this); 64 } 65 return thisServant_; 66 } 67 68 public org.omg.CORBA.Object activate() 69 { 70 return ProxyPullSupplierHelper.narrow(getServant()._this_object(getORB())); 71 } 72 } | Popular Tags |