|
|||||||||||
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 Receiver
observer
- - the component the delivery should be acknowledged to.Delivery
,
DeliveryObserver
public boolean contains(Receiver receiver)
contains
in interface Distributor
public java.util.Iterator iterator()
iterator
in interface Distributor
public boolean add(Receiver receiver)
Distributor
add
in interface Distributor
public boolean remove(Receiver receiver)
Distributor
remove
in interface Distributor
public int getNumberOfReceivers()
getNumberOfReceivers
in interface Distributor
public void acknowledge(Delivery d, Transaction tx) throws java.lang.Throwable
acknowledge
in interface DeliveryObserver
java.lang.Throwable
public void cancel(Delivery d) throws java.lang.Throwable
cancel
in interface DeliveryObserver
java.lang.Throwable
public long getChannelID()
getChannelID
in interface Channel
public boolean isRecoverable()
isRecoverable
in interface Channel
public boolean acceptReliableMessages()
Channel
acceptReliableMessages
in interface Channel
public java.util.List browse()
browse
in interface Channel
public java.util.List browse(Filter filter)
browse
in interface Channel
filter
- - may be null, in which case no filter is applied.
public void deliver()
Channel
deliver
in interface Channel
public void close()
Channel
close
in interface Channel
public java.util.List delivering(Filter filter)
public java.util.List undelivered(Filter filter)
public void clear()
Channel
clear
in interface Channel
public int getMessageCount()
getMessageCount
in interface Channel
public void removeAllReferences() throws java.lang.Throwable
Channel
removeAllReferences
in interface Channel
java.lang.Throwable
public void load() throws java.lang.Exception
load
in interface Channel
java.lang.Exception
public void unload() throws java.lang.Exception
unload
in interface Channel
java.lang.Exception
public void activate()
activate
in interface Channel
public void deactivate()
deactivate
in interface Channel
public boolean isActive()
isActive
in interface Channel
public java.util.List recoverDeliveries(java.util.List messageIds)
recoverDeliveries
in interface Channel
public int getDeliveringCount()
getDeliveringCount
in interface Channel
public int getMaxSize()
getMaxSize
in interface Channel
public int getMessagesAdded()
getMessagesAdded
in interface Channel
public void setMaxSize(int newSize)
setMaxSize
in interface Channel
public int getScheduledCount()
Channel
getScheduledCount
in interface Channel
public java.lang.String getName()
getName
in interface Queue
public Filter getFilter()
getFilter
in interface Queue
public boolean isClustered()
isClustered
in interface Queue
public QueueStats getStats()
getStats
in interface ClusteredQueue
public int getNodeId()
getNodeId
in interface ClusteredQueue
public boolean isLocal()
isLocal
in interface ClusteredQueue
public 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 |