Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.ChannelException

257
258
259
260
261
262
263
264
265
266
        // Wait for the future.
        future.awaitUninterruptibly();
        if (!future.isSuccess()) {
            future.getChannel().close().awaitUninterruptibly();
            throw new ChannelException("Failed to bind to: " + localAddress, future.getCause());
        }

        return channel;
    }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
        // Wait for the future.
        future.awaitUninterruptibly();
        if (!future.isSuccess()) {
            future.getChannel().close().awaitUninterruptibly();
            throw new ChannelException("Failed to bind to: " + localAddress, future.getCause());
        }

        return channel;
    }
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
   public static HotRodServer startHotRodServer(EmbeddedCacheManager cacheManager) {
      // TODO: This is very rudimentary!! HotRodTestingUtil needs a more robust solution where ports are generated randomly and retries if already bound
      HotRodServer server = null;
      int maxTries = 10;
      int currentTries = 0;
      ChannelException lastException = null;
      while (server == null && currentTries < maxTries) {
         try {
            server = HotRodTestingUtil.startHotRodServer(cacheManager, uniquePort.incrementAndGet());
         } catch (ChannelException e) {
            if (!(e.getCause() instanceof BindException)) {
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
            if (!started) {
                // Open a selector if this worker didn't start yet.
                try {
                    this.selector = selector = Selector.open();
                } catch (Throwable t) {
                    throw new ChannelException(
                            "Failed to create a selector.", t);
                }

                // Start the worker thread with the new Selector.
                String threadName =
View Full Code Here
654
655
656
657
658
659
660
661
662
663
664
            } catch (ClosedChannelException e) {
                if (future != null) {
                    future.setFailure(e);
                }
                close(channel, succeededFuture(channel));
                throw new ChannelException(
                        "Failed to register a socket to the selector.", e);
            }

            if (server) {
                fireChannelOpen(channel);
View Full Code Here
85
86
87
88
89
90
91
92
    public boolean isBroadcast() {
        try {
            return socket.getBroadcast();
        } catch (SocketException e) {
            throw new ChannelException(e);
        }
    }
View Full Code Here
93
94
95
96
97
98
99
100
    public void setBroadcast(boolean broadcast) {
        try {
            socket.setBroadcast(broadcast);
        } catch (SocketException e) {
            throw new ChannelException(e);
        }
    }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    public InetAddress getInterface() {
        if (socket instanceof MulticastSocket) {
            try {
                return ((MulticastSocket) socket).getInterface();
            } catch (SocketException e) {
                throw new ChannelException(e);
            }
        } else {
            throw new UnsupportedOperationException();
        }
    }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    public void setInterface(InetAddress interfaceAddress) {
        if (socket instanceof MulticastSocket) {
            try {
                ((MulticastSocket) socket).setInterface(interfaceAddress);
            } catch (SocketException e) {
                throw new ChannelException(e);
            }
        } else {
            throw new UnsupportedOperationException();
        }
    }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    public boolean isLoopbackModeDisabled() {
        if (socket instanceof MulticastSocket) {
            try {
                return ((MulticastSocket) socket).getLoopbackMode();
            } catch (SocketException e) {
                throw new ChannelException(e);
            }
        } else {
            throw new UnsupportedOperationException();
        }
    }
View Full Code Here
TOP

Related Classes of org.jboss.netty.channel.ChannelException

  • com.addthis.meshy.Meshy
  • com.flipkart.phantom.netty.uds.OioServerSocketChannel
  • org.helios.netty.examples.state.CustomServerBootstrap
  • org.infinispan.client.hotrod.TestHelper
  • org.jboss.netty.bootstrap.ConnectionlessBootstrap
  • org.jboss.netty.bootstrap.ServerBootstrap
  • org.jboss.netty.channel.local.DefaultLocalChannel
  • org.jboss.netty.channel.local.LocalClientChannelSink
  • org.jboss.netty.channel.local.LocalServerChannelSink
  • org.jboss.netty.channel.socket.DefaultDatagramChannelConfig
    • 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.