public interface MessageQueue
Modifier and Type | Method and Description |
---|---|
void |
discard() |
void |
finishInit() |
void |
fireActivationCallback() |
QueueActivationCallback |
getActivationCallback() |
Object |
getActivationLock() |
Buffer |
getBuffer() |
BufferColor |
getBufferColor() |
long |
getCurrentBufferSequenceNumber() |
MessageDeliveryHandler |
getDeliveryHandler() |
long |
getLastTransmissionTime() |
Object |
getPageLock() |
QueueSession |
getSession() |
void |
heartBeat() |
int |
incrementMessageCount() |
boolean |
isInitialized() |
boolean |
isPaged() |
boolean |
isStale() |
boolean |
messagesWaiting() |
boolean |
offer(Message message) |
boolean |
poll(ByteWriteAdapter stream) |
boolean |
poll(TimeUnit timeUnit,
int time,
ByteWriteAdapter stream) |
void |
resetMessageCount() |
void |
setActivationCallback(QueueActivationCallback activationCallback) |
void |
setDeliveryHandler(MessageDeliveryHandler handler) |
void |
setDeliveryHandlerToDefault() |
void |
setPaged(boolean pageStatus) |
void |
setTimeout(long timeout) |
void |
stopQueue() |
void |
wake() |
boolean poll(ByteWriteAdapter stream) throws IOException
IOException
boolean poll(TimeUnit timeUnit, int time, ByteWriteAdapter stream) throws IOException
IOException
boolean offer(Message message) throws IOException
IOException
long getCurrentBufferSequenceNumber()
void wake()
void setActivationCallback(QueueActivationCallback activationCallback)
QueueActivationCallback getActivationCallback()
void fireActivationCallback()
QueueSession getSession()
void finishInit()
boolean isStale()
boolean isPaged()
void setPaged(boolean pageStatus)
boolean isInitialized()
void heartBeat()
boolean messagesWaiting()
void discard()
void stopQueue()
Object getActivationLock()
Object getPageLock()
MessageDeliveryHandler getDeliveryHandler()
void setDeliveryHandler(MessageDeliveryHandler handler)
void setDeliveryHandlerToDefault()
BufferColor getBufferColor()
Buffer getBuffer()
int incrementMessageCount()
void resetMessageCount()
long getLastTransmissionTime()
void setTimeout(long timeout)
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.