TEIID-5014: Unable to use parameterized query with node pg module and…

… Teiid/JBoss VDB (fix for node.js prepared statements)
teiid · Sep 25, 2017 · 3e93fc5 · 3e93fc5
1 parent 7906b0b
commit 3e93fc5
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/runtime/src/main/java/org/teiid/transport/PgBackendProtocol.java b/runtime/src/main/java/org/teiid/transport/PgBackendProtocol.java
@@ -420,7 +420,11 @@ public void terminated() {
 	public void flush() {
 		this.dataOut = null;
 		this.writer = null;
-		Channels.write(this.ctx.getChannel(), null);
+		try {
+				((OutputStreamWriter) this.ctx).flush();
+	    } catch (IOException e){
+			LogManager.logError(LogConstants.CTX_ODBC, e, "channel being flushed - ");
+	    }
 	}
 
 	@Override
@@ -429,8 +433,8 @@ public void emptyQueryReceived() {
 	}
 
 	private void terminate(Throwable t) {
-		trace("channel being terminated - ", t.getMessage());
-		this.ctx.getChannel().close();
+	    LogManager.logDetail(LogConstants.CTX_ODBC, "channel being terminated - ", t.getMessage());
+	    this.ctx.getChannel().close();
 	}
 
 	private void sendEmptyQueryResponse() {