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
public abstract class AbstractProxySupplier
extends AbstractProxy
implements MessageConsumer, NotifySubscribeOperations
Field Summary | |
protected Runnable |
|
Fields inherited from class org.jacorb.notification.servant.AbstractProxy | |
admin_ , channelContext_ , id_ , isIDPublic_ , lifetimeFilter_ , logger_ , offerManager_ , priorityFilter_ , qosSettings_ , subscriptionManager_ , thisServant_ |
Constructor Summary | |
|
Method Summary | |
ConsumerAdmin |
|
void |
|
protected void |
|
void | |
void |
|
void | |
protected void | |
protected Message[] | |
protected Message[] |
|
int | |
TaskExecutor | |
protected Message | |
protected Message | |
int | |
protected Message[] |
|
protected void |
|
boolean | |
protected boolean | |
boolean | |
EventType[] |
|
void | |
void |
|
void |
|
void |
|
protected Runnable scheduleDeliverPendingMessagesOperation_
Check if there are pending Messages and deliver them to the Consumer. the operation is not executed immediately. instead it is scheduled to the Push Thread Pool. only initialized for ProxyPushSuppliers.
protected AbstractProxySupplier(AbstractAdmin admin, ChannelContext channelContext)
protected void connectClient(Object client)
- Overrides:
- connectClient in interface AbstractProxy
public void disableDelivery()
- Specified by:
- disableDelivery in interface MessageConsumer
public final void dispose()
- Specified by:
- dispose in interface Disposable
- Overrides:
- dispose in interface AbstractProxy
protected void enqueue(Message message)
put a Message in the queue of pending Messages.
- Parameters:
message
- theMessage
to queue.
public int getErrorThreshold()
- Specified by:
- getErrorThreshold in interface MessageConsumer
public int getPendingMessagesCount()
protected void handleFailedPushOperation(PushOperation operation, Throwable error)
public boolean hasPendingData()
- Specified by:
- hasPendingData in interface MessageConsumer
protected boolean isEnabled()
public boolean isPushSupplier()
public void preActivate() throws UnsupportedQoS
- Specified by:
- preActivate in interface ManageableServant
- Overrides:
- preActivate in interface AbstractProxy
public final void subscription_change(EventType added, EventType removed) throws InvalidEventType