Skip to content

O
Openfire
Commit ab5ee328 authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gaston
Browse files
Options

Removed extra end of stream. JM-332 


git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@1637 b35dd754-fafc-0310-a699-88a17e54d16e
parent a92017da
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 5 deletions
src/java/org/jivesoftware/messenger/component/ComponentSession.java
View file @ ab5ee328
...@@ -84,7 +84,6 @@ public class ComponentSession extends Session { ...@@ -84,7 +84,6 @@ public class ComponentSession extends Session {
// Include the bad-format in the response // Include the bad-format in the response
StreamError error = new StreamError(StreamError.Condition.bad_format); StreamError error = new StreamError(StreamError.Condition.bad_format);
sb.append(error.toXML()); sb.append(error.toXML());
sb.append("</stream:stream>");
writer.write(sb.toString()); writer.write(sb.toString());
writer.flush(); writer.flush();
// Close the underlying connection // Close the underlying connection
...@@ -96,7 +95,6 @@ public class ComponentSession extends Session { ...@@ -96,7 +95,6 @@ public class ComponentSession extends Session {
Log.debug("[ExComp] Component is not allowed to connect with subdomain: " + subdomain); Log.debug("[ExComp] Component is not allowed to connect with subdomain: " + subdomain);
StreamError error = new StreamError(StreamError.Condition.host_unknown); StreamError error = new StreamError(StreamError.Condition.host_unknown);
sb.append(error.toXML()); sb.append(error.toXML());
sb.append("</stream:stream>");
writer.write(sb.toString()); writer.write(sb.toString());
writer.flush(); writer.flush();
// Close the underlying connection // Close the underlying connection
...@@ -110,7 +108,6 @@ public class ComponentSession extends Session { ...@@ -110,7 +108,6 @@ public class ComponentSession extends Session {
// Include the internal-server-error in the response // Include the internal-server-error in the response
StreamError error = new StreamError(StreamError.Condition.internal_server_error); StreamError error = new StreamError(StreamError.Condition.internal_server_error);
sb.append(error.toXML()); sb.append(error.toXML());
sb.append("</stream:stream>");
writer.write(sb.toString()); writer.write(sb.toString());
writer.flush(); writer.flush();
// Close the underlying connection // Close the underlying connection
...@@ -124,7 +121,6 @@ public class ComponentSession extends Session { ...@@ -124,7 +121,6 @@ public class ComponentSession extends Session {
// Include the conflict error in the response // Include the conflict error in the response
StreamError error = new StreamError(StreamError.Condition.conflict); StreamError error = new StreamError(StreamError.Condition.conflict);
sb.append(error.toXML()); sb.append(error.toXML());
sb.append("</stream:stream>");
writer.write(sb.toString()); writer.write(sb.toString());
writer.flush(); writer.flush();
// Close the underlying connection // Close the underlying connection
...@@ -170,7 +166,6 @@ public class ComponentSession extends Session { ...@@ -170,7 +166,6 @@ public class ComponentSession extends Session {
// Include the conflict error in the response // Include the conflict error in the response
StreamError error = new StreamError(StreamError.Condition.not_authorized); StreamError error = new StreamError(StreamError.Condition.not_authorized);
sb.append(error.toXML()); sb.append(error.toXML());
sb.append("</stream:stream>");
writer.write(sb.toString()); writer.write(sb.toString());
writer.flush(); writer.flush();
// Close the underlying connection // Close the underlying connection
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

Technounit-GROUP 2023