Modifier and Type | Method and Description |
---|---|
QueueSession |
SessionEndEvent.getSession()
Returns the session that ended.
|
Constructor and Description |
---|
SessionEndEvent(QueueSession session)
Creates a SessionEndEvent for the given QueueSession.
|
Modifier and Type | Method and Description |
---|---|
static QueueSession |
BusToolsCli.getClientSession() |
Modifier and Type | Method and Description |
---|---|
QueueSession |
HttpSessionProvider.createOrGetSession(javax.servlet.http.HttpSession externSessRef,
String remoteQueueID) |
QueueSession |
HttpSessionProvider.SessionsContainer.createSession(String httpSessionId,
String remoteQueueId) |
QueueSession |
MessageQueueImpl.getSession() |
QueueSession |
HttpSessionProvider.SessionsContainer.getSession(String remoteQueueId) |
QueueSession |
ServerMessageBusImpl.getSessionBySessionId(String id) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
ServerMessageBusImpl.getMessageQueues()
Gets all the message queues
|
Modifier and Type | Method and Description |
---|---|
void |
ServerMessageBusImpl.associateNewQueue(QueueSession oldSession,
QueueSession newSession) |
MessageQueue |
ServerMessageBusImpl.getQueue(QueueSession session)
Gets the queue corresponding to the session id given
|
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
|
Constructor and Description |
---|
MessageQueueImpl(TransmissionBuffer buffer,
QueueSession session,
int timeoutSecs) |
Modifier and Type | Method and Description |
---|---|
QueueSession |
SessionProvider.createOrGetSession(T externSessRef,
String remoteQueueId)
Looks up or creates the
QueueSession that identifies a communication channel with a specific queue in a
specific remote Errai Bus. |
static QueueSession |
RpcContext.getQueueSession() |
QueueSession |
MessageQueue.getSession() |
QueueSession |
ServerMessageBus.getSessionBySessionId(String id) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
ServerMessageBus.getMessageQueues() |
Modifier and Type | Method and Description |
---|---|
void |
ServerMessageBus.associateNewQueue(QueueSession oldSession,
QueueSession newSession) |
MessageQueue |
ServerMessageBus.getQueue(QueueSession session)
Gets the queue containing the messages that are waiting to be transmitted
|
Modifier and Type | Class and Description |
---|---|
class |
IntrabusQueueSession |
Modifier and Type | Field and Description |
---|---|
static QueueSession |
IntrabusQueueSession.INSTANCE |
Modifier and Type | Method and Description |
---|---|
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
EJValue value) |
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
javax.servlet.http.HttpServletRequest request) |
static Message |
MessageFactory.createCommandMessage(QueueSession session,
javax.servlet.http.HttpServletRequest request,
String json)
Creates the command message from the given JSON string and session.
|
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
InputStream inputStream) |
static Message |
MessageFactory.createCommandMessage(QueueSession session,
String json) |
Modifier and Type | Method and Description |
---|---|
static String |
WebSocketTokenManager.getNewOneTimeToken(QueueSession session) |
static boolean |
WebSocketTokenManager.verifyOneTimeToken(QueueSession session,
String token) |
Modifier and Type | Method and Description |
---|---|
QueueSession |
MessageBusProxy.getSessionBySessionId(String id) |
Modifier and Type | Method and Description |
---|---|
Map<QueueSession,MessageQueue> |
MessageBusProxy.getMessageQueues() |
Modifier and Type | Method and Description |
---|---|
void |
MessageBusProxy.associateNewQueue(QueueSession oldSession,
QueueSession newSession) |
MessageQueue |
MessageBusProxy.getQueue(QueueSession session) |
Modifier and Type | Method and Description |
---|---|
static QueueSession |
WebSocketNegotiationHandler.establishNegotiation(EJValue val,
QueueChannel queueChannel,
ErraiService service) |
Modifier and Type | Method and Description |
---|---|
QueueSession |
SessionContext.getSession() |
QueueSession |
LocalContext.getSession() |
Modifier and Type | Method and Description |
---|---|
static SessionContext |
SessionContext.get(QueueSession session) |
static ServerLaundryList |
ServerLaundryList.get(QueueSession session) |
static LocalContext |
LocalContext.get(QueueSession session) |
Modifier and Type | Field and Description |
---|---|
protected QueueSession |
DefaultErraiWebSocketChannel.queueSession |
Modifier and Type | Method and Description |
---|---|
static QueueSession |
CDIServerUtil.getSession(Message message) |
Modifier and Type | Method and Description |
---|---|
QueueSession |
EventConversationContext.Context.getSession() |
Modifier and Type | Method and Description |
---|---|
static void |
EventConversationContext.activate(Object o,
QueueSession session)
Activate the conversation scope.
|
static void |
EventConversationContext.activate(QueueSession session)
Activate a conversations scope.
|
void |
EventRoutingTable.activateRoute(String eventType,
Set<String> annotations,
QueueSession queueSession) |
void |
EventRoutingTable.deactivateRoute(String eventType,
Set<String> annotations,
QueueSession queueSession) |
boolean |
EventRoutingTable.isRouteActive(String eventType,
Set<String> annotations,
QueueSession queueSession) |
Constructor and Description |
---|
EventConversationContext.Context(Object eventObject,
QueueSession session) |
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.