|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
Abstract base class for ProxySuppliers. This class provides following logic for the different ProxySuppliers:
Field Summary | |
protected java.lang.Runnable |
scheduleDeliverPendingMessagesOperation_
Check if there are pending Messages and deliver them to the Consumer. |
Fields inherited from class org.jacorb.notification.servant.AbstractProxy |
admin_, channelContext_, id_, isIDPublic_, lifetimeFilter_, logger_, offerManager_, priorityFilter_, qosSettings_, subscriptionManager_, thisServant_ |
Constructor Summary | |
protected |
AbstractProxySupplier(AbstractAdmin admin,
ChannelContext channelContext)
|
Method Summary | |
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
protected void |
connectClient(Object client)
|
void |
disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead. |
void |
dispose()
Dispose this Object. |
void |
enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again. |
protected void |
enqueue(Message message)
put a Message in the queue of pending Messages. |
protected Message[] |
getAllMessages()
|
protected Message[] |
getAtLeastMessages(int min)
|
int |
getErrorThreshold()
access the error threshold for this MessageConsumer. if the error count exeeds the threshold the MessageConsumer will be disconnected. |
TaskExecutor |
getExecutor()
|
protected Message |
getMessageBlocking()
|
protected Message |
getMessageNoBlock()
|
int |
getPendingMessagesCount()
|
protected Message[] |
getUpToMessages(int max)
|
protected void |
handleFailedPushOperation(PushOperation operation,
java.lang.Throwable error)
|
boolean |
hasPendingData()
check if this MessageConsumer has pending work to do. pending work is to push events to its connected (Push)Consumer. |
protected boolean |
isEnabled()
|
boolean |
isPushSupplier()
|
ConsumerAdmin |
MyAdmin()
|
EventType[] |
obtain_offered_types(ObtainInfoMode obtainInfoMode)
|
void |
preActivate()
|
void |
setTaskExecutor(TaskExecutor executor)
|
void |
setTaskExecutor(TaskExecutor executor,
Disposable disposeTaskExecutor)
|
void |
subscription_change(EventType[] added,
EventType[] removed)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jacorb.notification.interfaces.MessageConsumer |
deliverMessage, deliverPendingData, getErrorCounter, incErrorCounter, isDisposed, resetErrorCounter |
Methods inherited from interface org.jacorb.notification.interfaces.FilterStage |
getMessageConsumer, getSubsequentFilterStages, hasMessageConsumer |
Methods inherited from interface org.jacorb.notification.servant.ManageableServant |
activate |
Field Detail |
protected java.lang.Runnable scheduleDeliverPendingMessagesOperation_
Constructor Detail |
protected AbstractProxySupplier(AbstractAdmin admin, ChannelContext channelContext)
Method Detail |
public void configure(org.apache.avalon.framework.configuration.Configuration conf)
configure
in interface org.apache.avalon.framework.configuration.Configurable
configure
in class AbstractProxy
public void preActivate() throws UnsupportedQoS
preActivate
in interface ManageableServant
preActivate
in class AbstractProxy
UnsupportedQoS
public TaskExecutor getExecutor()
getExecutor
in interface MessageConsumer
TaskExecutor
that should be used to
push Messages to the connected Consumer.public void setTaskExecutor(TaskExecutor executor)
public void setTaskExecutor(TaskExecutor executor, Disposable disposeTaskExecutor)
public int getPendingMessagesCount()
public boolean hasPendingData()
MessageConsumer
hasPendingData
in interface MessageConsumer
protected void enqueue(Message message)
message
- the Message
to queue.protected Message getMessageBlocking() throws java.lang.InterruptedException
java.lang.InterruptedException
protected Message getMessageNoBlock()
protected Message[] getAllMessages()
protected Message[] getUpToMessages(int max)
protected Message[] getAtLeastMessages(int min)
public int getErrorThreshold()
MessageConsumer
getErrorThreshold
in interface MessageConsumer
public final void dispose()
Disposable
dispose
in interface Disposable
dispose
in class AbstractProxy
public final ConsumerAdmin MyAdmin()
public final void subscription_change(EventType[] added, EventType[] removed) throws InvalidEventType
subscription_change
in interface NotifySubscribeOperations
InvalidEventType
public final EventType[] obtain_offered_types(ObtainInfoMode obtainInfoMode)
protected void connectClient(Object client)
connectClient
in class AbstractProxy
public void enableDelivery()
MessageConsumer
enableDelivery
in interface MessageConsumer
public void disableDelivery()
MessageConsumer
disableDelivery
in interface MessageConsumer
protected boolean isEnabled()
public boolean isPushSupplier()
protected void handleFailedPushOperation(PushOperation operation, java.lang.Throwable error)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |