|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ServerMessageBus
This interface, ServerMessageBus, extends the client's MessageBus
,
and adds functionality so the server can transmit messages to a client and vice versa
Method Summary | |
---|---|
void |
addQueueClosedListener(QueueClosedListener listener)
Register a QueueClosedListener with the bus. |
void |
associateNewQueue(QueueSession oldSession,
QueueSession newSession)
|
void |
closeQueue(MessageQueue queue)
Closes the specified message queue |
void |
closeQueue(String sessionId)
Closes the queue associated with the sessionId |
void |
configure(ErraiServiceConfigurator service)
Configures the bus using the configuration specified |
Message |
getDeadLetterMessage(String messageId)
|
Map<QueueSession,MessageQueue> |
getMessageQueues()
|
MessageQueue |
getQueue(QueueSession session)
Gets the queue containing the messages that are waiting to be transmitted |
MessageQueue |
getQueueBySession(String id)
|
Collection<MessageCallback> |
getReceivers(String subject)
Get a collection of all receivers registered for a specificed subject |
ExecutorService |
getScheduler()
Returns the associated scheduler which keeps track of timed events |
QueueSession |
getSessionBySessionId(String id)
|
boolean |
hasRemoteSubscription(String sessionId,
String subject)
|
boolean |
hasRemoteSubscriptions(String subject)
|
boolean |
removeDeadLetterMessage(String messageId)
|
void |
stop()
Stop the MessateBus. |
Methods inherited from interface org.jboss.errai.bus.client.api.messaging.MessageBus |
---|
addSubscribeListener, addUnsubscribeListener, attachMonitor, isSubscribed, send, send, sendGlobal, subscribe, subscribeLocal, unsubscribeAll |
Method Detail |
---|
MessageQueue getQueue(QueueSession session)
session
- - the session of the queue
void closeQueue(String sessionId)
sessionId
- - the session id of the message queuevoid closeQueue(MessageQueue queue)
queue
- - the message queue to closeExecutorService getScheduler()
void addQueueClosedListener(QueueClosedListener listener)
QueueClosedListener
with the bus.
listener
- a instance of the listenervoid configure(ErraiServiceConfigurator service)
service
- - the configuration to useCollection<MessageCallback> getReceivers(String subject)
subject
- The subject.
boolean hasRemoteSubscriptions(String subject)
boolean hasRemoteSubscription(String sessionId, String subject)
Map<QueueSession,MessageQueue> getMessageQueues()
MessageQueue getQueueBySession(String id)
QueueSession getSessionBySessionId(String id)
void associateNewQueue(QueueSession oldSession, QueueSession newSession)
Message getDeadLetterMessage(String messageId)
boolean removeDeadLetterMessage(String messageId)
void stop()
|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |