Qorus Integration Engine®  4.0.3.p2_git
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 Methods

 constructor (hash< auto > cx, *hash< auto > ah)
 creates the object from an inbound request More...
 
- Public Member Methods 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
 

Additional Inherited Members

- Private Attributes inherited from OMQ::ServiceLogBase
code slog
 service logging method call reference
 

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

◆ constructor()

OMQ::AbstractServiceDataStreamResponseHandler::constructor ( hash< auto >  cx,
*hash< auto >  ah 
)

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: