Examples of send()

Examples of org.agilewiki.jfile.transactions.transactionAggregator.AggregateTransaction.send()

51
52
53
54
55
56
57
58
59
60
61
        openDbFile.send(future, db2);
        System.out.println("online");
        TransactionAggregator transactionAggregator2 = db2.getTransactionAggregator();
        aggregateIncrementTransaction.sendEvent(transactionAggregator2);
        aggregateIncrementTransaction.sendEvent(transactionAggregator2);
        int total2 = (Integer) aggregateGetTransaction.send(future, transactionAggregator2);
        assertEquals(3, total2);
        db2.closeDbFile();

        System.out.println("db3");
        IMDB db3 = new IMDB(mailboxFactory, factory, directoryPath);
View Full Code Here

Examples of org.agilewiki.jid.collection.IGet.send()

52
53
54
55
56
57
58
59
60
61
62
            Actor t0 = tjf.newActor(factory.getMailbox(), factory);
            IGet iget0 = new IGet(0);
            IGet iget1 = new IGet(1);
            Actor e0 = iget0.send(future, t0);
            assertNull(GetString.req.send(future, e0));
            Actor e1 = iget1.send(future, t0);
            assertNull(GetString.req.send(future, e1));
            (new SetString("Apples")).send(future, e0);
            assertEquals("Apples", GetString.req.send(future, e0));
            (new SetString("Oranges")).send(future, e1);
            assertEquals("Oranges", GetString.req.send(future, e1));
View Full Code Here

Examples of org.agilewiki.jid.collection.vlenc.IAdd.send()

29
30
31
32
33
34
35
36
37
38
39
        root.initialize(mailbox, factory);
        (new SetActor("sum")).send(future, root);
        Sum sum = (Sum) (new ResolvePathname("0")).send(future, root);
        IAdd iAdd = new IAdd(-1);
        IGet iGet = new IGet(-1);
        iAdd.send(future, sum);
        IntegerJid ij0 = (IntegerJid) iGet.send(future, sum);
        (new SetInteger(1)).send(future, ij0);
        iAdd.send(future, sum);
        IntegerJid ij1 = (IntegerJid) iGet.send(future, sum);
        (new SetInteger(2)).send(future, ij1);
View Full Code Here

Examples of org.agilewiki.jid.scalar.vlens.actor.SetActor.send()

36
37
38
39
40
41
42
43
44
45
46
            assertTrue(GetBoolean.req.send(future, boolean2));
            assertTrue(GetBoolean.req.send(future, boolean3));

            Actor jidJid1 = ActorJidFactory.fac.newActor(factory.getMailbox(), factory);
            SetActor sjvb = new SetActor(JidFactories.BOOLEAN_JID_TYPE);
            sjvb.send(future, jidJid1);
            BooleanJid rpa = (BooleanJid) (new ResolvePathname("0")).send(future, jidJid1);
            assertFalse(GetBoolean.req.send(future, rpa));
            (new SetBoolean(true)).send(future, rpa);
            rpa = (BooleanJid) (new ResolvePathname("0")).send(future, jidJid1);
            assertTrue(GetBoolean.req.send(future, rpa));
View Full Code Here

Examples of org.agorava.api.oauth.OAuthRequest.send()

85
86
87
88
89
90
91
92
93
94
95
        request.addOAuthParameter(AgoravaConstants.CALLBACK, config.getCallback());
        addOAuthParams(request, AgoravaConstants.EMPTY_TOKEN);
        appendSignature(request);

        LOGGER.fine("sending request...");
        Response response = request.send(tuner);
        //todo:should check return code and launch ResponseException if it's not 200
        String body = response.getBody();

        LOGGER.fine("response status code: " + response.getCode());
        LOGGER.fine("response body: " + body);
View Full Code Here

Examples of org.agorava.rest.OAuthRequestImpl.send()

52
53
54
55
56
57
58
59
60
61
62
        request.addBodyParameter(AgoravaConstants.CODE, verifier.getValue());
        request.addBodyParameter(AgoravaConstants.REDIRECT_URI, config.getCallback());
        request.addBodyParameter("grant_type", "authorization_code");
        if (config.hasScope())
            request.addBodyParameter(AgoravaConstants.SCOPE, config.getScope());
        Response response = request.send(); //todo:should check return code and launch ResponseException if it's not 200
        return api.getAccessTokenExtractor().extract(response.getBody());
    }

    @Override
    public OAuth.OAuthVersion getVersion() {
View Full Code Here

Examples of org.ajax4jsf.javascript.DnDScript.send()

62
63
64
65
66
67
68
69
70
71
72
   */
  public void testSend() {
    DnDScript resource = new DnDScript();
        ResourceContext context = new FacesResourceContext(facesContext);
        try {
      resource.send(context);
    } catch (IOException e) {
      e.printStackTrace();
      assertTrue("error send style",false);
    }
  }
View Full Code Here

Examples of org.ajax4jsf.resource.InternetResource.send()

388
389
390
391
392
393
394
395
396
397
398
          ByteArrayOutputStream baos = new ByteArrayOutputStream();
          response.setOutputStream(new MockServletOutputStream(baos));
         
          resource.sendHeaders(resourceContext);
          resource.send(resourceContext);
         
          return new WebResponseImpl(
              new WebResponseData(
                  new ByteArrayInputStream(baos.toByteArray()),
                  HttpServletResponse.SC_OK,
View Full Code Here

Examples of org.ajax4jsf.webapp.CacheContent.send()

209
210
211
212
213
214
215
216
217
218
219
            response.setDateHeader("Expires", System
                .currentTimeMillis()
                + InternetResource.DEFAULT_EXPIRE);
          }
          if (!request.getMethod().equals("HEAD")) {
            content.send(response);
          }
        } catch (CacheException e) {
          log.error(
              Messages.getMessage(Messages.SEND_RESOURCE_ERROR),
              e);
View Full Code Here

Examples of org.apache.accumulo.server.tabletserver.mastermessage.MasterMessage.send()

2811
2812
2813
2814
2815
2816
2817
2818
2819
2820
2821
          // then
          // finally block should place mm back on queue
          while (!serverStopRequested && mm != null && client != null && client.getOutputProtocol() != null
              && client.getOutputProtocol().getTransport() != null && client.getOutputProtocol().getTransport().isOpen()) {
            try {
              mm.send(SecurityConstants.getSystemCredentials(), getClientAddressString(), iface);
              mm = null;
            } catch (TException ex) {
              log.warn("Error sending message: queuing message again");
              masterMessages.putFirst(mm);
              mm = null;
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.