|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | |||||||||
PREV NEXT | FRAMES NO FRAMES |