se.rupy.http

Class Async

java.lang.Object

se.rupy.http.Async

All Implemented Interfaces:

java.lang.Runnable

public class Async
extends java.lang.Object
implements java.lang.Runnable

High speed HTTP async NIO client.

This exists because Apache HAC:

- Can't handle Murphy's law.
- Rarely blocks forever stuck in sun.misc.Unsafe.park().
- Is pretty slow and big (adds ~20-30 ms. and 1.5 MB).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Async.Call Holds the channel and buffer.
static class	Async.Timeout Thrown when SocketChannel.read(ByteBuffer) returns -1.
static class	Async.Work This is your Async callback.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	debug()
void	run()
void	send(java.lang.String host, Async.Work work, int invalidate) Send work to some host.

Methods inherited from class java.lang.Object

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

Method Detail

debug

public boolean debug()

send

public void send(java.lang.String host,
        Async.Work work,
        int invalidate)
          throws java.lang.Exception

Send work to some host. If you are using fuse, throw the event immediately after to avoid async cascades.

Parameters:

invalidate - the number of seconds after which the channel is regarded as unreliable.

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable