|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.jboss.messaging.core.plugin.postoffice.cluster.RemoteQueueStub
A RemoteQueueStub TODO to avoid having to implement a lot of methods that throw UnsupportedOperationException should define an interface that only declares the required methods and implement that
| Constructor Summary | |
RemoteQueueStub(int nodeId,
java.lang.String name,
long id,
boolean recoverable,
PersistenceManager pm,
Filter filter)
|
|
| Method Summary | |
boolean |
acceptReliableMessages()
A non-recoverable channel cannot guarantee recoverability for reliable messages so by default it won't accept reliable messages. |
void |
acknowledge(Delivery d,
Transaction tx)
|
void |
activate()
|
boolean |
add(Receiver receiver)
Add a local receiver to this distributor. |
java.util.List |
browse()
|
java.util.List |
browse(Filter filter)
|
void |
cancel(Delivery d)
|
void |
clear()
Clears non-recoverable state but not persisted state, so a recovery of the channel is possible TODO really? |
void |
close()
Close the channel |
boolean |
contains(Receiver receiver)
|
void |
deactivate()
|
void |
deliver()
Delivers as many references as possible to its router until no more deliveries are returned. |
java.util.List |
delivering(Filter filter)
|
long |
getChannelID()
|
int |
getDeliveringCount()
|
Filter |
getFilter()
|
int |
getMaxSize()
|
int |
getMessageCount()
|
int |
getMessagesAdded()
|
java.lang.String |
getName()
|
int |
getNodeId()
|
int |
getNumberOfReceivers()
|
int |
getScheduledCount()
Count scheduled for delivery |
QueueStats |
getStats()
|
Delivery |
handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
A receiver can return an active, "done" or null delivery. |
boolean |
isActive()
|
boolean |
isClustered()
|
boolean |
isLocal()
|
boolean |
isRecoverable()
|
java.util.Iterator |
iterator()
|
void |
load()
|
java.util.List |
recoverDeliveries(java.util.List messageIds)
|
boolean |
remove(Receiver receiver)
Remove a local receiver from this distributor. |
void |
removeAllReferences()
Remove all the references in the channel |
void |
setMaxSize(int newSize)
|
void |
setStats(QueueStats stats)
|
java.lang.String |
toString()
|
java.util.List |
undelivered(Filter filter)
|
void |
unload()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
public RemoteQueueStub(int nodeId,
java.lang.String name,
long id,
boolean recoverable,
PersistenceManager pm,
Filter filter)
| Method Detail |
public Delivery handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
Receiver
handle in interface Receiverobserver - - the component the delivery should be acknowledged to.Delivery,
DeliveryObserverpublic boolean contains(Receiver receiver)
contains in interface Distributorpublic java.util.Iterator iterator()
iterator in interface Distributorpublic boolean add(Receiver receiver)
Distributor
add in interface Distributorpublic boolean remove(Receiver receiver)
Distributor
remove in interface Distributorpublic int getNumberOfReceivers()
getNumberOfReceivers in interface Distributor
public void acknowledge(Delivery d,
Transaction tx)
throws java.lang.Throwable
acknowledge in interface DeliveryObserverjava.lang.Throwable
public void cancel(Delivery d)
throws java.lang.Throwable
cancel in interface DeliveryObserverjava.lang.Throwablepublic long getChannelID()
getChannelID in interface Channelpublic boolean isRecoverable()
isRecoverable in interface Channelpublic boolean acceptReliableMessages()
Channel
acceptReliableMessages in interface Channelpublic java.util.List browse()
browse in interface Channelpublic java.util.List browse(Filter filter)
browse in interface Channelfilter - - may be null, in which case no filter is applied.
public void deliver()
Channel
deliver in interface Channelpublic void close()
Channel
close in interface Channelpublic java.util.List delivering(Filter filter)
public java.util.List undelivered(Filter filter)
public void clear()
Channel
clear in interface Channelpublic int getMessageCount()
getMessageCount in interface Channel
public void removeAllReferences()
throws java.lang.Throwable
Channel
removeAllReferences in interface Channeljava.lang.Throwable
public void load()
throws java.lang.Exception
load in interface Channeljava.lang.Exception
public void unload()
throws java.lang.Exception
unload in interface Channeljava.lang.Exceptionpublic void activate()
activate in interface Channelpublic void deactivate()
deactivate in interface Channelpublic boolean isActive()
isActive in interface Channelpublic java.util.List recoverDeliveries(java.util.List messageIds)
recoverDeliveries in interface Channelpublic int getDeliveringCount()
getDeliveringCount in interface Channelpublic int getMaxSize()
getMaxSize in interface Channelpublic int getMessagesAdded()
getMessagesAdded in interface Channelpublic void setMaxSize(int newSize)
setMaxSize in interface Channelpublic int getScheduledCount()
Channel
getScheduledCount in interface Channelpublic java.lang.String getName()
getName in interface Queuepublic Filter getFilter()
getFilter in interface Queuepublic boolean isClustered()
isClustered in interface Queuepublic QueueStats getStats()
getStats in interface ClusteredQueuepublic int getNodeId()
getNodeId in interface ClusteredQueuepublic boolean isLocal()
isLocal in interface ClusteredQueuepublic void setStats(QueueStats stats)
public java.lang.String toString()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||