org.granite.client.messaging.channel.amf
Class AMFRemotingChannel

java.lang.Object
  org.granite.client.messaging.channel.AbstractChannel<Transport>
      org.granite.client.messaging.channel.AbstractHTTPChannel
          org.granite.client.messaging.channel.amf.AbstractAMFChannel
              org.granite.client.messaging.channel.amf.AMFRemotingChannel

All Implemented Interfaces:

Runnable, Channel, RemotingChannel, TransportStopListener

Direct Known Subclasses:

JMFAMFRemotingChannel

public class AMFRemotingChannel
extends AbstractAMFChannel
implements RemotingChannel

Author:

Franck WOLFF

Field Summary

protected MessagingCodec<org.granite.messaging.amf.AMF0Message>	codec
protected int	index

Fields inherited from class org.granite.client.messaging.channel.AbstractHTTPChannel

authenticated, defaultTimeToLive, maxConcurrentRequests, pinged

Fields inherited from class org.granite.client.messaging.channel.AbstractChannel

clientId, credentials, id, transport, transportData, uri

Fields inherited from interface org.granite.client.messaging.channel.Channel

BYTEARRAY_BODY_HEADER, RECONNECT_INTERVAL_MS_KEY, RECONNECT_MAX_ATTEMPTS_KEY

Constructor Summary

AMFRemotingChannel(Transport transport, Configuration configuration, String id, URI uri, int maxConcurrentRequests)

AMFRemotingChannel(Transport transport, String id, URI uri)

AMFRemotingChannel(Transport transport, String id, URI uri, int maxConcurrentRequests)

Method Summary

protected TransportMessage	createTransportMessage(AsyncToken token)
protected ResponseMessage	decodeResponse(InputStream is)
protected MessagingCodec<org.granite.messaging.amf.AMF0Message>	newMessagingCodec(Configuration configuration)

Methods inherited from class org.granite.client.messaging.channel.amf.AbstractAMFChannel

convertFromAmf, convertFromAmf, convertToAmf

Methods inherited from class org.granite.client.messaging.channel.AbstractHTTPChannel

getMaxConcurrentRequests, getRequest, isAuthenticated, isStarted, logout, onCancelled, onError, onMessage, onStop, run, schedule, send, start, stop

Methods inherited from class org.granite.client.messaging.channel.AbstractChannel

getClientId, getCredentials, getId, getTransport, getTransportData, getUri, setCredentials, setTransportData

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.granite.client.messaging.channel.Channel

getClientId, getCredentials, getId, getTransport, getTransportData, getUri, isAuthenticated, isStarted, logout, onCancelled, onError, onMessage, send, setCredentials, setTransportData, start, stop

Field Detail

codec

protected final MessagingCodec<org.granite.messaging.amf.AMF0Message> codec

index

protected volatile int index

Constructor Detail

AMFRemotingChannel

public AMFRemotingChannel(Transport transport,
                          String id,
                          URI uri)

AMFRemotingChannel

public AMFRemotingChannel(Transport transport,
                          String id,
                          URI uri,
                          int maxConcurrentRequests)

AMFRemotingChannel

public AMFRemotingChannel(Transport transport,
                          Configuration configuration,
                          String id,
                          URI uri,
                          int maxConcurrentRequests)

Method Detail

newMessagingCodec

protected MessagingCodec<org.granite.messaging.amf.AMF0Message> newMessagingCodec(Configuration configuration)

createTransportMessage

protected TransportMessage createTransportMessage(AsyncToken token)
                                           throws UnsupportedEncodingException

Specified by:

createTransportMessage in class AbstractHTTPChannel

Throws:

UnsupportedEncodingException

decodeResponse

protected ResponseMessage decodeResponse(InputStream is)
                                  throws IOException

Specified by:

decodeResponse in class AbstractHTTPChannel

Throws:

IOException