Package | Description |
---|---|
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 |
Modifier and Type | Class and Description |
---|---|
class |
MessageQueueImpl
A message queue is keeps track of which messages need to be sent outbound.
|
Modifier and Type | Method and Description |
---|---|
MessageQueue |
ServerMessageBusImpl.getQueue(QueueSession session)
Gets the queue corresponding to the session id given
|
MessageQueue |
ServerMessageBusImpl.getQueueBySession(String sessionId) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
ServerMessageBusImpl.getMessageQueues()
Gets all the message queues
|
Collection<MessageQueue> |
ServerMessageBusImpl.RemoteMessageCallback.getQueues() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
ServerMessageBus.getMessageQueues() |
Modifier and Type | Method and Description |
---|---|
void |
QueueActivationCallback.activate(MessageQueue queue)
This function is responsible for activating a queue.
|
void |
ServerMessageBus.closeQueue(MessageQueue queue)
Closes the specified message queue
|
Constructor and Description |
---|
QueueCloseEvent(MessageQueue queue) |
Modifier and Type | Method and Description |
---|---|
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 |
MessageDeliveryHandler.deliver(MessageQueue queue,
Message message)
This method is responsible for delivering a message into the transport layer.
|
boolean |
DirectDeliveryHandler.deliver(MessageQueue queue,
Message message) |
boolean |
BufferDeliveryHandler.deliver(MessageQueue queue,
Message message) |
void |
Pageable.discardPageData(MessageQueue queue) |
static void |
PageUtil.discardPageData(MessageQueue queue) |
static File |
PageUtil.getOrCreatePageFile(MessageQueue queue) |
static String |
PageUtil.getPageFileName(MessageQueue queue) |
void |
MessageDeliveryHandler.noop(MessageQueue queue)
Sends a NOOP (No-Operation) to the remote connected
|
void |
DirectDeliveryHandler.noop(MessageQueue queue) |
void |
BufferDeliveryHandler.noop(MessageQueue queue) |
void |
Wakeable.onWake(MessageQueue queue) |
void |
DirectDeliveryHandler.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) |
Modifier and Type | Method and Description |
---|---|
MessageQueue |
MessageBusProxy.getQueue(QueueSession session) |
MessageQueue |
MessageBusProxy.getQueueBySession(String id) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
MessageBusProxy.getMessageQueues() |
Modifier and Type | Method and Description |
---|---|
void |
MessageBusProxy.closeQueue(MessageQueue queue) |
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.