org.jboss.errai.bus.server.api
Interface MessageQueue
- All Known Implementing Classes:
- MessageQueueImpl
public interface MessageQueue
poll
boolean poll(ByteWriteAdapter stream)
throws IOException
- Throws:
IOException
poll
boolean poll(TimeUnit timeUnit,
int time,
ByteWriteAdapter stream)
throws IOException
- Throws:
IOException
offer
boolean offer(Message message)
throws IOException
- Throws:
IOException
getCurrentBufferSequenceNumber
long getCurrentBufferSequenceNumber()
wake
void wake()
setActivationCallback
void setActivationCallback(QueueActivationCallback activationCallback)
getActivationCallback
QueueActivationCallback getActivationCallback()
fireActivationCallback
void fireActivationCallback()
getSession
QueueSession getSession()
finishInit
void finishInit()
isStale
boolean isStale()
isPaged
boolean isPaged()
setPaged
void setPaged(boolean pageStatus)
isInitialized
boolean isInitialized()
heartBeat
void heartBeat()
messagesWaiting
boolean messagesWaiting()
discard
void discard()
stopQueue
void stopQueue()
getActivationLock
Object getActivationLock()
getPageLock
Object getPageLock()
getDeliveryHandler
MessageDeliveryHandler getDeliveryHandler()
setDeliveryHandler
void setDeliveryHandler(MessageDeliveryHandler handler)
setDeliveryHandlerToDefault
void setDeliveryHandlerToDefault()
getBufferColor
BufferColor getBufferColor()
getBuffer
Buffer getBuffer()
incrementMessageCount
int incrementMessageCount()
resetMessageCount
void resetMessageCount()
getLastTransmissionTime
long getLastTransmissionTime()
setTimeout
void setTimeout(long timeout)
Copyright © 2013-2014 JBoss, a division of Red Hat. All Rights Reserved.