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.PushTaskExecutorFactory; 28 import org.jacorb.notification.engine.TaskProcessor; 29 import org.omg.CORBA.ORB ; 30 import org.omg.CosEventChannelAdmin.AlreadyConnected; 31 import org.omg.CosEventChannelAdmin.ProxyPushSupplierHelper; 32 import org.omg.CosEventChannelAdmin.ProxyPushSupplierOperations; 33 import org.omg.CosEventChannelAdmin.ProxyPushSupplierPOATie; 34 import org.omg.CosEventComm.PushConsumer; 35 import org.omg.CosNotifyChannelAdmin.ConsumerAdmin; 36 import org.omg.PortableServer.POA ; 37 import org.omg.PortableServer.Servant ; 38 39 43 public class ECProxyPushSupplierImpl extends ProxyPushSupplierImpl implements 44 ProxyPushSupplierOperations 45 { 46 private static final ConsumerAdmin NO_ADMIN = null; 47 48 public ECProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, 49 TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory) throws ConfigurationException 50 { 51 super(admin, orb, poa, conf, taskProcessor, pushTaskExecutorFactory, OfferManager.NULL_MANAGER, SubscriptionManager.NULL_MANAGER, NO_ADMIN); 52 } 53 54 56 public void connect_push_consumer(PushConsumer pushConsumer) throws AlreadyConnected 57 { 58 connect_any_push_consumer(pushConsumer); 59 } 60 61 public synchronized Servant getServant() 62 { 63 if (thisServant_ == null) 64 { 65 thisServant_ = new ProxyPushSupplierPOATie(this); 66 } 67 return thisServant_; 68 } 69 70 public org.omg.CORBA.Object activate() 71 { 72 return ProxyPushSupplierHelper.narrow(getServant()._this_object(getORB())); 73 } 74 } | Popular Tags |