io.crossbar.autobahn.wamp.transports

Class NettyTransport

java.lang.Object

io.crossbar.autobahn.wamp.transports.NettyTransport

All Implemented Interfaces:

ITransport

public class NettyTransport
extends java.lang.Object
implements ITransport

Constructor Summary

Constructors

Constructor and Description
NettyTransport(java.lang.String uri)
NettyTransport(java.lang.String uri, java.util.concurrent.ExecutorService executor)
NettyTransport(java.lang.String uri, java.util.concurrent.ExecutorService executor, WebSocketOptions options)
NettyTransport(java.lang.String uri, java.util.List<java.lang.String> serializers)
NettyTransport(java.lang.String uri, java.util.List<java.lang.String> serializers, java.util.concurrent.ExecutorService executor)
NettyTransport(java.lang.String uri, WebSocketOptions options)

Method Summary

Modifier and Type	Method and Description
void	abort()
void	close()
void	connect(ITransportHandler transportHandler)
boolean	isOpen()
void	send(byte[] payload, boolean isBinary)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyTransport

public NettyTransport(java.lang.String uri)

NettyTransport

public NettyTransport(java.lang.String uri,
                      java.util.List<java.lang.String> serializers)

NettyTransport

public NettyTransport(java.lang.String uri,
                      WebSocketOptions options)

NettyTransport

public NettyTransport(java.lang.String uri,
                      java.util.concurrent.ExecutorService executor)

NettyTransport

public NettyTransport(java.lang.String uri,
                      java.util.List<java.lang.String> serializers,
                      java.util.concurrent.ExecutorService executor)

NettyTransport

public NettyTransport(java.lang.String uri,
                      java.util.concurrent.ExecutorService executor,
                      WebSocketOptions options)

Method Detail

connect

public void connect(ITransportHandler transportHandler)
             throws java.lang.Exception

Specified by:

connect in interface ITransport

Throws:

java.lang.Exception

send

public void send(byte[] payload,
                 boolean isBinary)

Specified by:

send in interface ITransport

isOpen

public boolean isOpen()

Specified by:

isOpen in interface ITransport

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface ITransport

Throws:

java.lang.Exception

abort

public void abort()
           throws java.lang.Exception

Specified by:

abort in interface ITransport

Throws:

java.lang.Exception