Qorus Integration Engine  3.0.4.p7
OMQ::AbstractServiceDataStreamResponseHandler Class Reference

this class implements a request handler supporting the DataStream protocol for Qorus services and allows logging to the service log file More...

Inheritance diagram for OMQ::AbstractServiceDataStreamResponseHandler:
DataStreamRequestHandler::AbstractDataStreamRequestHandler OMQ::ServiceLogBase

Public Member Functions

 constructor (hash $cx, *hash $ah)
 creates the object from an inbound request More...
 
- Public Member Functions inherited from OMQ::ServiceLogBase
 constructor ()
 creates the object and sets the service context for logging
 
 log (int $ll, string $fmt)
 logs to the service log file
 

Detailed Description

this class implements a request handler supporting the DataStream protocol for Qorus services and allows logging to the service log file

this class must be subclassed and then the recvDataImpl() and sendDataImpl() methods reimplemented to provide data receiving and sending support, respectively.

Member Function Documentation

OMQ::AbstractServiceDataStreamResponseHandler::constructor ( hash  $cx,
*hash  $ah 
)
inline

creates the object from an inbound request

Parameters
cxcall context hash; this hash will have the following keys:
  • socket: the bind address used to bind the listener ("socket-info" provides more detailed information)
  • socket-info: a hash of socket information for the listening socket (as returned by Qore::Socket::getSocketInfo())
  • peer-info: a hash of socket information for the remote socket (as returned by Qore::Socket::getPeerInfo())
  • url: a hash of broken-down URL information (as returned from parseURL())
  • id: the unique HTTP connection ID
  • listener-id: the HTTP server listener ID (see HttpServer::getListenerInfo())
  • user: the current RBAC username (if any)
  • hdr: a hash of header information as returned by Qore::Socket::readHTTPHeader()
  • body: the deserialized message body
  • aih: a hash of "Accept" values
ahany URI arguments in the request

The documentation for this class was generated from the following file: