You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/01 18:04:16 UTC
svn commit: r382082 - in
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp:
Connect.java FrameBuilder.java
Author: jstrachan
Date: Wed Mar 1 09:04:16 2006
New Revision: 382082
URL: http://svn.apache.org/viewcvs?rev=382082&view=rev
Log:
minor refactor to avoid strange eclipse compile error message
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java?rev=382082&r1=382081&r2=382082&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java Wed Mar 1 09:04:16 2006
@@ -83,9 +83,13 @@
format.onFullyConnected();
StringBuffer buffer = new StringBuffer();
- buffer.append(Stomp.Responses.CONNECTED).append(Stomp.NEWLINE);
- buffer.append(Stomp.Headers.Connected.SESSION).append(Stomp.Headers.SEPERATOR).append(connectionInfo.getClientId()).append(Stomp.NEWLINE).append(
- Stomp.NEWLINE);
+ buffer.append(Stomp.Responses.CONNECTED);
+ buffer.append(Stomp.NEWLINE);
+ buffer.append(Stomp.Headers.Connected.SESSION);
+ buffer.append(Stomp.Headers.SEPERATOR);
+ buffer.append(connectionInfo.getClientId());
+ buffer.append(Stomp.NEWLINE);
+ buffer.append(Stomp.NEWLINE);
buffer.append(Stomp.NULL);
out.writeBytes(buffer.toString());
return true;
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java?rev=382082&r1=382081&r2=382082&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java Wed Mar 1 09:04:16 2006
@@ -79,7 +79,10 @@
String key = (String) iterator.next();
String property = headers.getProperty(key);
if (property != null) {
- buffer.append(key).append(Stomp.Headers.SEPERATOR).append(property).append(Stomp.NEWLINE);
+ buffer.append(key);
+ buffer.append(Stomp.Headers.SEPERATOR);
+ buffer.append(property);
+ buffer.append(Stomp.NEWLINE);
}
}
buffer.append(Stomp.NEWLINE);