Examples of org.apache.activemq.transport.tcp.SslTransport

Package org.apache.activemq.transport.tcp

Examples of org.apache.activemq.transport.tcp.SslTransport

org.apache.activemq.transport.tcp.SslTransport
A Transport class that uses SSL and client-side certificate authentication. Client-side certificate authentication must be enabled through the constructor. By default, this class will have the same client authentication behavior as the socket it is passed. This class will set ConnectionInfo's transportContext to the SSL certificates of the client. NOTE: Accessor method for needClientAuth was not provided on purpose. This is because needClientAuth's value must be set before the socket is connected. Otherwise, unexpected situations may occur.

     * Overriding to allow for proper configuration through reflection but delegate to get common
     * configuration
     */
    public Transport compositeConfigure(Transport transport, WireFormat format, Map options) {
        if (transport instanceof SslTransport)  {
            SslTransport sslTransport = (SslTransport)transport.narrow(SslTransport.class);
            IntrospectionSupport.setProperties(sslTransport, options);
        } else if (transport instanceof NIOSSLTransport) {
            NIOSSLTransport sslTransport = (NIOSSLTransport)transport.narrow(NIOSSLTransport.class);
            IntrospectionSupport.setProperties(sslTransport, options);
        }

View Full Code Here

            } catch (Exception e) {
                LOG.warn("path isn't a valid local location for SslTransport to use", e);
            }
        }
        SocketFactory socketFactory = createSocketFactory();
        return new SslTransport(wf, (SSLSocketFactory)socketFactory, location, localLocation, false);
    }

View Full Code Here

     * Overriding to allow for proper configuration through reflection but
     * delegate to get common configuration
     */
    public Transport compositeConfigure(Transport transport, WireFormat format, Map options) {
        if (transport instanceof SslTransport) {
            SslTransport sslTransport = (SslTransport) transport.narrow(SslTransport.class);
            IntrospectionSupport.setProperties(sslTransport, options);
        } else if (transport instanceof NIOSSLTransport) {
            NIOSSLTransport sslTransport = (NIOSSLTransport) transport.narrow(NIOSSLTransport.class);
            IntrospectionSupport.setProperties(sslTransport, options);
        }

View Full Code Here

            } catch (Exception e) {
                LOG.warn("path isn't a valid local location for SslTransport to use", e);
            }
        }
        SocketFactory socketFactory = createSocketFactory();
        return new SslTransport(wf, (SSLSocketFactory) socketFactory, location, localLocation, false);
    }

View Full Code Here

    protected SslTransportServer createSslTransportServer(final URI location, SSLServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException {
        return new SslTransportServer(this, location, serverSocketFactory) {


            @Override
            protected Transport createTransport(Socket socket, WireFormat format) throws IOException {
                return new SslTransport(format, (SSLSocket)socket) {


                    private X509Certificate[] cachedPeerCerts;


                    @Override
                    public void doConsume(Object command) {

View Full Code Here

TOP

Related Classes of org.apache.activemq.transport.tcp.SslTransport

org.apache.activemq.command.ConnectionInfo

org.apache.activemq.transport.nio.NIOSSLTransportFactory

org.apache.activemq.transport.stomp.StompSslTransportFactory

java.util.HashMap

javax.net.ssl.SSLSocket

javax.net.ssl.SSLSession

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.