biemond/biemond-orawls

View on GitHub
files/providers/wls_messaging_bridge/index.py.erb

Summary

Maintainability
Test Coverage

m = ls('/MessagingBridges',returnMap='true')

f = open_file("name;target;targettype;asyncenabled;batchinterval;batchsize;durabilityenabled;idletimemax;preservemsgproperty;qosdegradationallowed;qos;reconnectdelayincrease;reconnectdelaymax;reconnectdelaymin;selector;started;transactiontimeout;sourcedestination;targetdestination")
for token in m:
    print '___'+token+'___'
    cd('/MessagingBridges/'+token)

    asyncenabled = get('AsyncEnabled')
    batchinterval = get('BatchInterval')
    batchsize = get('BatchSize')
    durabilityenabled = get('DurabilityEnabled')
    idletimemax = get('IdleTimeMaximum')
    preservemsgproperty = get('PreserveMsgProperty')
    qosdegradationallowed = get('QOSDegradationAllowed')
    qos = get('QualityOfService')
    reconnectdelayincrease = get('ReconnectDelayIncrease')
    reconnectdelaymax = get('ReconnectDelayMaximum')
    reconnectdelaymin = get('ReconnectDelayMinimum')
    selector = get('Selector')
    started = get('Started')
    transactiontimeout = get('TransactionTimeout')

    sourcedestinationMbean = cmo.getSourceDestination()
    if sourcedestinationMbean:
       path = getPath(sourcedestinationMbean)
       cd("/"+path)
       sourcedestination  = get('Name')
       cd('/MessagingBridges/'+token)
    else:
       sourcedestination = ''

    targetdestinationMbean = cmo.getTargetDestination()
    if targetdestinationMbean:
       path = getPath(targetdestinationMbean)
       cd("/"+path)
       targetdestination  = get('Name')
       cd('/MessagingBridges/'+token)
    else:
       targetdestination = ''

    target, targetType = retrieve_target_list('/Deployments/'+token)

    add_index_entry(f, [domain+'/'+token,','.join(target),','.join(targetType),asyncenabled,batchinterval,batchsize,durabilityenabled,idletimemax,preservemsgproperty,qosdegradationallowed,qos,reconnectdelayincrease,reconnectdelaymax,reconnectdelaymin,selector,started,transactiontimeout,sourcedestination,targetdestination])
f.close()
report_back_success()