From f98d1258b3594fac76b2beb40c9af30e8920019b Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Thu, 23 Oct 2008 19:32:02 +0000 Subject: This is for QPID-1296 added a boolean to the connect method to indicate whether an SSL connection should be created. currently there seems to be two issues. 1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation. 2. I haven't able to get client side authentication working. For item 1 we may need to use nio classes to get around the issue. For item 2 I am yet to figure out the correct config options to get client side auth working. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@707453 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'qpid/java/client/src/main') diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java index 6e886f25a8..116b163b3c 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java @@ -263,7 +263,9 @@ public class AMQProtocolHandler extends IoHandlerAdapter _protocolSession = new AMQProtocolSession(this, _connection); _stateManager.setProtocolSession(_protocolSession); IoTransport.connect_0_9(getProtocolSession(), - brokerDetail.getHost(), brokerDetail.getPort()); + brokerDetail.getHost(), + brokerDetail.getPort(), + brokerDetail.useSSL()); _protocolSession.init(); } -- cgit v1.2.1