[ http://jira.jboss.com/jira/browse/JBESB-1675?page=all ] Tom Cunningham updated JBESB-1675: ---------------------------------- Fix Version/s: 4.3 -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBESB-1675?page=comments#action_12411215 ] Vinicius Carvalho commented on JBESB-1675: ------------------------------------------ Tom, I would like to add a server output log to this in order to help, but I have some very, very frighting numbers. After JBoss starts with trace log for juddi, log goes to 50M just for start (and sometimes, the selects takes so long, that I'm having issues with deployment, some beans do not even deploy). Ok, first test: Access the /contract page. result = 30M of log, and over 120 seconds waiting for the page (for every request) Second test, send an message to the ESB. Result = 100M of log, over 40 seconds for a response. I'd like to note, that the database (the entire juddidb) has 973 rows, the sum of all rows in the catalog. When we clean the database, our log stays bellow 2M, response time for a ESB message is between 1 and 2 seconds (max), and as I'm writing this, JBoss is trying to stop for over 6 minutes now, over 200M of log have been generated and every line is related to juddi sql statements. I could post the server.log, but I guess (since its over 300M now) it will be bigger than the maximum attach file size. Well, I can post numbers as soon as I analyze the log with some sort of awk/grep combination (like, how many statements per scenario: startup, contract, service invoking, shutdown), I could past some parts of the output as well Also, we had 2 vm crashes due to network problems, when we checked the hs_err log, we checked the the reason was.... JUDDI (man I hate this thing already) We are using the default ESB config, we only changed database access, we are using mysql 5.0 as our SGDB. What else do you guys need? would you want our jboss-esb.xml file? As I said before we have only 14 services, how could be so many selects. I can't imagine this on production, what I've done to pass this right now, is have an mbean that on stop removes the tables from the database. Why can't this be used as a cache? In a Hibernate fashion? Do we need to query every time the binding_template? How often does it change? I work for a Red Hat partner in Brazil, we are on the process of "free to fee" with our customer, we solved the issue by cleaning the table, but I can't guarantee that after a few days running the problem comes back, I really believe it happens only on startup and stop. Best regards (and please, help us ;) ) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBESB-1675?page=comments#action_12411219 ] Vinicius Carvalho commented on JBESB-1675: ------------------------------------------ Just another thing. After droping the tables, the same test as before resulted in a total of 4876 selects, which is a lot if you ask me, but its far less than the other option :(. I really can't imagine why juddi queries all services for every call on the registry, this generate a lot of selects... Regards -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBESB-1675?page=all ] Kevin Conner updated JBESB-1675: -------------------------------- Assignee: (was: Tom Cunningham) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Luc DEW commented on JBESB-1675: -------------------------------- Thanks Bodo for the patch, i would like to apply it for my current project since i noticed that internal ESB communications (between a jms gateway and non-gateway listener) were slow partially due to the services and category lookups in database (I also had 5000 selects created for just on message.). We configured Jboss ESB to persist the juddi tables in Oracle server. I would like to be sure how i can apply your patch: - deploy the sar file in the server's deploy directory - make my ESB archive depends on the "jboss.esb:service=CachedESBRegistry" MBean But am i supposed to reconfigure the jboss ESB sar's registry (jbossesb-properties.xml ) and especially the org.jboss.soa.esb.registry.implementationClass attribute ? Or can i just make the jboss ESB 's sar depend on your MBean and clients will use the RegistryFactory to retrieve the Registry ? I also can't wait for the next release. Hope you will read me Thanks Luc -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Kevin Conner commented on JBESB-1675: ------------------------------------- There are currently eight services created at startup, a summary of the DB accesses will be shown after the commentary. The following sequences are generated when a service has *already been registered* with jUDDI, other operations will be invoked on the first occassion. public void registerEPR(String category, String serviceName, String serviceDescription, EPR epr, String eprDescription) protected Service findService(String category, String serviceName) throws JAXRException The first step when registering an EPR is to locate the service. In order to do this our code searches for the classification we are using to register the services, the SQL being invoked is sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME = ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC param[1] = 'org.jboss.soa.esb.:category' This returns a single row representing the model definition. The next query is to ascertain the correct authorised user of the model. sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL param[1] = 'uuid:C7536010-F786-11DB-A010-E6245C4E79A1' Once we have this information we can query the registry to locate the services BulkResponse response = bqm.findServices(null, findQualifiers, namePatterns, classifications, null); sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE FROM BUSINESS_SERVICE S,SERVICE_CATEGORY C WHERE C.SERVICE_KEY = S.SERVICE_KEY AND ((C.TMODEL_KEY_REF = ? AND C.KEY_VALUE = ?)) ORDER BY S.LAST_UPDATE DESC param[1] = 'uuid:C7536010-F786-11DB-A010-E6245C4E79A1' param[2] = 'JBossESB-Internal' Find all services with the correct category, returning a row for each service within that category (eight in a normal deployment) The next step is to narrow down this list to the right service. sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE,N.NAME FROM BUSINESS_SERVICE S,SERVICE_NAME N WHERE N.SERVICE_KEY = S.SERVICE_KEY AND ((UPPER(NAME) = ?)) AND S.SERVICE_KEY IN (?,?,?,?,?,?,?,?) ORDER BY N.NAME DESC,S.LAST_UPDATE DESC param[1] = 'INVOKERSERVICE' param[2] = 'B5C14C50-5CAB-11DD-ADED-96C4460C4C9A' param[3] = 'B5A55FE0-5CAB-11DD-ADED-A5C22D903D36' param[4] = 'B56E2340-5CAB-11DD-ADED-EFD604928108' param[5] = 'AD3C0DE0-5CAB-11DD-ADED-81D73D5DC0EE' param[6] = 'AA23D160-5CAB-11DD-ADED-A273F824BE84' param[7] = 'AA0F37F0-5CAB-11DD-ADED-E2928732C77E' param[8] = 'A9FC2520-5CAB-11DD-ADED-FD755562266D' param[9] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' This will return a single row for the service in question. Following this jUDDI then obtains the Business Key and service name sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? param[1] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID param[1] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' Having found the services we then make yet another query to obtain the classification and authorised user ClassificationScheme cScheme = bqm.findClassificationSchemeByName(findQualifiers, "org.jboss.soa.esb.:category"); sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME LIKE ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC param[1] = 'org.jboss.soa.esb.:category%' sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL param[1] = 'uuid:C7536010-F786-11DB-A010-E6245C4E79A1' We are now in a position of saving the new EPR by adding a service binding. Obtain the publisher sql is: SELECT PUBLISHER_NAME,EMAIL_ADDRESS,IS_ADMIN,IS_ENABLED,MAX_BUSINESSES,MAX_SERVICES_PER_BUSINESS,MAX_BINDINGS_PER_SERVICE,MAX_TMODELS FROM PUBLISHER WHERE PUBLISHER_ID=? param[1] = 'jbossesb' Create an authentication token sql is: INSERT INTO AUTH_TOKEN (AUTH_TOKEN,PUBLISHER_ID,PUBLISHER_NAME,CREATED,LAST_USED,NUMBER_OF_USES,TOKEN_STATE) VALUES (?,?,?,?,?,0,1) param[1] = 'authToken:8309CCC0-5D4F-11DD-8CC0-C698BD83BA6D' param[2] = 'jbossesb' param[3] = 'JBoss ESB User' param[4] = '2008-07-29 10:19:57.357' param[5] = '2008-07-29 10:19:57.357' Retrieve the publisher for the authentication token we have just created (?) sql is: SELECT PUBLISHER_ID,PUBLISHER_NAME FROM AUTH_TOKEN WHERE AUTH_TOKEN=? param[1] = 'authToken:8309CCC0-5D4F-11DD-8CC0-C698BD83BA6D' Retrieve the state of the authentication token (?) sql is: SELECT TOKEN_STATE FROM AUTH_TOKEN WHERE AUTH_TOKEN=? param[1] = 'authToken:8309CCC0-5D4F-11DD-8CC0-C698BD83BA6D' Retrieve the 'last used' timestamp for the authentication token sql is: SELECT LAST_USED FROM AUTH_TOKEN WHERE AUTH_TOKEN=? param[1] = 'authToken:8309CCC0-5D4F-11DD-8CC0-C698BD83BA6D' Update the 'last used' token sql is: UPDATE AUTH_TOKEN SET LAST_USED=?,NUMBER_OF_USES=NUMBER_OF_USES+1 WHERE AUTH_TOKEN=? param[1] = '2008-07-29 10:19:57.475' param[2] = 'authToken:8309CCC0-5D4F-11DD-8CC0-C698BD83BA6D' Obtain the business key associated with the service sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? param[1] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' Obtain the business entity/service information (although it does not appear to be used subsequently) sql is: SELECT * FROM BUSINESS_ENTITY e, BUSINESS_SERVICE s WHERE e.BUSINESS_KEY = s.BUSINESS_KEY AND s.SERVICE_KEY=? AND e.PUBLISHER_ID=? param[1] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' param[2] = 'jbossesb' Finally, add the binding sql is: INSERT INTO BINDING_TEMPLATE (SERVICE_KEY,BINDING_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR,LAST_UPDATE) VALUES (?,?,?,?,?,?) param[1] = 'A9CC6290-5CAB-11DD-ADED-C7C43FE3D3A4' param[2] = '83214C60-5D4F-11DD-8C60-D2901B2101B5' param[3] = 'other' param[4] = '<wsa:From xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing">... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... xmlns:jbossesb="http://schemas.jboss.com/ws/2007/01/jbossesb"&g... param[5] = 'null' param[6] = '2008-07-29 10:19:57.487' In total, registering eight EPRs (without defining the services) creates the following access 8 sql is: INSERT INTO AUTH_TOKEN (AUTH_TOKEN,PUBLISHER_ID,PUBLISHER_NAME,CREATED,LAST_USED,NUMBER_OF_USES,TOKEN_STATE) VALUES (?,?,?,?,?,0,1) 8 sql is: INSERT INTO BINDING_TEMPLATE (SERVICE_KEY,BINDING_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR,LAST_UPDATE) VALUES (?,?,?,?,?,?) 16 sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL 16 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? 8 sql is: SELECT * FROM BUSINESS_ENTITY e, BUSINESS_SERVICE s WHERE e.BUSINESS_KEY = s.BUSINESS_KEY AND s.SERVICE_KEY=? AND e.PUBLISHER_ID=? 8 sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID 8 sql is: SELECT LAST_USED FROM AUTH_TOKEN WHERE AUTH_TOKEN=? 8 sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME LIKE ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC 8 sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME = ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC 8 sql is: SELECT PUBLISHER_ID,PUBLISHER_NAME FROM AUTH_TOKEN WHERE AUTH_TOKEN=? 8 sql is: SELECT PUBLISHER_NAME,EMAIL_ADDRESS,IS_ADMIN,IS_ENABLED,MAX_BUSINESSES,MAX_SERVICES_PER_BUSINESS,MAX_BINDINGS_PER_SERVICE,MAX_TMODELS FROM PUBLISHER WHERE PUBLISHER_ID=? 8 sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE FROM BUSINESS_SERVICE S,SERVICE_CATEGORY C WHERE C.SERVICE_KEY = S.SERVICE_KEY AND ((C.TMODEL_KEY_REF = ? AND C.KEY_VALUE = ?)) ORDER BY S.LAST_UPDATE DESC 8 sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE,N.NAME FROM BUSINESS_SERVICE S,SERVICE_NAME N WHERE N.SERVICE_KEY = S.SERVICE_KEY AND ((UPPER(NAME) = ?)) AND S.SERVICE_KEY IN (?,?,?,?,?,?,?,?) ORDER BY N.NAME DESC,S.LAST_UPDATE DESC 8 sql is: SELECT TOKEN_STATE FROM AUTH_TOKEN WHERE AUTH_TOKEN=? 8 sql is: UPDATE AUTH_TOKEN SET LAST_USED=?,NUMBER_OF_USES=NUMBER_OF_USES+1 WHERE AUTH_TOKEN=? The unregister will follow later, although that is much worse than registering -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Kevin Conner commented on JBESB-1675: ------------------------------------- I have been through the scout/jUDDI source code for the registerEPR operation. The following are the associated lines where the main handling occurs. All are 1:1 mappings between our code and (eventually) jUDDI with the exception of the saveServiceBindings call within scout makes two invocations to jUUDI ClassificationScheme cScheme = bqm.findClassificationSchemeByName(findQualifiers, "org.jboss.soa.esb.:category"); FindTModelFunction.execute(RegistryObject) line: 165 sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME = ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC FindTModelFunction.execute(RegistryObject) line: 182 sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL BulkResponse response = bqm.findServices(null, findQualifiers, namePatterns, classifications, null); FindServiceFunction.execute(RegistryObject) line: 181 sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE FROM BUSINESS_SERVICE S,SERVICE_CATEGORY C WHERE C.SERVICE_KEY = S.SERVICE_KEY AND ((C.TMODEL_KEY_REF = ? AND C.KEY_VALUE = ?)) ORDER BY S.LAST_UPDATE DESC FindServiceFunction.execute(RegistryObject) line: 181 sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE,N.NAME FROM BUSINESS_SERVICE S,SERVICE_NAME N WHERE N.SERVICE_KEY = S.SERVICE_KEY AND ((UPPER(NAME) = ?)) AND S.SERVICE_KEY IN (?,?,?,?,?,?,?,?) ORDER BY N.NAME DESC,S.LAST_UPDATE DESC FindServiceFunction.execute(RegistryObject) line: 198 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? FindServiceFunction.execute(RegistryObject) line: 198 sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID ClassificationScheme cScheme = bqm.findClassificationSchemeByName(findQualifiers, "org.jboss.soa.esb.:category"); FindTModelFunction.execute(RegistryObject) line: 165 sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME LIKE ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC FindTModelFunction.execute(RegistryObject) line: 182 sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL br = blm.saveServiceBindings(serviceBindings); BusinessLifeCycleManagerImpl.executeOperation(Object, String) line: 527 GetAuthTokenFunction.execute(RegistryObject) line: 79 sql is: SELECT PUBLISHER_NAME,EMAIL_ADDRESS,IS_ADMIN,IS_ENABLED,MAX_BUSINESSES,MAX_SERVICES_PER_BUSINESS,MAX_BINDINGS_PER_SERVICE,MAX_TMODELS FROM PUBLISHER WHERE PUBLISHER_ID=? GetAuthTokenFunction.execute(RegistryObject) line: 91 sql is: INSERT INTO AUTH_TOKEN (AUTH_TOKEN,PUBLISHER_ID,PUBLISHER_NAME,CREATED,LAST_USED,NUMBER_OF_USES,TOKEN_STATE) VALUES (?,?,?,?,?,0,1) BusinessLifeCycleManagerImpl.executeOperation(Object, String) line: 541 SaveBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 73 sql is: SELECT PUBLISHER_ID,PUBLISHER_NAME FROM AUTH_TOKEN WHERE AUTH_TOKEN=? SaveBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 77 sql is: SELECT TOKEN_STATE FROM AUTH_TOKEN WHERE AUTH_TOKEN=? SaveBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 77 sql is: SELECT LAST_USED FROM AUTH_TOKEN WHERE AUTH_TOKEN=? SaveBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 84 sql is: UPDATE AUTH_TOKEN SET LAST_USED=?,NUMBER_OF_USES=NUMBER_OF_USES+1 WHERE AUTH_TOKEN=? SaveBindingFunction.execute(RegistryObject) line: 90 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? SaveBindingFunction.execute(RegistryObject) line: 96 sql is: SELECT * FROM BUSINESS_ENTITY e, BUSINESS_SERVICE s WHERE e.BUSINESS_KEY = s.BUSINESS_KEY AND s.SERVICE_KEY=? AND e.PUBLISHER_ID=? SaveBindingFunction.execute(RegistryObject) line: 155 sql is: INSERT INTO BINDING_TEMPLATE (SERVICE_KEY,BINDING_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR,LAST_UPDATE) VALUES (?,?,?,?,?,?) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Kevin Conner commented on JBESB-1675: ------------------------------------- The following is a breakdown of a single invocation of unregister EPR. The interesting thing to note from this is the behaviour of the findServiceBindings call, especially the third invocation into jUDDI. The third invocation retrieves the details of the BUSINESS object from the registry and this appears to include the *details of every service in the registry*. So each request into scout, to obtain the service binding, appears to retrieve everything. I am still investigating how to address this but it is easy to see why scout/jUDDI is running slowly. Obtain the category classification and model information ClassificationScheme cScheme = bqm.findClassificationSchemeByName(findQualifiers, "org.jboss.soa.esb.:category"); FindTModelFunction.execute(RegistryObject) line: 165 sql is: SELECT M.TMODEL_KEY,M.LAST_UPDATE,M.NAME,M.DELETED FROM TMODEL M WHERE M.DELETED IS NULL AND M.NAME = ? ORDER BY M.NAME DESC,M.LAST_UPDATE DESC FindTModelFunction.execute(RegistryObject) line: 182 sql is: SELECT AUTHORIZED_NAME,OPERATOR,NAME,LANG_CODE,OVERVIEW_URL,DELETED FROM TMODEL WHERE TMODEL_KEY=? AND DELETED IS NULL Find the service in the registry BulkResponse response = bqm.findServices(null, findQualifiers, namePatterns, classifications, null); FindServiceFunction.execute(RegistryObject) line: 181 sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE FROM BUSINESS_SERVICE S,SERVICE_CATEGORY C WHERE C.SERVICE_KEY = S.SERVICE_KEY AND ((C.TMODEL_KEY_REF = ? AND C.KEY_VALUE = ?)) ORDER BY S.LAST_UPDATE DESC sql is: SELECT S.SERVICE_KEY,S.LAST_UPDATE,N.NAME FROM BUSINESS_SERVICE S,SERVICE_NAME N WHERE N.SERVICE_KEY = S.SERVICE_KEY AND ((UPPER(NAME) = ?)) AND S.SERVICE_KEY IN (?,?,?,?,?,?,?,?) ORDER BY N.NAME DESC,S.LAST_UPDATE DESC FindServiceFunction.execute(RegistryObject) line: 198 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID Find the service bindings (the section within chevrons are repeated multiple times) BulkResponse bulkResponse = bqm.findServiceBindings(service.getKey(),findQualifiers,null,null); BusinessQueryManagerImpl.findServiceBindings(Key, Collection, Collection, Collection) line: 576 FindBindingFunction.execute(RegistryObject) line: 156 sql is: SELECT B.BINDING_KEY,B.LAST_UPDATE FROM BINDING_TEMPLATE B WHERE B.SERVICE_KEY = ? ORDER BY B.LAST_UPDATE DESC FindBindingFunction.execute(RegistryObject) line: 173 sql is: SELECT SERVICE_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE BINDING_KEY=? sql is: SELECT LANG_CODE,DESCR, BINDING_DESCR_ID FROM BINDING_DESCR WHERE BINDING_KEY=? ORDER BY BINDING_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM BINDING_CATEGORY WHERE BINDING_KEY=? ORDER BY CATEGORY_ID sql is: SELECT TMODEL_KEY,OVERVIEW_URL,INSTANCE_PARMS, TMODEL_INSTANCE_INFO_ID FROM TMODEL_INSTANCE_INFO WHERE BINDING_KEY=? ORDER BY TMODEL_INSTANCE_INFO_ID <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<< BusinessQueryManagerImpl.getRegistryObject(String, String) line: 746 GetServiceDetailFunction.execute(RegistryObject) line: 71 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? GetServiceDetailFunction.execute(RegistryObject) line: 82 sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID sql is: SELECT LANG_CODE,DESCR, SERVICE_DESCR_ID FROM SERVICE_DESCR WHERE SERVICE_KEY=? ORDER BY SERVICE_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM SERVICE_CATEGORY WHERE SERVICE_KEY=? ORDER BY CATEGORY_ID sql is: SELECT BINDING_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE SERVICE_KEY=? sql is: SELECT SERVICE_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE BINDING_KEY=? sql is: SELECT LANG_CODE,DESCR, BINDING_DESCR_ID FROM BINDING_DESCR WHERE BINDING_KEY=? ORDER BY BINDING_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM BINDING_CATEGORY WHERE BINDING_KEY=? ORDER BY CATEGORY_ID sql is: SELECT TMODEL_KEY,OVERVIEW_URL,INSTANCE_PARMS, TMODEL_INSTANCE_INFO_ID FROM TMODEL_INSTANCE_INFO WHERE BINDING_KEY=? ORDER BY TMODEL_INSTANCE_INFO_ID <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<< BusinessQueryManagerImpl.getRegistryObject(String, String) line: 753 GetBusinessDetailFunction.execute(RegistryObject) line: 70 sql is: SELECT AUTHORIZED_NAME,OPERATOR FROM BUSINESS_ENTITY WHERE BUSINESS_KEY=? GetBusinessDetailFunction.execute(RegistryObject) line: 81 sql is: SELECT AUTHORIZED_NAME,OPERATOR FROM BUSINESS_ENTITY WHERE BUSINESS_KEY=? sql is: SELECT LANG_CODE,NAME, BUSINESS_NAME_ID FROM BUSINESS_NAME WHERE BUSINESS_KEY=? ORDER BY BUSINESS_NAME_ID sql is: SELECT LANG_CODE,DESCR, BUSINESS_DESCR_ID FROM BUSINESS_DESCR WHERE BUSINESS_KEY=? ORDER BY BUSINESS_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, IDENTIFIER_ID FROM BUSINESS_IDENTIFIER WHERE BUSINESS_KEY=? ORDER BY IDENTIFIER_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM BUSINESS_CATEGORY WHERE BUSINESS_KEY=? ORDER BY CATEGORY_ID sql is: SELECT USE_TYPE,URL, DISCOVERY_URL_ID FROM DISCOVERY_URL WHERE BUSINESS_KEY=? ORDER BY DISCOVERY_URL_ID sql is: SELECT USE_TYPE,PERSON_NAME, CONTACT_ID FROM CONTACT WHERE BUSINESS_KEY=? ORDER BY CONTACT_ID sql is: SELECT USE_TYPE,PHONE_NUMBER, PHONE_ID FROM PHONE WHERE BUSINESS_KEY=? AND CONTACT_ID=? ORDER BY PHONE_ID sql is: SELECT USE_TYPE,EMAIL_ADDRESS, EMAIL_ID FROM EMAIL WHERE BUSINESS_KEY=? AND CONTACT_ID=? ORDER BY EMAIL_ID sql is: SELECT USE_TYPE,SORT_CODE,TMODEL_KEY, ADDRESS_ID FROM ADDRESS WHERE BUSINESS_KEY=? AND CONTACT_ID=? ORDER BY ADDRESS_ID sql is: SELECT LINE,KEY_NAME,KEY_VALUE, ADDRESS_LINE_ID FROM ADDRESS_LINE WHERE BUSINESS_KEY=? AND CONTACT_ID=? AND ADDRESS_ID=? ORDER BY ADDRESS_LINE_ID sql is: SELECT SERVICE_KEY FROM BUSINESS_SERVICE WHERE BUSINESS_KEY=? The following is repeated for each service (8 times) sql is: SELECT BUSINESS_KEY FROM BUSINESS_SERVICE WHERE SERVICE_KEY=? sql is: SELECT LANG_CODE,NAME, SERVICE_NAME_ID FROM SERVICE_NAME WHERE SERVICE_KEY=? ORDER BY SERVICE_NAME_ID sql is: SELECT LANG_CODE,DESCR, SERVICE_DESCR_ID FROM SERVICE_DESCR WHERE SERVICE_KEY=? ORDER BY SERVICE_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM SERVICE_CATEGORY WHERE SERVICE_KEY=? ORDER BY CATEGORY_ID sql is: SELECT BINDING_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE SERVICE_KEY=? sql is: SELECT SERVICE_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE BINDING_KEY=? sql is: SELECT LANG_CODE,DESCR, BINDING_DESCR_ID FROM BINDING_DESCR WHERE BINDING_KEY=? ORDER BY BINDING_DESCR_ID sql is: SELECT TMODEL_KEY_REF,KEY_NAME,KEY_VALUE, CATEGORY_ID FROM BINDING_CATEGORY WHERE BINDING_KEY=? ORDER BY CATEGORY_ID sql is: SELECT TMODEL_KEY,OVERVIEW_URL,INSTANCE_PARMS, TMODEL_INSTANCE_INFO_ID FROM TMODEL_INSTANCE_INFO WHERE BINDING_KEY=? ORDER BY TMODEL_INSTANCE_INFO_ID <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<< Finally, delete the bindings blm.deleteServiceBindings(serviceBindingKeys); BusinessLifeCycleManagerImpl.executeOperation(Object, String) line: 527 GetAuthTokenFunction.execute(RegistryObject) line: 79 sql is: SELECT PUBLISHER_NAME,EMAIL_ADDRESS,IS_ADMIN,IS_ENABLED,MAX_BUSINESSES,MAX_SERVICES_PER_BUSINESS,MAX_BINDINGS_PER_SERVICE,MAX_TMODELS FROM PUBLISHER WHERE PUBLISHER_ID=? GetAuthTokenFunction.execute(RegistryObject) line: 88 sql is: INSERT INTO AUTH_TOKEN (AUTH_TOKEN,PUBLISHER_ID,PUBLISHER_NAME,CREATED,LAST_USED,NUMBER_OF_USES,TOKEN_STATE) VALUES (?,?,?,?,?,0,1) BusinessLifeCycleManagerImpl.executeOperation(Object, String) line: 557 DeleteBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 73 sql is: SELECT PUBLISHER_ID,PUBLISHER_NAME FROM AUTH_TOKEN WHERE AUTH_TOKEN=? DeleteBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 77 sql is: SELECT TOKEN_STATE FROM AUTH_TOKEN WHERE AUTH_TOKEN=? sql is: SELECT LAST_USED FROM AUTH_TOKEN WHERE AUTH_TOKEN=? DeleteBindingFunction(AbstractFunction).getPublisher(AuthInfo, DataStore) line: 82 sql is: UPDATE AUTH_TOKEN SET LAST_USED=?,NUMBER_OF_USES=NUMBER_OF_USES+1 WHERE AUTH_TOKEN=? DeleteBindingFunction.execute(RegistryObject) line: 85 sql is: SELECT SERVICE_KEY,ACCESS_POINT_TYPE,ACCESS_POINT_URL,HOSTING_REDIRECTOR FROM BINDING_TEMPLATE WHERE BINDING_KEY=? DeleteBindingFunction.execute(RegistryObject) line: 93 sql is: SELECT * FROM BUSINESS_ENTITY e, BUSINESS_SERVICE s, BINDING_TEMPLATE t WHERE s.SERVICE_KEY = t.SERVICE_KEY AND e.BUSINESS_KEY = s.BUSINESS_KEY AND t.BINDING_KEY=? AND e.PUBLISHER_ID=? DeleteBindingFunction.execute(RegistryObject) line: 103 sql is: DELETE FROM BINDING_DESCR WHERE BINDING_KEY=? sql is: DELETE FROM BINDING_CATEGORY WHERE BINDING_KEY=? sql is: DELETE FROM TMODEL_INSTANCE_INFO_DESCR WHERE BINDING_KEY=? sql is: DELETE FROM INSTANCE_DETAILS_DOC_DESCR WHERE BINDING_KEY=? sql is: DELETE FROM INSTANCE_DETAILS_DESCR WHERE BINDING_KEY=? sql is: DELETE FROM TMODEL_INSTANCE_INFO WHERE BINDING_KEY=? sql is: DELETE FROM BINDING_TEMPLATE WHERE BINDING_KEY=? 121 statements for one EPR -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Kevin Conner commented on JBESB-1675: ------------------------------------- The object references for a single binding look like the following, ServiceBinding -> Service -> Organisation, but as you traverse up the hierarchy you discover new versions of previous objects. The service contains a fresh copy of each binding and the Organisation contains a fresh copy of each service. Therefore - the original binding will exist in three places (binding, associated service, service in organisation). - the associated service (and each additional binding for that service) will exist twice. - every other service (and associated bindings) will exist once. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBESB-1675?page=com.atlassian.jira.plu... ] Kevin Conner closed JBESB-1675. ------------------------------- Resolution: Done The concept of 'registry interceptors' has been introduced into the registry codebase in order to share the differing concerns across concrete implementations of registries. The InVM functionality has been moved out of the current JAXR registry implementation and is now an interceptor. A second interceptor provided basic (in vm) caching of the registry information and is configured through jbossesb-properties.xml. The caching interceptor does not support clustering (as does the TreeCache implementation attached to this case) but it should be straight forward to modify that version and create a cache which is applicable over a cluster. I have also modified the build to apply an AOP aspect to the scout codebase. This aspect prevents the scout codebase from pulling down the complete ESB registry when querying for service bindings. This is all committed in revision 21337. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira