Package com.genesys.wsclient

Examples of com.genesys.wsclient.GenesysEventReceiver$Subscription

78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
        .create();

    // Optional: do a dummy request in order to get a session cookie
    client.createRequest("GET", "/api/v2/diagnostics/version").execute();

    GenesysEventReceiver eventReceiver = client.setupEventReceiver()
        .eventExecutor(eventExecutor)
        .create();
   
    eventReceiver.open();

    EventSubscription subscription = eventReceiver.subscribeAll(new GenesysEventListener() {
      @Override public void eventReceived(GenesysEvent event) {
        System.err.println(
          "Handling event received from channel " + event.getChannel()
          + " in thread " + Thread.currentThread().getName()
          + " with content " + event.getContent());
View Full Code Here
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
      .credentials(TestParams.USERNAME, TestParams.PASSWORD)
      .create();

    client.createRequest("GET", "/api/v2/diagnostics/version").execute();

    GenesysEventReceiver eventReceiver = client.setupEventReceiver()
      .eventExecutor(dummyExecutor)
      .create();

    eventReceiver.subscribeAll(new GenesysEventListener() {
    @Override public void eventReceived(GenesysEvent event) {}
    });
 
    eventReceiver.open();
   
    Thread.sleep(30000000);
  }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
    GenesysClient client = new GenesysClient.Setup()
      .serverUri("http://nonexistanthostanywhere")
      .credentials(TestParams.USERNAME, TestParams.PASSWORD)
      .create();

    GenesysEventReceiver eventReceiver = client.setupEventReceiver()
      .eventExecutor(dummyExecutor)
      .create();

    eventReceiver.open();
  }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    GenesysClient client = new GenesysClient.Setup()
      .serverUri("http://nonexistanthostanywhere")
      .credentials(TestParams.USERNAME, TestParams.PASSWORD)
      .create();

    GenesysEventReceiver eventReceiver = client.setupEventReceiver()
      .eventExecutor(dummyExecutor)
      .create();

    eventReceiver.close();
  }
View Full Code Here
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
    }

    public Object createObject(Attributes attributes) {
        String host = attributes.getValue("host");
        User user = (User) digester.peek();
        Subscription subscription = user.createSubscription(host);
        String autoConnect = attributes.getValue("autoConnect");
        if (autoConnect == null) {
            autoConnect = "false";
        }
        if ("true".equalsIgnoreCase(autoConnect) ||
            "yes".equalsIgnoreCase(autoConnect)) {
            subscription.setAutoConnect(true);
        } else {
            subscription.setAutoConnect(false);
        }
        subscription.setPassword(attributes.getValue("password"));
        subscription.setType(attributes.getValue("type"));
        subscription.setUsername(attributes.getValue("username"));
        return (subscription);
    }
View Full Code Here
153
154
155
156
157
158
159
160
161
162
     * If there are none, a zero-length array is returned.
     */
    public Subscription[] getSubscriptions() {

        synchronized (subscriptions) {
            Subscription results[] = new Subscription[subscriptions.size()];
            return ((Subscription[]) subscriptions.values().toArray(results));
        }

    }
View Full Code Here
276
277
278
279
280
281
282
283
284
285
286
            // Print entries for each defined user and associated subscriptions
            User users[] = findUsers();
            for (int i = 0; i < users.length; i++) {
                writer.print("  ");
                writer.println(users[i]);
                Subscription subscriptions[] =
                    users[i].getSubscriptions();
                for (int j = 0; j < subscriptions.length; j++) {
                    writer.print("    ");
                    writer.println(subscriptions[j]);
                    writer.print("    ");
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
    }

    public Object createObject(Attributes attributes) {
        String host = attributes.getValue("host");
        User user = (User) digester.peek();
        Subscription subscription = user.createSubscription(host);
        String autoConnect = attributes.getValue("autoConnect");
        if (autoConnect == null) {
            autoConnect = "false";
        }
        if ("true".equalsIgnoreCase(autoConnect) ||
            "yes".equalsIgnoreCase(autoConnect)) {
            subscription.setAutoConnect(true);
        } else {
            subscription.setAutoConnect(false);
        }
        subscription.setPassword(attributes.getValue("password"));
        subscription.setType(attributes.getValue("type"));
        subscription.setUsername(attributes.getValue("username"));
        return (subscription);
    }
View Full Code Here
148
149
150
151
152
153
154
155
156
157
     * If there are none, a zero-length array is returned.
     */
    public Subscription[] getSubscriptions() {

        synchronized (subscriptions) {
            Subscription results[] = new Subscription[subscriptions.size()];
            return ((Subscription[]) subscriptions.values().toArray(results));
        }

    }
View Full Code Here
271
272
273
274
275
276
277
278
279
280
281
            // Print entries for each defined user and associated subscriptions
            User users[] = findUsers();
            for (int i = 0; i < users.length; i++) {
                writer.print("  ");
                writer.println(users[i]);
                Subscription subscriptions[] =
                    users[i].getSubscriptions();
                for (int j = 0; j < subscriptions.length; j++) {
                    writer.print("    ");
                    writer.println(subscriptions[j]);
                    writer.print("    ");
View Full Code Here
TOP

Related Classes of com.genesys.wsclient.GenesysEventReceiver$Subscription

  • com.genesys.wsclient.checks.GenesysEventReceiverCheck
  • com.genesys.wsclient.impl.Authentication
  • com.genesys.wsclient.impl.Jetty769HttpRequest
  • com.genesys.wsclient.samples.Samples
  • org.apache.juddi.api.impl.API_099_LoadTests
  • org.apache.juddi.api.impl.UDDISubscriptionImpl
  • org.apache.juddi.samples.UddiSubscribe
  • org.apache.juddi.subscription.notify.Demo
  • org.apache.juddi.v3.client.mapping.UDDIServiceCache
  • org.apache.juddi.v3.tck.JUDDI_101_ClientSubscriptionCallbackAPIIntegrationTest
    • Copyright © 2018 www.massapicom. 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.