org.xmlBlaster.client.protocol.http.common
Class PersistentRequest

java.lang.Object
  java.lang.Thread
      org.xmlBlaster.client.protocol.http.common.PersistentRequest

All Implemented Interfaces:

java.lang.Runnable

public class PersistentRequest
extends java.lang.Thread

Opens a persistent http connection to the servlet which is the proxy to xmlBlaster.

All asynchronous callback messages are received here.

Synchronous requests like subscribe() are NOT handled here.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

void	run() Connect to xmlBlaster.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Connect to xmlBlaster. The InputStream is never closed so the servlet can push new messages to us. To keep the http connection alive we do a ping pong.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread