Package org.apache.qpid.transport

Examples of org.apache.qpid.transport.TransportException

141
142
143
144
145
146
147
148
            _acceptor.setDaemon(false);
            _acceptor.start();
        }
        catch (IOException e)
        {
            throw new TransportException("Unable to start server socket", e);
        }
    }
View Full Code Here
205
206
207
208
209
210
211
212
213
                {
                    _serverSocket.close();
                }
                catch (IOException e)
                {
                    throw new TransportException(e);
                }
            }
        }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
    public void send(java.nio.ByteBuffer buf)
    {
        if (session.isClosing())
        {
            throw new TransportException("attempted to write to a closed socket");
        }

        synchronized (this)
        {
            lastWrite = session.write(ByteBuffer.wrap(buf));
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
            {
                sslCtx = createSSLContext();
            }
            catch (Exception e)
            {
                throw new TransportException("Error creating SSL Context", e);
            }
           
            try
            {
                engine = sslCtx.createSSLEngine();
                engine.setUseClientMode(true);
            }
            catch(Exception e)
            {
                throw new TransportException("Error creating SSL Engine", e);
            }
           
            this.sender = new SSLSender(engine,new IoSender(this, 2*writeBufferSize, timeout));
            this.endpoint = binding.endpoint(sender);
            this.receiver = new IoReceiver(this, new SSLReceiver(engine,binding.receiver(endpoint),(SSLSender)sender),
View Full Code Here
198
199
200
201
202
203
204
205
206
207
208
209
            socket.connect(new InetSocketAddress(address, port));
            return socket;
        }
        catch (SocketException e)
        {
            throw new TransportException("Error connecting to broker", e);
        }
        catch (IOException e)
        {
            throw new TransportException("Error connecting to broker", e);
        }
    }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
                if (block && Thread.currentThread() != this)
                {
                    join(timeout);
                    if (isAlive())
                    {
                        throw new TransportException("join timed out");
                    }
                }
            }
            catch (InterruptedException e)
            {
                throw new TransportException(e);
            }
            catch (IOException e)
            {
                throw new TransportException(e);
            }
        }
    }
View Full Code Here
82
83
84
85
86
87
88
89
90
                Socket sock = socket.accept();
                IoTransport<E> transport = new IoTransport<E>(sock, binding,false);
            }
            catch (IOException e)
            {
                throw new TransportException(e);
            }
        }
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
        {
            out = socket.getOutputStream();
        }
        catch (IOException e)
        {
            throw new TransportException("Error getting output stream for socket", e);
        }

        setDaemon(true);
        setName(String.format("IoSender - %s", socket.getRemoteSocketAddress()));
        start();
View Full Code Here
169
170
171
172
173
174
175
176
177
178
               
                   
            }
            catch(SSLException e)
            {
                throw new TransportException("Error in SSLReceiver",e);
            }
              
        }
    }
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
          }
         
          if (hostname != null && !(hostname.equalsIgnoreCase(hostnameExpected) ||
                  hostname.equalsIgnoreCase(hostnameExpected + ".localdomain")))
          {
              throw new TransportException("SSL hostname verification failed." +
                                           " Expected : " + hostnameExpected +
                                           " Found in cert : " + hostname);
          }
         
        }
View Full Code Here
TOP

Related Classes of org.apache.qpid.transport.TransportException

  • org.apache.qpid.transport.network.io.IoAcceptor
  • org.apache.qpid.transport.network.io.IoNetworkTransport
  • org.apache.qpid.transport.network.io.IoNetworkTransport$AcceptingThread
  • org.apache.qpid.transport.network.io.IoReceiver
  • org.apache.qpid.transport.network.io.IoSender
  • org.apache.qpid.transport.network.io.IoTransport
  • org.apache.qpid.transport.network.mina.MinaSender
  • org.apache.qpid.transport.network.security.SecurityLayer$SSLSecurityLayer
  • org.apache.qpid.transport.network.security.SecurityLayerFactory$SSLSecurityLayer
  • org.apache.qpid.transport.network.security.ssl.SSLReceiver
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.