Errai 3.0.1-SNAPSHOT

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

Packages that use MessageQueue
org.jboss.errai.bus.server The server-side components of ErraiBus. 
org.jboss.errai.bus.server.api   
org.jboss.errai.bus.server.io   
org.jboss.errai.bus.server.service   
 

Uses of MessageQueue in org.jboss.errai.bus.server
 

Classes in org.jboss.errai.bus.server that implement MessageQueue
 class MessageQueueImpl
          A message queue is keeps track of which messages need to be sent outbound.
 

Methods in org.jboss.errai.bus.server that return MessageQueue
 MessageQueue ServerMessageBusImpl.getQueue(QueueSession session)
          Gets the queue corresponding to the session id given
 MessageQueue ServerMessageBusImpl.getQueueBySession(String sessionId)
           
 

Methods in org.jboss.errai.bus.server that return types with arguments of type MessageQueue
 Map<QueueSession,MessageQueue> ServerMessageBusImpl.getMessageQueues()
          Gets all the message queues
 Collection<MessageQueue> ServerMessageBusImpl.RemoteMessageCallback.getQueues()
           
 

Methods in org.jboss.errai.bus.server with parameters of type MessageQueue
 void ServerMessageBusImpl.RemoteMessageCallback.addQueue(MessageQueue queue)
           
 void ServerMessageBusImpl.closeQueue(MessageQueue queue)
          Closes the message queue
 boolean ServerMessageBusImpl.RemoteMessageCallback.contains(MessageQueue queue)
           
 void ServerMessageBusImpl.remoteSubscribe(QueueSession sessionContext, MessageQueue queue, String subject)
          Adds a new remote subscription and fires subscription listeners
 void ServerMessageBusImpl.remoteUnsubscribe(QueueSession sessionContext, MessageQueue queue, String subject)
          Unsubscribes a remote subscription and fires the appropriate listeners
 void ServerMessageBusImpl.RemoteMessageCallback.removeQueue(MessageQueue queue)
           
 

Uses of MessageQueue in org.jboss.errai.bus.server.api
 

Methods in org.jboss.errai.bus.server.api that return MessageQueue
 MessageQueue QueueCloseEvent.getQueue()
           
 MessageQueue ServerMessageBus.getQueue(QueueSession session)
          Gets the queue containing the messages that are waiting to be transmitted
 MessageQueue ServerMessageBus.getQueueBySession(String id)
           
 

Methods in org.jboss.errai.bus.server.api that return types with arguments of type MessageQueue
 Map<QueueSession,MessageQueue> ServerMessageBus.getMessageQueues()
           
 

Methods in org.jboss.errai.bus.server.api with parameters of type MessageQueue
 void QueueActivationCallback.activate(MessageQueue queue)
          This function is responsible for activating a queue.
 void ServerMessageBus.closeQueue(MessageQueue queue)
          Closes the specified message queue
 

Constructors in org.jboss.errai.bus.server.api with parameters of type MessageQueue
QueueCloseEvent(MessageQueue queue)
           
 

Uses of MessageQueue in org.jboss.errai.bus.server.io
 

Methods in org.jboss.errai.bus.server.io with parameters of type MessageQueue
 void Cleanable.clean(MessageQueue queue)
           
 void BufferDeliveryHandler.clean(MessageQueue queue)
           
 boolean Buffered.copyFromBuffer(MessageQueue queue, ByteWriteAdapter toAdapter)
           
 boolean BufferDeliveryHandler.copyFromBuffer(MessageQueue queue, ByteWriteAdapter toAdapter)
           
 boolean Buffered.copyFromBuffer(TimeUnit timeUnit, int timeout, MessageQueue queue, ByteWriteAdapter toAdapter)
           
 boolean BufferDeliveryHandler.copyFromBuffer(TimeUnit timeUnit, int timeout, MessageQueue queue, ByteWriteAdapter toAdapter)
           
 boolean DirectDeliveryHandler.deliver(MessageQueue queue, Message message)
           
 boolean MessageDeliveryHandler.deliver(MessageQueue queue, Message message)
          This method is responsible for delivering a message into the transport layer.
 boolean BufferDeliveryHandler.deliver(MessageQueue queue, Message message)
           
static void PageUtil.discardPageData(MessageQueue queue)
           
 void Pageable.discardPageData(MessageQueue queue)
           
static File PageUtil.getOrCreatePageFile(MessageQueue queue)
           
static String PageUtil.getPageFileName(MessageQueue queue)
           
 void DirectDeliveryHandler.noop(MessageQueue queue)
           
 void MessageDeliveryHandler.noop(MessageQueue queue)
          Sends a NOOP (No-Operation) to the remote connected
 void BufferDeliveryHandler.noop(MessageQueue queue)
           
 void DirectDeliveryHandler.onWake(MessageQueue queue)
           
 void Wakeable.onWake(MessageQueue queue)
           
static boolean PageUtil.pageIfStraddling(MessageQueue queue)
           
 boolean Pageable.pageOut(MessageQueue queue)
           
static boolean PageUtil.pageWaitingToDisk(MessageQueue queue)
           
static void PageUtil.readInPageFile(MessageQueue queue, ByteWriteAdapter outputStream, BufferFilter callback)
           
static void PageUtil.writeToPageFile(MessageQueue queue, InputStream inputStream, boolean append)
           
 

Uses of MessageQueue in org.jboss.errai.bus.server.service
 

Methods in org.jboss.errai.bus.server.service that return MessageQueue
 MessageQueue MessageBusProxy.getQueue(QueueSession session)
           
 MessageQueue MessageBusProxy.getQueueBySession(String id)
           
 

Methods in org.jboss.errai.bus.server.service that return types with arguments of type MessageQueue
 Map<QueueSession,MessageQueue> MessageBusProxy.getMessageQueues()
           
 

Methods in org.jboss.errai.bus.server.service with parameters of type MessageQueue
 void MessageBusProxy.closeQueue(MessageQueue queue)
           
 


Errai 3.0.1-SNAPSHOT

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