Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve synchronization checks in STOMP relay session

Browse Source
This commit is contained in:
Rossen Stoyanchev
2013-06-19 08:28:58 -04:00
parent 28174744a7
commit 811bb1b0c9
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-websocket/src/main/java/org/springframework/web/messaging/stomp/support/StompRelayPubSubMessageHandler.java
View File

@@ -250,13 +250,15 @@ public class StompRelayPubSubMessageHandler<M extends Message> extends AbstractP
public void forward(M message, StompHeaders headers) {
synchronized(this.monitor) {
if (!this.isConnected) {
if (logger.isTraceEnabled()) {
logger.trace("Adding to queue message " + message + ", queue size=" + this.messageQueue.size());
if (!this.isConnected) {
synchronized(this.monitor) {
if (!this.isConnected) {
this.messageQueue.add(message);
if (logger.isTraceEnabled()) {
logger.trace("Queued message " + message + ", queue size=" + this.messageQueue.size());
}
return;
}
this.messageQueue.add(message);
return;
}
}