version 1.7, 2009/11/30 16:49:50
|
version 1.7.4.1, 2013/06/03 22:36:42
|
|
|
const String& className, | const String& className, |
const String& methodName); | const String& methodName); |
| |
|
void getFilterOrHandlerEPR( |
|
WsmEndpointReference& instanceEPR, |
|
const String address, |
|
const String instanceName, |
|
const String className); |
|
|
private: | private: |
| |
void _checkRequiredHeader( | void _checkRequiredHeader( |
|
|
const String& messageId, | const String& messageId, |
const WsmEndpointReference& epr); | const WsmEndpointReference& epr); |
| |
|
WsmRequest* _decodeWSSubscriptionRequest( |
|
WsmReader& wsmReader, |
|
const String& messageId, |
|
WsmEndpointReference& epr, |
|
AutoPtr<WsmRequest> &createHandlerRequest, |
|
AutoPtr<WsmRequest> &createSubRequest, |
|
Boolean &createFilter); |
|
|
|
WsmRequest* _decodeWSUnsubscribeRequest( |
|
WsmReader& wsmReader, |
|
const String& messageId, |
|
WsmEndpointReference& epr, |
|
const String& identifier, |
|
Boolean & deleteFilter, |
|
AutoPtr<WsmRequest> &deleteFilterRequest, |
|
AutoPtr<WsmRequest> &deleteHandlerRequest); |
|
|
bool _isIdentifyRequest(WsmReader& wsmReader); | bool _isIdentifyRequest(WsmReader& wsmReader); |
| |
void _sendIdentifyResponse(Uint32 queueId); | void _sendIdentifyResponse(Uint32 queueId); |
| |
|
void _copyRequestProperties( |
|
WsmRequest *request, |
|
const WsmRequest *originalRequest); |
// The queue to which to forward the decoded WsmRequests. | // The queue to which to forward the decoded WsmRequests. |
WsmProcessor* _wsmProcessor; | WsmProcessor* _wsmProcessor; |
| |