#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] |