|
version 1.5, 2005/04/11 16:30:26
|
version 1.6, 2005/06/07 01:27:16
|
|
|
|
| const Uint32 NUM_OPTIONS = sizeof(optionsTable) / sizeof(optionsTable[0]); | const Uint32 NUM_OPTIONS = sizeof(optionsTable) / sizeof(optionsTable[0]); |
| | |
| //retry settings | //retry settings |
| //ATTN: Do we want to make these configurable? If so, is a global setting for all the consumers ok? |
|
| static const Uint32 DEFAULT_MAX_RETRY_COUNT = 5; | static const Uint32 DEFAULT_MAX_RETRY_COUNT = 5; |
| static const Uint32 DEFAULT_RETRY_LAPSE = 10000; //300000; //ms |
static const Uint32 DEFAULT_RETRY_LAPSE = 300000; //ms = 5 minutes |
| | |
| | |
| | |
|
|
|
| idleTimeout); | idleTimeout); |
| | |
| | |
| _optionMgr.registerOptions(optionsTable, NUM_OPTIONS); |
//ATTN: Bugzilla 3765 - Uncomment when OptionManager has a reset capability |
| |
//_optionMgr.registerOptions(optionsTable, NUM_OPTIONS); |
| | |
| struct timeval deallocateWait = {15, 0}; | struct timeval deallocateWait = {15, 0}; |
| _thread_pool = new ThreadPool(0, "ConsumerManager", 0, 0, deallocateWait); | _thread_pool = new ThreadPool(0, "ConsumerManager", 0, 0, deallocateWait); |
|
|
|
| | |
| try | try |
| { | { |
| //ATTN: Does the OptionManager need to be reset? There's no method for it. |
//Bugzilla 3765 - Change this to use a member var when OptionManager has a reset option |
| |
OptionManager _optionMgr; |
| |
_optionMgr.registerOptions(optionsTable, NUM_OPTIONS); //comment this line out later |
| _optionMgr.mergeFile(configFile); | _optionMgr.mergeFile(configFile); |
| _optionMgr.checkRequiredOptions(); | _optionMgr.checkRequiredOptions(); |
| | |
Return to
ConsumerManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / DynListener