private class StompBrokerRelayMessageHandler.RelaySession
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
isConnected |
private java.util.concurrent.BlockingQueue<Message<?>> |
messageQueue |
private java.lang.Object |
monitor |
private |
promise |
private java.lang.String |
sessionId |
Constructor and Description |
---|
StompBrokerRelayMessageHandler.RelaySession(java.lang.String sessionId) |
Modifier and Type | Method and Description |
---|---|
private void |
flushMessages( |
void |
forward(Message<?> message) |
private boolean |
forwardInternal(Message<?> message,
|
void |
open(Message<?> message) |
private void |
readStompFrame(java.lang.String stompFrame) |
private void |
sendError(java.lang.String sessionId,
java.lang.String errorText) |
protected void |
sendMessageToClient(Message<?> message) |
private final java.lang.String sessionId
private final java.util.concurrent.BlockingQueue<Message<?>> messageQueue
privatepromise
private volatile boolean isConnected
private final java.lang.Object monitor
public StompBrokerRelayMessageHandler.RelaySession(java.lang.String sessionId)
public void open(Message<?> message)
private void readStompFrame(java.lang.String stompFrame)
protected void sendMessageToClient(Message<?> message)
private void sendError(java.lang.String sessionId, java.lang.String errorText)
public void forward(Message<?> message)
private boolean forwardInternal(Message<?> message,connection)
private void flushMessages(connection)