oracle.syndication.server.transport.http
Class HttpTransProtocolManager

java.lang.Object
  |
  +--oracle.syndication.server.transport.http.HttpTransProtocolManager

public class HttpTransProtocolManager
extends java.lang.Object
implements OSSTransProtocolManager, oracle.xml.parser.v2.XMLConstants

This implementation of the OSSTransProtocolManager relies on the facilities of the HttpServletRequest and HttpServletResponse classes.

Since:
9.0.0.0.0 Beta

Constructor Summary
HttpTransProtocolManager()
          used by the requestor
HttpTransProtocolManager(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)
          This instance of the OSSTransProtocolManager is created using an HttpServletRequest and an HttpServletResponse.
 
Method Summary
TypeMethod
static void augment(org.w3c.dom.Document doc, java.lang.String szURL)
          Augments a DOM Document by adding another layer above called ice-push-package with an attribute called push-url whose value we set.
 void destroy()
          This allows clean up of the transport layer.
 boolean isPushing()
          Tells if we are pushing
static void main(java.lang.String[] args)
           
 OSSRequest readRequest()
          This method reads a request from a transport layer
 OSSResponse sendRequest(HTTPClient.URI destURI, OSSRequest req)
          This method is used for the syndication entity ( Server: PUSH or Broadcasting; Client: Send request )
 void setPushing(oracle.ds.driver.DSConnection dsConn, java.lang.String szSubscriberURL)
          This lets us know that we have a sink for writing to Dynamic Services.
 void setRequestAsReader(java.io.Reader rd)
           
 void setResponseWriter(java.io.PrintWriter pw)
           
 void writeResponse(OSSResponse resp)
          This method represents the functionality to write to a sink whatever messages are to be written.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HttpTransProtocolManager

public HttpTransProtocolManager(javax.servlet.http.HttpServletRequest req,
                                javax.servlet.http.HttpServletResponse resp)
                         throws java.io.IOException
This instance of the OSSTransProtocolManager is created using an HttpServletRequest and an HttpServletResponse.

HttpTransProtocolManager

public HttpTransProtocolManager()
used by the requestor
Method Detail

setPushing

public void setPushing(oracle.ds.driver.DSConnection dsConn,
                       java.lang.String szSubscriberURL)
This lets us know that we have a sink for writing to Dynamic Services. The DSConnection being set, it allows us to use Dynamic Services to push responses back to the subscribers.

isPushing

public boolean isPushing()
Tells if we are pushing
Specified by:
isPushing in interface OSSTransProtocolManager

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

augment

public static void augment(org.w3c.dom.Document doc,
                           java.lang.String szURL)
Augments a DOM Document by adding another layer above called ice-push-package with an attribute called push-url whose value we set.

writeResponse

public void writeResponse(OSSResponse resp)
                   throws java.io.IOException
This method represents the functionality to write to a sink whatever messages are to be written. This sink is what represents the subscriber and this method will be used by the syndicator
Specified by:
writeResponse in interface OSSTransProtocolManager

readRequest

public OSSRequest readRequest()
This method reads a request from a transport layer
Specified by:
readRequest in interface OSSTransProtocolManager

sendRequest

public OSSResponse sendRequest(HTTPClient.URI destURI,
                               OSSRequest req)
                        throws OSSException
This method is used for the syndication entity ( Server: PUSH or Broadcasting; Client: Send request )
Specified by:
sendRequest in interface OSSTransProtocolManager

destroy

public void destroy()
             throws java.io.IOException
This allows clean up of the transport layer.
Specified by:
destroy in interface OSSTransProtocolManager

setRequestAsReader

public void setRequestAsReader(java.io.Reader rd)

setResponseWriter

public void setResponseWriter(java.io.PrintWriter pw)