#include <bulkDataFlowConsumer.h>
Public Member Functions | |
| BulkDataFlowConsumer (const char *flowname, AVStreams::protocolSpec prot, const char *format) | |
| virtual | ~BulkDataFlowConsumer () |
| virtual int | get_callback (const char *flowname, TAO_AV_Callback *&callback) |
| virtual int | set_protocol_object (const char *flowname, TAO_AV_Protocol_Object *object) |
| virtual TAO_AV_Protocol_Object * | getProtocolObject () |
| virtual TReceiverCallback * | getBulkDataCallback () |
| virtual void | set_flow_handler (const char *flowname, TAO_AV_Flow_Handler *handler) |
| virtual TAO_AV_Flow_Handler * | getFlowHandler () |
| virtual void | setCbTimeout (ACE_Time_Value cbTimeout) |
Private Attributes | |
| TReceiverCallback * | cb_p |
| ACE_CString | flowname_m |
| TAO_AV_Protocol_Object * | protObj_p |
| TAO_AV_Flow_Handler * | handler_p |
| ACE_Time_Value | cbTimeout_m |
| AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::BulkDataFlowConsumer | ( | const char * | flowname, | |
| AVStreams::protocolSpec | prot, | |||
| const char * | format | |||
| ) |
Constructor
| flowname | ||
| AVStreams::protocolSpec | ||
| format |
|
| virtual AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::~BulkDataFlowConsumer | ( | ) | [virtual] |
Destructor
| virtual int AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::get_callback | ( | const char * | flowname, | |
| TAO_AV_Callback *& | callback | |||
| ) | [virtual] |
Creates the application callback and return its handle to AVStreams for further application callbacks. This callback will be used to store data e.g. in the Archive.
| flowname | ||
| TAO_AV_Callback |
| virtual TReceiverCallback* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getBulkDataCallback | ( | ) | [virtual] |
| virtual TAO_AV_Flow_Handler* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getFlowHandler | ( | ) | [virtual] |
| virtual TAO_AV_Protocol_Object* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getProtocolObject | ( | ) | [virtual] |
Get the protocol object
| virtual void AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::set_flow_handler | ( | const char * | flowname, | |
| TAO_AV_Flow_Handler * | handler | |||
| ) | [virtual] |
| virtual int AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::set_protocol_object | ( | const char * | flowname, | |
| TAO_AV_Protocol_Object * | object | |||
| ) | [virtual] |
Set the protocol object
| flowname | ||
| TAO_AV_Protocol_Object |
| virtual void AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::setCbTimeout | ( | ACE_Time_Value | cbTimeout | ) | [inline, virtual] |
TReceiverCallback* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::cb_p [private] |
ACE_Time_Value AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::cbTimeout_m [private] |
ACE_CString AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::flowname_m [private] |
TAO_AV_Flow_Handler* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::handler_p [private] |
TAO_AV_Protocol_Object* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::protObj_p [private] |
1.7.0