Package io.ably.lib.transport

Class WebSocketTransport

java.lang.Object

io.ably.lib.transport.WebSocketTransport

All Implemented Interfaces:

ITransport

public class WebSocketTransport
extends Object
implements ITransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WebSocketTransport.Factory	public factory API

Nested classes/interfaces inherited from interface io.ably.lib.transport.ITransport

ITransport.ConnectListener, ITransport.Mode, ITransport.TransportParams

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WebSocketTransport(ITransport.TransportParams params, ConnectionManager connectionManager)	protected constructor

Method Summary

Modifier and Type	Method	Description
void	close()	Close this transport.
void	connect(ITransport.ConnectListener connectListener)	ITransport methods
String	getHost()
String	getURL()	Get connection URL
protected void	preProcessReceivedMessage(ProtocolMessage message)
void	receive(ProtocolMessage msg)
void	send(ProtocolMessage msg)	Send a message on the channel
String	toString()
protected void	turnOffActivityCheckIfPingListenerIsNotSupported()	Visible For Testing

Methods inherited from class java.lang.Object

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

Constructor Details

WebSocketTransport

protected WebSocketTransport(ITransport.TransportParams params,
 ConnectionManager connectionManager)

protected constructor

Method Details

connect

public void connect(ITransport.ConnectListener connectListener)

ITransport methods

Specified by:

connect in interface ITransport

close

public void close()

Description copied from interface: ITransport

Close this transport.

Specified by:

close in interface ITransport

receive

public void receive(ProtocolMessage msg)
             throws AblyException

Specified by:

receive in interface ITransport

Throws:

AblyException

send

public void send(ProtocolMessage msg)
          throws AblyException

Description copied from interface: ITransport

Send a message on the channel

Specified by:

send in interface ITransport

Throws:

AblyException

getHost

public String getHost()

Specified by:

getHost in interface ITransport

preProcessReceivedMessage

protected void preProcessReceivedMessage(ProtocolMessage message)

turnOffActivityCheckIfPingListenerIsNotSupported

protected void turnOffActivityCheckIfPingListenerIsNotSupported()

Visible For Testing We need to turn off activity check for some tests (e.g. io.ably.lib.test.realtime.RealtimeConnectFailTest.disconnect_retry_channel_timeout_jitter_after_consistent_detach[binary_protocol]) Those tests expects that activity checks are passing, but protocol messages are not coming

toString

public String toString()

Overrides:

toString in class Object

getURL

public String getURL()

Description copied from interface: ITransport

Get connection URL

Specified by:

getURL in interface ITransport

Returns: