org.granite.client.messaging.transport.apache
Class ApacheAsyncTransport

java.lang.Object
  org.granite.client.messaging.transport.AbstractTransport
      org.granite.client.messaging.transport.apache.ApacheAsyncTransport

All Implemented Interfaces:

HTTPTransport, Transport

public class ApacheAsyncTransport
extends AbstractTransport
implements HTTPTransport

Author:

Franck WOLFF

Field Summary

protected org.apache.http.client.CookieStore	cookieStore
protected org.apache.http.impl.nio.client.DefaultHttpAsyncClient	httpClient
protected org.apache.http.params.BasicHttpParams	params

Constructor Summary

ApacheAsyncTransport()

ApacheAsyncTransport(org.apache.http.params.BasicHttpParams params)

Method Summary

void	configure(org.apache.http.impl.nio.client.DefaultHttpAsyncClient client)
void	poll(Channel channel, TransportMessage message)
TransportFuture	send(Channel channel, TransportMessage message)
boolean	start()
void	stop()

Methods inherited from class org.granite.client.messaging.transport.AbstractTransport

addStopListener, getConfiguration, getStatusHandler, removeStopListener, setConfiguration, setStatusHandler

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.transport.Transport

addStopListener, getConfiguration, getStatusHandler, removeStopListener, setConfiguration, setStatusHandler

Field Detail

params

protected final org.apache.http.params.BasicHttpParams params

httpClient

protected org.apache.http.impl.nio.client.DefaultHttpAsyncClient httpClient

cookieStore

protected org.apache.http.client.CookieStore cookieStore

Constructor Detail

ApacheAsyncTransport

public ApacheAsyncTransport()

ApacheAsyncTransport

public ApacheAsyncTransport(org.apache.http.params.BasicHttpParams params)

Method Detail

configure

public void configure(org.apache.http.impl.nio.client.DefaultHttpAsyncClient client)

start

public boolean start()

Specified by:

start in interface Transport

send

public TransportFuture send(Channel channel,
                            TransportMessage message)
                     throws TransportException

Specified by:

send in interface Transport

Throws:

TransportException

poll

public void poll(Channel channel,
                 TransportMessage message)
          throws TransportException

Specified by:

poll in interface Transport

Throws:

TransportException

stop

public void stop()

Specified by:

stop in interface Transport

Overrides:

stop in class AbstractTransport