Examples of addHaService()

Examples of org.apache.hadoop.gateway.ha.provider.HaProvider.addHaService()

48
49
50
51
52
53
54
55
56
57
58
      HaDescriptor descriptor = new DefaultHaDescriptor();
      HaProvider provider = new DefaultHaProvider(descriptor);
      ArrayList<String> urls = new ArrayList<String>();
      urls.add("http://host1");
      urls.add("http://host2");
      provider.addHaService("foo", urls);
      assertNull(provider.getActiveURL("bar"));
      String url = provider.getActiveURL("foo");
      assertNotNull(url);
      assertThat(url, isIn(urls));
   }
View Full Code Here

Examples of org.apache.hadoop.gateway.ha.provider.HaProvider.addHaService()

65
66
67
68
69
70
71
72
73
74
75
      String url1 = "http://host1";
      urls.add(url1);
      String url2 = "http://host2";
      urls.add(url2);
      String serviceName = "foo";
      provider.addHaService(serviceName, urls);
      assertEquals(url1, provider.getActiveURL(serviceName));
      provider.markFailedURL(serviceName, url1);
      assertEquals(url2, provider.getActiveURL(serviceName));
      provider.markFailedURL(serviceName, url2);
      assertEquals(url1, provider.getActiveURL(serviceName));
View Full Code Here

Examples of org.apache.hadoop.gateway.ha.provider.HaProvider.addHaService()

88
89
90
91
92
93
94
95
96
97
98
      URI uri1 = new URI( "http://unreachable-host" );
      URI uri2 = new URI( "http://reachable-host" );
      ArrayList<String> urlList = new ArrayList<String>();
      urlList.add(uri1.toString());
      urlList.add(uri2.toString());
      provider.addHaService(serviceName, urlList);
      FilterConfig filterConfig = EasyMock.createNiceMock(FilterConfig.class);
      ServletContext servletContext = EasyMock.createNiceMock(ServletContext.class);

      EasyMock.expect(filterConfig.getInitParameter(WebHdfsHaHttpClientDispatch.RESOURCE_ROLE_ATTRIBUTE)).andReturn(serviceName).anyTimes();
      EasyMock.expect(filterConfig.getServletContext()).andReturn(servletContext).anyTimes();
View Full Code Here

Examples of org.apache.hadoop.gateway.ha.provider.impl.DefaultHaProvider.addHaService()

88
89
90
91
92
93
94
95
96
97
98
      URI uri1 = new URI( "http://unreachable-host" );
      URI uri2 = new URI( "http://reachable-host" );
      ArrayList<String> urlList = new ArrayList<String>();
      urlList.add(uri1.toString());
      urlList.add(uri2.toString());
      provider.addHaService(serviceName, urlList);
      FilterConfig filterConfig = EasyMock.createNiceMock(FilterConfig.class);
      ServletContext servletContext = EasyMock.createNiceMock(ServletContext.class);

      EasyMock.expect(filterConfig.getInitParameter(WebHdfsHaHttpClientDispatch.RESOURCE_ROLE_ATTRIBUTE)).andReturn(serviceName).anyTimes();
      EasyMock.expect(filterConfig.getServletContext()).andReturn(servletContext).anyTimes();
View Full Code Here

Examples of org.apache.hadoop.gateway.ha.provider.impl.DefaultHaProvider.addHaService()

74
75
76
77
78
79
80
81
82
83
84
      String clusterName = (String) servletContext.getAttribute(GatewayServices.GATEWAY_CLUSTER_ATTRIBUTE);
      ServiceRegistry serviceRegistry = services.getService(GatewayServices.SERVICE_REGISTRY_SERVICE);
      HaProvider provider = new DefaultHaProvider(descriptor);
      List<String> serviceNames = descriptor.getEnabledServiceNames();
      for (String serviceName : serviceNames) {
         provider.addHaService(serviceName, serviceRegistry.lookupServiceURLs(clusterName, serviceName));
      }
      servletContext.setAttribute(PROVIDER_ATTRIBUTE_NAME, provider);
   }

   private static URL locateDescriptor(ServletContext context) throws IOException {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.