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

private java.lang.String	connectQos
private java.lang.String	connectReturnQos
private java.lang.String	loginName
private java.lang.String	passwd
private XmlBlasterAccessRawBase	xmlBlasterAccess
private java.lang.String	xmlBlasterServletUrl

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

PersistentRequest(XmlBlasterAccessRawBase xmlBlasterAccess, java.lang.String xmlBlasterServletUrl, java.lang.String connectQos)
Connect to the BlasterHttpProxyServlet.

PersistentRequest(XmlBlasterAccessRawBase xmlBlasterAccess, java.lang.String xmlBlasterServletUrl, java.lang.String loginName, java.lang.String passwd)
Connect to the BlasterHttpProxyServlet.

Method Summary

(package private) java.lang.String	getConnectReturnQos()
private void	log(java.lang.String level, java.lang.String text) Log to java console of the browser
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

Field Detail

xmlBlasterServletUrl

private java.lang.String xmlBlasterServletUrl

xmlBlasterAccess

private XmlBlasterAccessRawBase xmlBlasterAccess

connectReturnQos

private java.lang.String connectReturnQos

loginName

private java.lang.String loginName

passwd

private java.lang.String passwd

connectQos

private java.lang.String connectQos

Constructor Detail

PersistentRequest

PersistentRequest(XmlBlasterAccessRawBase xmlBlasterAccess,
                  java.lang.String xmlBlasterServletUrl,
                  java.lang.String loginName,
                  java.lang.String passwd)

Connect to the BlasterHttpProxyServlet.

This is a convenience constructor if you don't want to create the connect QoS yourself.

Parameters:

xmlBlasterAccess - My creator

xmlBlasterServletUrl - "http://localhost:8080/xmlBlaster/BlasterHttpProxyServlet&appletInstanceCount=1"

loginName -

passwd -

PersistentRequest

PersistentRequest(XmlBlasterAccessRawBase xmlBlasterAccess,
                  java.lang.String xmlBlasterServletUrl,
                  java.lang.String connectQos)

Connect to the BlasterHttpProxyServlet.

Parameters:

xmlBlasterAccess - My creator

xmlBlasterServletUrl - "http://localhost:8080/xmlBlaster/BlasterHttpProxyServlet"

connectQos - It must at least contain the "securityService" settings to be evaluated!

See Also:

The interface.connect requirement

Method Detail

getConnectReturnQos

java.lang.String getConnectReturnQos()

log

private void log(java.lang.String level,
                 java.lang.String text)

Log to java console of the browser

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