Errai 3.0.1-SNAPSHOT

org.jboss.errai.bus.server.api
Interface MessageQueue

All Known Implementing Classes:
MessageQueueImpl

public interface MessageQueue


Method Summary
 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()
           
 

Method Detail

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)

Errai 3.0.1-SNAPSHOT

Copyright © 2013-2014 JBoss, a division of Red Hat. All Rights Reserved.