Prev Class | Next Class | Frames | No Frames |
Summary: Nested | Field | Method | Constr | Detail: Nested | Field | Method | Constr |
java.lang.Object
org.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
org.jacorb.notification.servant.StructuredProxyPushSupplierImpl
public class StructuredProxyPushSupplierImpl
extends AbstractProxySupplier
implements StructuredProxyPushSupplierOperations
Field Summary |
Fields inherited from class org.jacorb.notification.servant.AbstractProxySupplier | |
scheduleDeliverPendingMessagesOperation_ |
Fields inherited from class org.jacorb.notification.servant.AbstractProxy | |
admin_ , channelContext_ , id_ , isIDPublic_ , lifetimeFilter_ , logger_ , offerManager_ , priorityFilter_ , qosSettings_ , subscriptionManager_ , thisServant_ |
Constructor Summary | |
|
Method Summary | |
ProxyType |
|
Object |
|
void | |
protected void | |
void |
|
void |
|
protected void | |
void | |
MessageConsumer | |
Servant | |
List | |
boolean |
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier | |
MyAdmin , configure , connectClient , disableDelivery , dispose , enableDelivery , enqueue , getAllMessages , getAtLeastMessages , getErrorThreshold , getExecutor , getMessageBlocking , getMessageNoBlock , getPendingMessagesCount , getUpToMessages , handleFailedPushOperation , hasPendingData , isEnabled , isPushSupplier , obtain_offered_types , preActivate , setTaskExecutor , setTaskExecutor , subscription_change |
public StructuredProxyPushSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)
public ProxyType MyType()
- Specified by:
- MyType in interface ProxySupplierOperations
- Overrides:
- MyType in interface AbstractProxy
public void connect_structured_push_consumer(StructuredPushConsumer consumer) throws AlreadyConnected
- Specified by:
- connect_structured_push_consumer in interface StructuredProxyPushSupplierOperations
protected void connectionResumed()
- Overrides:
- connectionResumed in interface AbstractProxy
public void deliverMessage(Message message)
TODO check error handling when push fails
- Specified by:
- deliverMessage in interface MessageConsumer
public void deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
- Specified by:
- deliverPendingData in interface MessageConsumer
protected void disconnectClient()
- Overrides:
- disconnectClient in interface AbstractProxy
public void disconnect_structured_push_supplier()
- Specified by:
- disconnect_structured_push_supplier in interface StructuredPushSupplierOperations
public MessageConsumer getMessageConsumer()
- Specified by:
- getMessageConsumer in interface FilterStage
public List getSubsequentFilterStages()
- Specified by:
- getSubsequentFilterStages in interface FilterStage
public boolean hasMessageConsumer()
- Specified by:
- hasMessageConsumer in interface FilterStage