1 package org.jacorb.notification.servant; 2 3 22 23 import org.apache.avalon.framework.configuration.Configuration; 24 import org.jacorb.notification.MessageFactory; 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.ProxyPullConsumerHelper; 31 import org.omg.CosEventChannelAdmin.ProxyPullConsumerOperations; 32 import org.omg.CosEventChannelAdmin.ProxyPullConsumerPOATie; 33 import org.omg.CosEventComm.PullSupplier; 34 import org.omg.PortableServer.POA ; 35 import org.omg.PortableServer.Servant ; 36 37 41 42 public class ECProxyPullConsumerImpl extends ProxyPullConsumerImpl implements 43 ProxyPullConsumerOperations 44 { 45 public ECProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, 46 TaskProcessor taskProcessor, MessageFactory messageFactory) 47 { 48 super(admin, orb, poa, conf, taskProcessor, messageFactory, OfferManager.NULL_MANAGER, 49 SubscriptionManager.NULL_MANAGER); 50 } 51 52 public void connect_pull_supplier(PullSupplier pullSupplier) throws AlreadyConnected 53 { 54 connect_any_pull_supplier(pullSupplier); 55 } 56 57 public synchronized Servant getServant() 58 { 59 if (thisServant_ == null) 60 { 61 thisServant_ = new ProxyPullConsumerPOATie(this); 62 } 63 64 return thisServant_; 65 } 66 67 public org.omg.CORBA.Object activate() 68 { 69 return ProxyPullConsumerHelper.narrow(getServant()._this_object(getORB())); 70 } 71 72 } | Popular Tags |