http://git-wip-us.apache.org/repos/asf/juddi/blob/2c06b736/uddi-tck/src/test/java/org/apache/juddi/v3/tck/UDDI_090_SubscriptionListenerIntegrationTest.java ---------------------------------------------------------------------- diff --git a/uddi-tck/src/test/java/org/apache/juddi/v3/tck/UDDI_090_SubscriptionListenerIntegrationTest.java b/uddi-tck/src/test/java/org/apache/juddi/v3/tck/UDDI_090_SubscriptionListenerIntegrationTest.java deleted file mode 100644 index 5c43eeb..0000000 --- a/uddi-tck/src/test/java/org/apache/juddi/v3/tck/UDDI_090_SubscriptionListenerIntegrationTest.java +++ /dev/null @@ -1,620 +0,0 @@ -package org.apache.juddi.v3.tck; - -/* - * Copyright 2001-2009 The Apache Software Foundation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -import java.io.File; -import java.io.FileOutputStream; -import java.util.Iterator; -import java.util.Properties; -import java.util.Random; - -import javax.xml.ws.Endpoint; - -import org.apache.commons.configuration.ConfigurationException; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.juddi.v3.client.Release; -import org.apache.juddi.v3.client.config.UDDIClient; -import org.apache.juddi.v3.client.transport.Transport; -import org.uddi.v3_service.UDDIInquiryPortType; -import org.uddi.v3_service.UDDIPublicationPortType; -import org.uddi.v3_service.UDDISecurityPortType; -import org.uddi.v3_service.UDDISubscriptionPortType; - -import java.net.InetAddress; -import java.rmi.RemoteException; -import java.util.ArrayList; -import java.util.List; -import javax.xml.datatype.DatatypeFactory; -import javax.xml.ws.BindingProvider; -import javax.xml.ws.Holder; -import static org.apache.juddi.v3.tck.UDDI_090_SubscriptionListenerExternalTest.updatePublisherBusiness; - -import org.junit.AfterClass; -import org.junit.Assert; -import org.junit.Assume; -import org.junit.BeforeClass; -import org.junit.Ignore; -import org.junit.Test; -import org.uddi.api_v3.BusinessEntity; -import org.uddi.api_v3.Description; -import org.uddi.api_v3.GetBusinessDetail; -import org.uddi.api_v3.GetTModelDetail; -import org.uddi.api_v3.SaveTModel; -import org.uddi.api_v3.TModel; -import org.uddi.sub_v3.DeleteSubscription; -import org.uddi.sub_v3.Subscription; -import org.uddi.sub_v3.SubscriptionFilter; - -/** - * Used during the Maven build process for testing against jUDDI for Subscription Callbacks - * via the Subscription Listener service. Covers HTTP transport tests only<br><br> - * WARNING, when adding changes to this class, you MUST always add the corresponding functions - * to UDDI_090_SubscriptionListenerExternalTest - * - * @author <a href="mailto:[email protected]";>Tom Cunningham</a> - * @author <a href="mailto:[email protected]";>Alex O'Ree</a> - * @see UDDI_090_SubscriptionListenerExternalTest - */ -public class UDDI_090_SubscriptionListenerIntegrationTest { - - private static Log logger = LogFactory.getLog(UDDI_090_SubscriptionListenerIntegrationTest.class); - private static UDDISubscriptionPortType subscriptionMary = null; - private static UDDIInquiryPortType inquiryMary = null; - private static TckTModel tckTModelMary = null; - private static TckBusiness tckBusinessMary = null; - private static TckBusinessService tckBusinessServiceMary = null; - private static TckSubscriptionListener tckSubscriptionListenerMary = null; - private static String hostname = null; - private static UDDISubscriptionPortType subscriptionJoe = null; - private static UDDIInquiryPortType inquiryJoe = null; - private static UDDIPublicationPortType publicationMary = null; - private static UDDIPublicationPortType publicationJoe = null; - private static TckTModel tckTModelJoe = null; - private static TckBusiness tckBusinessJoe = null; - private static TckBusinessService tckBusinessServiceJoe = null; - private static TckSubscriptionListener tckSubscriptionListenerJoe = null; - private static Endpoint endPoint; - private static String authInfoJoe = null; - private static String authInfoMary = null; - private static UDDIClient manager; - private static Integer smtpPort = 25; - private static Integer httpPort = 80; - - @AfterClass - public static void stopManager() throws ConfigurationException { - if (!TckPublisher.isEnabled()) return; - tckTModelJoe.deleteCreatedTModels(authInfoJoe); - tckTModelMary.deleteCreatedTModels(authInfoMary); - manager.stop(); - //shutting down the TCK SubscriptionListener - endPoint.stop(); - endPoint = null; - } - - @BeforeClass - public static void startManager() throws ConfigurationException { - if (!TckPublisher.isEnabled()) return; - try { - smtpPort = 9700 + new Random().nextInt(99); - httpPort = 9600 + new Random().nextInt(99); - Properties properties = new Properties(); - properties.setProperty("juddi.mail.smtp.host", "localhost"); - properties.setProperty("juddi.mail.smtp.port", String.valueOf(smtpPort)); - properties.setProperty("juddi.mail.smtp.from", "[email protected]"); - String version = Release.getRegistryVersion().replaceAll(".SNAPSHOT", "-SNAPSHOT"); - String curDir = System.getProperty("user.dir"); - if (!curDir.endsWith("uddi-tck")) { - curDir += "/uddi-tck"; - } - String path = curDir + "/target/juddi-tomcat-" + version + "/temp/"; - System.out.println("Saving jUDDI email properties to " + path); - File tmpDir = new File(path); - File tmpFile = new File(tmpDir + "/juddi-mail.properties"); - if (!tmpFile.createNewFile()) { - tmpFile.delete(); - tmpFile.createNewFile(); - } - properties.store(new FileOutputStream(tmpFile), "tmp email settings"); - - hostname = InetAddress.getLocalHost().getHostName(); - //bring up the TCK SubscriptionListener - String httpEndpoint = "http://"; + hostname + ":" + httpPort + "/tcksubscriptionlistener"; - System.out.println("Bringing up SubscriptionListener endpoint at " + httpEndpoint); - endPoint = Endpoint.publish(httpEndpoint, new UDDISubscriptionListenerImpl()); - int count = 0; - while (!endPoint.isPublished()) { - httpPort = 9600 + new Random().nextInt(99); - httpEndpoint = "http://"; + hostname + ":" + httpPort + "/tcksubscriptionlistener"; - System.out.println("Bringing up SubscriptionListener endpoint at " + httpEndpoint); - endPoint = Endpoint.publish(httpEndpoint, new UDDISubscriptionListenerImpl()); - count++; - if (count > 10) { - Assert.fail("unable to bring up endpoint"); - } - } - - manager = new UDDIClient(); - manager.start(); - - logger.debug("Getting auth tokens.."); - - - Transport transport = manager.getTransport("uddiv3"); - UDDISecurityPortType security = transport.getUDDISecurityService(); - authInfoJoe = TckSecurity.getAuthToken(security, TckPublisher.getJoePublisherId(), TckPublisher.getJoePassword()); - authInfoMary = TckSecurity.getAuthToken(security, TckPublisher.getMaryPublisherId(), TckPublisher.getMaryPassword()); - //Assert.assertNotNull(authInfoJoe); - - - - publicationJoe = transport.getUDDIPublishService(); - inquiryJoe = transport.getUDDIInquiryService(); - subscriptionJoe = transport.getUDDISubscriptionService(); - if (!TckPublisher.isUDDIAuthMode()) { - TckSecurity.setCredentials((BindingProvider) publicationJoe, TckPublisher.getJoePublisherId(), TckPublisher.getJoePassword()); - TckSecurity.setCredentials((BindingProvider) inquiryJoe, TckPublisher.getJoePublisherId(), TckPublisher.getJoePassword()); - TckSecurity.setCredentials((BindingProvider) subscriptionJoe, TckPublisher.getJoePublisherId(), TckPublisher.getJoePassword()); - } - - - tckTModelJoe = new TckTModel(publicationJoe, inquiryJoe); - tckBusinessJoe = new TckBusiness(publicationJoe, inquiryJoe); - tckBusinessServiceJoe = new TckBusinessService(publicationJoe, inquiryJoe); - tckSubscriptionListenerJoe = new TckSubscriptionListener(subscriptionJoe, publicationJoe); - - - - - transport = manager.getTransport("uddiv3"); - publicationMary = transport.getUDDIPublishService(); - inquiryMary = transport.getUDDIInquiryService(); - subscriptionMary = transport.getUDDISubscriptionService(); - if (!TckPublisher.isUDDIAuthMode()) { - TckSecurity.setCredentials((BindingProvider) publicationMary, TckPublisher.getMaryPublisherId(), TckPublisher.getMaryPassword()); - TckSecurity.setCredentials((BindingProvider) inquiryMary, TckPublisher.getMaryPublisherId(), TckPublisher.getMaryPassword()); - TckSecurity.setCredentials((BindingProvider) subscriptionMary, TckPublisher.getMaryPublisherId(), TckPublisher.getMaryPassword()); - } - - - tckTModelMary = new TckTModel(publicationMary, inquiryMary); - tckTModelMary.saveMaryPublisherTmodel(authInfoMary); - - tckBusinessMary = new TckBusiness(publicationMary, inquiryMary); - tckBusinessServiceMary = new TckBusinessService(publicationMary, inquiryMary); - tckSubscriptionListenerMary = new TckSubscriptionListener(subscriptionMary, publicationMary); - - } catch (Exception e) { - logger.error(e.getMessage(), e); - Assert.fail("Could not obtain authInfo token."); - } - } - - @Test - public void joePublisherUpdate_HTTP_FIND_SERVICE() { - Assume.assumeTrue(TckPublisher.isEnabled()); - logger.info("joePublisherUpdate_HTTP_FIND_SERVICE"); - try { - TckCommon.removeAllExistingSubscriptions(authInfoJoe, subscriptionJoe); - String before = TckCommon.DumpAllServices(authInfoJoe, inquiryJoe); - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - tckTModelJoe.saveJoePublisherTmodel(authInfoJoe); - tckBusinessJoe.saveJoePublisherBusiness(authInfoJoe); - //Saving the binding template that will be called by the server for a subscription event - tckBusinessServiceJoe.saveJoePublisherService(authInfoJoe); - //Saving the HTTP Listener Service - tckSubscriptionListenerJoe.saveService(authInfoJoe, TckSubscriptionListener.LISTENER_HTTP_SERVICE_XML, httpPort, hostname); - //Saving the HTTP Subscription - tckSubscriptionListenerJoe.saveNotifierSubscription(authInfoJoe, "uddi_data/subscriptionnotifier/subscription1.xml"); - //Changing the service we subscribed to "JoePublisherService" - Thread.sleep(1000); - logger.info("Updating Service ********** "); - tckBusinessServiceJoe.updateJoePublisherService(authInfoJoe, "foo"); - - //waiting up to 100 seconds for the listener to notice the change. - for (int i = 0; i < TckPublisher.getSubscriptionTimeout(); i++) { - Thread.sleep(1000); - System.out.print("."); - if (UDDISubscriptionListenerImpl.notificationCount > 0) { - logger.info("Received HTTP Notification"); - break; - } - } - Iterator<String> iterator = UDDISubscriptionListenerImpl.notifcationMap.values().iterator(); - boolean found = false; - while (iterator.hasNext()) { - String test = iterator.next(); - if (test.toLowerCase().contains("service one")) { - found = true; - } - } - if (!found) { - logger.warn("Test failed, dumping service list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllServices(authInfoJoe, inquiryJoe)); - //if (!UDDISubscriptionListenerImpl.notifcationMap.get(0).contains("<name xml:lang=\"en\">Service One</name>")) { - Assert.fail("Notification does not contain the correct service"); - } - } catch (Exception e) { - logger.error("No exceptions please."); - e.printStackTrace(); - - Assert.fail(); - } finally { - tckSubscriptionListenerJoe.deleteNotifierSubscription(authInfoJoe, "uddi:uddi.joepublisher.com:subscriptionone"); - tckBusinessServiceJoe.deleteJoePublisherService(authInfoJoe); - tckBusinessJoe.deleteJoePublisherBusiness(authInfoJoe); - tckTModelJoe.deleteJoePublisherTmodel(authInfoJoe); - } - } - - - @Test - public void joePublisherUpdate_HTTP_FIND_BUSINESS() { - Assume.assumeTrue(TckPublisher.isEnabled()); - logger.info("joePublisherUpdate_HTTP_FIND_BUSINESS"); - try { - TckCommon.removeAllExistingSubscriptions(authInfoJoe, subscriptionJoe); - TckCommon.DeleteBusiness(TckBusiness.MARY_BUSINESS_KEY, authInfoMary, publicationMary); - String before = TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe); - Thread.sleep(5000); - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - tckTModelJoe.saveJoePublisherTmodel(authInfoJoe); - tckBusinessJoe.saveJoePublisherBusiness(authInfoJoe); - tckBusinessServiceJoe.saveJoePublisherService(authInfoJoe); - //Saving the Listener Service - logger.info("Saving Joe's callback endpoint ********** "); - tckSubscriptionListenerJoe.saveService(authInfoJoe, TckSubscriptionListener.LISTENER_HTTP_SERVICE_XML, httpPort, hostname); - //Saving the Subscription - logger.info("Saving Joe's subscription********** "); - tckSubscriptionListenerJoe.saveNotifierSubscription(authInfoJoe, "uddi_data/subscriptionnotifier/subscription2.xml"); - //Changing the service we subscribed to "JoePublisherService" - - logger.info("Clearing the inbox********** "); - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - Thread.sleep(2000); - logger.info("Saving Mary's Business ********** "); - tckBusinessMary.saveMaryPublisherBusiness(authInfoMary); - - //waiting up to 10 seconds for the listener to notice the change. - - for (int i = 0; i < TckPublisher.getSubscriptionTimeout(); i++) { - Thread.sleep(1000); - System.out.print("."); - //if (UDDISubscriptionListenerImpl.notificationCount > 0) { - - //} - } - logger.info("RX " + UDDISubscriptionListenerImpl.notificationCount + " notifications"); - Iterator<String> it = UDDISubscriptionListenerImpl.notifcationMap.values().iterator(); - boolean found = false; - while (it.hasNext()) { - String msg = it.next(); - if (TckCommon.isDebug()) { - logger.info("Notification: " + msg); - } - if (msg.toLowerCase().contains("mary")) { - found = true; - } - - } - if (UDDISubscriptionListenerImpl.notificationCount == 0) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe)); - Assert.fail("No Notification was sent"); - } - if (!found) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe)); - Assert.fail("Notification does not contain the correct service"); - } - } catch (Exception e) { - logger.error("No exceptions please."); - e.printStackTrace(); - - Assert.fail(); - } finally { - tckSubscriptionListenerJoe.deleteNotifierSubscription(authInfoJoe, "uddi:uddi.joepublisher.com:subscriptionone"); - tckBusinessServiceJoe.deleteJoePublisherService(authInfoJoe); - tckTModelJoe.deleteJoePublisherTmodel(authInfoJoe); - TckCommon.DeleteBusiness(TckBusiness.MARY_BUSINESS_KEY, authInfoMary, publicationMary); - //tckBusinessMary.deleteMaryPublisherBusiness(authInfoMary); - } - } - - - //tmodel tests - @Test - public void joePublisherUpdate_HTTP_FIND_TMODEL() { - Assume.assumeTrue(TckPublisher.isEnabled()); - logger.info("joePublisherUpdate_HTTP_FIND_TMODEL"); - TckCommon.removeAllExistingSubscriptions(authInfoJoe, subscriptionJoe); - try { - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - String before=TckCommon.DumpAllTModels(authInfoJoe, inquiryJoe); - tckTModelJoe.saveJoePublisherTmodel(authInfoJoe); - tckTModelJoe.saveTModels(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - tckBusinessJoe.saveJoePublisherBusiness(authInfoJoe); - tckBusinessServiceJoe.saveJoePublisherService(authInfoJoe); - //Saving the Listener Service - tckSubscriptionListenerJoe.saveService(authInfoJoe, TckSubscriptionListener.LISTENER_HTTP_SERVICE_XML, httpPort, hostname); - //Saving the Subscription - tckSubscriptionListenerJoe.saveNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION3_XML); - //Changing the service we subscribed to "JoePublisherService" - Thread.sleep(1000); - logger.info("Deleting tModel ********** "); - tckTModelJoe.deleteTModel(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3, TckTModel.JOE_PUBLISHER_TMODEL_SUBSCRIPTION3_TMODEL_KEY); - - //waiting up to 100 seconds for the listener to notice the change. - - for (int i = 0; i < TckPublisher.getSubscriptionTimeout(); i++) { - Thread.sleep(1000); - System.out.print("."); - if (UDDISubscriptionListenerImpl.notificationCount > 0) { - logger.info("Received Notification"); - break; - } - } - - if (UDDISubscriptionListenerImpl.notificationCount == 0) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllTModels(authInfoJoe, inquiryJoe)); - Assert.fail("No Notification was sent"); - } - if (!UDDISubscriptionListenerImpl.notifcationMap.get(0).contains("<name xml:lang=\"en\">tModel One</name>")) { - Assert.fail("Notification does not contain the correct service"); - } - - } catch (Exception e) { - logger.error("No exceptions please."); - e.printStackTrace(); - - Assert.fail(); - } finally { - tckSubscriptionListenerJoe.deleteNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION_KEY); - tckBusinessServiceJoe.deleteJoePublisherService(authInfoJoe); - tckBusinessJoe.deleteJoePublisherBusiness(authInfoJoe); - tckTModelJoe.deleteJoePublisherTmodel(authInfoJoe); - tckTModelJoe.deleteTModel(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_SUBSCRIPTION3_TMODEL_KEY, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - } - } - - /** - * getBusiness tests - * joe want's updates on mary's business - * @throws Exception - */ - @Test - public void joePublisherUpdate_HTTP_GET_BUSINESS_DETAIL() throws Exception{ - Assume.assumeTrue(TckPublisher.isEnabled()); - logger.info("joePublisherUpdate_HTTP_GET_BUSINESS_DETAIL"); - TckCommon.removeAllExistingSubscriptions(authInfoJoe, subscriptionJoe); - Holder<List<Subscription>> holder=null; - try { - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - String before = TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe); - - tckTModelJoe.saveJoePublisherTmodel(authInfoJoe); - tckTModelJoe.saveTModels(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - - tckTModelMary.saveMaryPublisherTmodel(authInfoMary); - BusinessEntity saveMaryPublisherBusiness = tckBusinessMary.saveMaryPublisherBusiness(authInfoMary); - - tckBusinessJoe.saveJoePublisherBusiness(authInfoJoe); - tckBusinessServiceJoe.saveJoePublisherService(authInfoJoe); - //Saving the Listener Service - tckSubscriptionListenerJoe.saveService(authInfoJoe, TckSubscriptionListener.LISTENER_HTTP_SERVICE_XML, httpPort, hostname); - - //Saving the Subscription - holder = new Holder<List<Subscription>>(); - holder.value = new ArrayList<Subscription>(); - Subscription sub = new Subscription(); - sub.setBindingKey("uddi:uddi.joepublisher.com:bindinglistener"); - sub.setNotificationInterval(DatatypeFactory.newInstance().newDuration(5000)); - sub.setSubscriptionFilter(new SubscriptionFilter()); - sub.getSubscriptionFilter().setGetBusinessDetail(new GetBusinessDetail()); - sub.getSubscriptionFilter().getGetBusinessDetail().getBusinessKey().add(TckBusiness.MARY_BUSINESS_KEY); - - holder.value.add(sub); - subscriptionJoe.saveSubscription(authInfoJoe, holder); - //tckSubscriptionListenerJoe.saveNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION3_XML); - //Changing the service we subscribed to "JoePublisherService" - Thread.sleep(1000); - logger.info("updating Mary's business ********** "); - updatePublisherBusiness(authInfoMary,saveMaryPublisherBusiness, publicationMary); - - logger.info("Waiting " + TckPublisher.getSubscriptionTimeout() + " seconds for delivery"); - //waiting up to 100 seconds for the listener to notice the change. - for (int i = 0; i < TckPublisher.getSubscriptionTimeout(); i++) { - Thread.sleep(1000); - System.out.print("."); - if (UDDISubscriptionListenerImpl.notificationCount > 0) { - // logger.info("Received Notification"); -// break; - } - } - - if (UDDISubscriptionListenerImpl.notificationCount == 0) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe)); - Assert.fail("No Notification was sent"); - } - Iterator<String> it = UDDISubscriptionListenerImpl.notifcationMap.values().iterator(); - StringBuilder sb = new StringBuilder(); - boolean found = false; - while (it.hasNext()) { - String test = it.next(); - sb.append("Message: " + test + System.getProperty("line.separator")); - if (test.contains("Updated Name")) { - found = true; - break; - } - } - if (!found) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe)); - Assert.fail("Notification does not contain the correct service. Messages received: " + sb.toString()); - } - - } catch (Exception e) { - logger.error("No exceptions please."); - e.printStackTrace(); - - Assert.fail(); - } finally { - //tckSubscriptionListenerJoe.deleteNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION_KEY); - DeleteSubscription ds = new DeleteSubscription(); - ds.setAuthInfo(authInfoJoe); - ds.getSubscriptionKey().add(holder.value.get(0).getSubscriptionKey()); - subscriptionJoe.deleteSubscription(ds); - tckBusinessMary.deleteMaryPublisherBusiness(authInfoMary); - tckTModelMary.deleteMaryPublisherTmodel(authInfoMary); - - tckBusinessServiceJoe.deleteJoePublisherService(authInfoJoe); - tckBusinessJoe.deleteJoePublisherBusiness(authInfoJoe); - tckTModelJoe.deleteJoePublisherTmodel(authInfoJoe); - tckTModelJoe.deleteTModel(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_SUBSCRIPTION3_TMODEL_KEY, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - - } - } - - - - - /** - * getBusiness tests - * joe want's updates on mary's business - * @throws Exception - */ - @Test - public void joePublisherUpdate_HTTP_GET_TMODEL_DETAIL() throws Exception{ - Assume.assumeTrue(TckPublisher.isEnabled()); - logger.info("joePublisherUpdate_HTTP_GET_TMODEL_DETAIL"); - TckCommon.removeAllExistingSubscriptions(authInfoJoe, subscriptionJoe); - Holder<List<Subscription>> holder=null; - try { - UDDISubscriptionListenerImpl.notifcationMap.clear(); - UDDISubscriptionListenerImpl.notificationCount = 0; - String before = TckCommon.DumpAllTModels(authInfoJoe, inquiryJoe); - - tckTModelJoe.saveJoePublisherTmodel(authInfoJoe); - tckTModelJoe.saveTModels(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - TModel saveMaryPublisherTmodel = tckTModelMary.saveMaryPublisherTmodel(authInfoMary); - - tckBusinessJoe.saveJoePublisherBusiness(authInfoJoe); - tckBusinessServiceJoe.saveJoePublisherService(authInfoJoe); - //Saving the Listener Service - tckSubscriptionListenerJoe.saveService(authInfoJoe, TckSubscriptionListener.LISTENER_HTTP_SERVICE_XML, httpPort, hostname); - - //Saving the Subscription - holder = new Holder<List<Subscription>>(); - holder.value = new ArrayList<Subscription>(); - Subscription sub = new Subscription(); - sub.setBindingKey("uddi:uddi.joepublisher.com:bindinglistener"); - sub.setNotificationInterval(DatatypeFactory.newInstance().newDuration(5000)); - sub.setSubscriptionFilter(new SubscriptionFilter()); - sub.getSubscriptionFilter().setGetTModelDetail(new GetTModelDetail()); - sub.getSubscriptionFilter().getGetTModelDetail().getTModelKey().add(TckTModel.MARY_PUBLISHER_TMODEL_KEY); - - holder.value.add(sub); - subscriptionJoe.saveSubscription(authInfoJoe, holder); - //tckSubscriptionListenerJoe.saveNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION3_XML); - //Changing the service we subscribed to "JoePublisherService" - Thread.sleep(1000); - logger.info("updating Mary's tModel ********** "); - updateTModel(authInfoMary,saveMaryPublisherTmodel, publicationMary); - - logger.info("Waiting " + TckPublisher.getSubscriptionTimeout() + " seconds for delivery"); - //waiting up to 100 seconds for the listener to notice the change. - for (int i = 0; i < TckPublisher.getSubscriptionTimeout(); i++) { - Thread.sleep(1000); - System.out.print("."); - if (UDDISubscriptionListenerImpl.notificationCount > 0) { - // logger.info("Received Notification"); -// break; - } - } - - if (UDDISubscriptionListenerImpl.notificationCount == 0) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllTModels(authInfoJoe, inquiryJoe)); - Assert.fail("No Notification was sent"); - } - Iterator<String> it = UDDISubscriptionListenerImpl.notifcationMap.values().iterator(); - StringBuilder sb = new StringBuilder(); - boolean found = false; - while (it.hasNext()) { - String test = it.next(); - sb.append("Message: " + test + System.getProperty("line.separator")); - if (test.contains("a new description")) { - found = true; - break; - } - } - if (!found) { - logger.warn("Test failed, dumping business list"); - logger.warn("BEFORE " + before); - logger.warn("After " + TckCommon.DumpAllBusinesses(authInfoJoe, inquiryJoe)); - logger.warn("Messages RX " + sb.toString()); - Assert.fail("Notification does not contain the correct service. Messages received: " + sb.toString()); - } - - } catch (Exception e) { - logger.error("No exceptions please."); - e.printStackTrace(); - - Assert.fail(); - } finally { - //tckSubscriptionListenerJoe.deleteNotifierSubscription(authInfoJoe, TckSubscriptionListener.SUBSCRIPTION_KEY); - DeleteSubscription ds = new DeleteSubscription(); - ds.setAuthInfo(authInfoJoe); - ds.getSubscriptionKey().add(holder.value.get(0).getSubscriptionKey()); - subscriptionJoe.deleteSubscription(ds); - //tckBusinessMary.deleteMaryPublisherBusiness(authInfoMary); - tckTModelMary.deleteMaryPublisherTmodel(authInfoMary); - - tckBusinessServiceJoe.deleteJoePublisherService(authInfoJoe); - tckBusinessJoe.deleteJoePublisherBusiness(authInfoJoe); - tckTModelJoe.deleteJoePublisherTmodel(authInfoJoe); - tckTModelJoe.deleteTModel(authInfoJoe, TckTModel.JOE_PUBLISHER_TMODEL_SUBSCRIPTION3_TMODEL_KEY, TckTModel.JOE_PUBLISHER_TMODEL_XML_SUBSCRIPTION3); - - } - } - - - //TODO If a subscriber specifies a maximum number of entries to be returned with a subscription and the amount of data to be returned exceeds -//this limit, or if the node determines based on its policy that there are too many entries to be returned in a single group, - //then the node SHOULD provide a chunkToken with results. - //TODO If no more results are pending, the value of the chunkToken MUST be "0". - - public static void updateTModel(String authInfoMary, TModel saveMaryPublisherTmodel, UDDIPublicationPortType publicationMary) throws Exception { - saveMaryPublisherTmodel.getDescription().add(new Description("a new description",null)); - SaveTModel stm = new SaveTModel(); - stm.setAuthInfo(authInfoMary); - stm.getTModel().add(saveMaryPublisherTmodel); - publicationMary.saveTModel(stm); - } -}
--------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
