version 1.9, 2006/08/09 21:13:05
|
version 1.10, 2006/10/03 13:40:42
|
|
|
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. |
// | // |
//============================================================================== | //============================================================================== |
// |
|
// Author: Mike Day (mdday@us.ibm.com) |
|
// |
|
// Modified By: |
|
// |
|
//%//////////////////////////////////////////////////////////////////////////// | //%//////////////////////////////////////////////////////////////////////////// |
| |
| |
|
|
DynamicRoutingTable & operator =(const DynamicRoutingTable & table); | DynamicRoutingTable & operator =(const DynamicRoutingTable & table); |
~DynamicRoutingTable(void); | ~DynamicRoutingTable(void); |
| |
static const DynamicRoutingTable get_ro_routing_table(void); |
|
static DynamicRoutingTable get_rw_routing_table(void); | static DynamicRoutingTable get_rw_routing_table(void); |
| |
// get a single service that can route this spec. | // get a single service that can route this spec. |
MessageQueueService *get_routing(const CIMName& classname, | MessageQueueService *get_routing(const CIMName& classname, |
const CIMNamespaceName& ns, | const CIMNamespaceName& ns, |
Uint32 type, | Uint32 type, |
Uint32 flags) const; |
|
|
|
// get a single service that can route this spec. |
|
MessageQueueService *get_routing(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
Uint32 flags, | Uint32 flags, |
String & provider, | String & provider, |
String & module) const; | String & module) const; |
| |
|
|
// get a single service that can route this extended spec. |
|
MessageQueueService *get_routing(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags) const ; |
|
|
|
// get a single service that can route this extended spec. |
|
MessageQueueService *get_routing(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags, |
|
String & provider, |
|
String & module) const ; |
|
|
|
// get an array of services that can route this spec. |
|
void get_routing(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
Uint32 flags, |
|
Array<MessageQueueService *>& results) const; |
|
|
|
// get an array of services that can route this extended spec. |
|
void get_routing(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags, |
|
Array<MessageQueueService *>& results) const ; |
|
|
|
Boolean insert_record(const CIMName& classname, | Boolean insert_record(const CIMName& classname, |
const CIMNamespaceName& ns, | const CIMNamespaceName& ns, |
Uint32 type, | Uint32 type, |
|
|
Boolean insert_record(const CIMName& classname, | Boolean insert_record(const CIMName& classname, |
const CIMNamespaceName& ns, | const CIMNamespaceName& ns, |
Uint32 type, | Uint32 type, |
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags, |
|
MessageQueueService* svce) ; |
|
|
|
Boolean insert_record(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
Uint32 flags, | Uint32 flags, |
MessageQueueService* svce, | MessageQueueService* svce, |
const String& provider, | const String& provider, |
const String& module) ; | const String& module) ; |
|
|
Boolean insert_record(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags, |
|
MessageQueueService* svce, |
|
const String& provider, |
|
const String& module) ; |
|
|
|
MessageQueueService * remove_record(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
Uint32 flags); |
|
|
|
MessageQueueService * remove_record(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags); |
|
Uint32 remove_multiple_records(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
Uint32 flags); |
|
|
|
Uint32 remove_multiple_records(const CIMName& classname, |
|
const CIMNamespaceName& ns, |
|
Uint32 type, |
|
const Array<Uint8>& extended_type, |
|
Uint32 flags, |
|
const Array<Uint8>& extended_flags); |
|
Uint32 remove_router_records(const MessageQueueService* router); |
|
|
|
/** | /** |
Router "types". These are actually keys used in the routing table. | Router "types". These are actually keys used in the routing table. |
A provider manager (or other service provider) that can route messages | A provider manager (or other service provider) that can route messages |
|
|
*/ | */ |
| |
static const Uint32 INTERNAL; // "control providers" | static const Uint32 INTERNAL; // "control providers" |
|
static const Uint32 METHOD; |
static const Uint32 INSTANCE; | static const Uint32 INSTANCE; |
static const Uint32 CLASS; | static const Uint32 CLASS; |
static const Uint32 METHOD; |
|
static const Uint32 ASSOCIATION; |
|
static const Uint32 QUERY; |
|
static const Uint32 INDICATION; |
|
static const Uint32 CONSUMER; |
|
static const Uint32 SERVICE; // derived from MessageQueueService |
|
static const Uint32 AUTHORIZATION; // authorization plug-in |
|
static const Uint32 AUTHENTICATION; // authentication plug-in |
|
static const Uint32 ENCODE_HOOK; // hook to process outbound messages |
|
static const Uint32 DECODE_HOOK; // hook to process incoming messages |
|
static const Uint32 EXTENDED; |
|
|
|
| |
void dump_table(void); | void dump_table(void); |
| |