~ubuntu-branches/ubuntu/trusty/nordugrid-arc/trusty

« back to all changes in this revision

Viewing changes to java/examples/ResourceDiscovery.java

  • Committer: Package Import Robot
  • Author(s): Mattias Ellert
  • Date: 2013-05-08 13:48:03 UTC
  • mfrom: (1.1.7)
  • mto: This revision was merged to the branch mainline in revision 15.
  • Revision ID: package-import@ubuntu.com-20130508134803-mrhc5w4d5y7ubyj4
3.0.1 Release

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
//
 
2
// The nordugrid-arc-java package is required. To compile and run this example:
 
3
// 
 
4
// export CLASSPATH=/usr/lib64/java/arc.jar:.
 
5
// export LD_LIBRARY_PATH=/usr/lib64/java
 
6
// javac ResourceDiscovery.java
 
7
// java ResourceDiscovery ldap://index1.nordugrid.org/Mds-vo-name=NorduGrid,o=grid
 
8
//  
 
9
// The PATHs above may vary depending on ARC install location and system
 
10
// architecture. 
 
11
 
 
12
import nordugrid.arc.*; // For the sake of brevity in this example import everything from arc
 
13
 
 
14
public class ResourceDiscovery implements ComputingServiceTypeConsumer
 
15
{
 
16
    public int i;
 
17
    
 
18
    public ResourceDiscovery() {
 
19
      i = 0;
 
20
    }
 
21
    
 
22
    public static void main(String[] args)
 
23
    {
 
24
        // Set up logging to stderr with level VERBOSE (a lot of output will be shown)
 
25
        LogStream_ostream logstdout = new LogStream_ostream(nordugrid.arc.arc.getStdout());
 
26
        logstdout.setFormat(nordugrid.arc.LogFormat.ShortFormat);
 
27
        Logger.getRootLogger().addDestination(logstdout);
 
28
        Logger.getRootLogger().setThreshold(nordugrid.arc.LogLevel.VERBOSE);
 
29
        Logger logger = new Logger(Logger.getRootLogger(), "resourcediscovery");
 
30
 
 
31
        // Create Endpoint object from the passed argument (registry or index service)
 
32
        Endpoint e = new Endpoint(args[0], Endpoint.CapabilityEnum.REGISTRY);
 
33
        
 
34
        // This object holds various attributes, including proxy location and selected services.
 
35
        UserConfig uc = new UserConfig("");
 
36
        
 
37
        // Example Java consumer
 
38
        ResourceDiscovery rd = new ResourceDiscovery();
 
39
        
 
40
        // Create a instance for discovering computing services at the registry service.
 
41
        ComputingServiceRetriever csr = new ComputingServiceRetriever(uc);
 
42
        csr.addConsumer(rd);
 
43
        csr.addEndpoint(e); // Add endpoint ... which initiates discovery.
 
44
        csr._wait(); // Wait for results to be retrieved.
 
45
        
 
46
        for (ComputingServiceType cst : csr) {
 
47
            System.out.println(cst);
 
48
        }
 
49
        
 
50
        System.out.println(rd.i + " services found.");
 
51
    }
 
52
    
 
53
    public void addEntity(ComputingServiceType cst) {
 
54
      i += 1;
 
55
    }
 
56
}