Package org.jboss.narayana.blacktie.jatmibroker.xatmi

Examples of org.jboss.narayana.blacktie.jatmibroker.xatmi.X_OCTET

41
42
43
44
45
46
47
48
49
50
51
  public EchoServiceTestService() throws ConfigurationException {
    super();
  }

  public Response tpservice(TPSVCINFO svcinfo) throws ConnectionException {
    X_OCTET rcvd = (X_OCTET) svcinfo.getBuffer();
    X_OCTET buffer = (X_OCTET) svcinfo.getConnection().tpalloc("X_OCTET",
        null, rcvd.getByteArray().length);
    buffer.setByteArray(rcvd.getByteArray());
    return new Response(Connection.TPSUCCESS, 0, buffer, 0);
  }
View Full Code Here
14
15
16
17
18
19
20
21
22
23
      .getLogger(RollbackOnlyTpcallTPESVCFAILService.class);

  public Response tpservice(TPSVCINFO svcinfo) throws ConnectionException {
    log.info("test_tpcall_TPESVCFAIL_service");
    int len = 60;
    X_OCTET toReturn = (X_OCTET) svcinfo.getConnection().tpalloc("X_OCTET",
        null, len);
    toReturn.setByteArray("test_tpcall_TPESVCFAIL_service".getBytes());
    return new Response(Connection.TPFAIL, 0, toReturn, 0);
  }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
        return args;
      }
    } else if (args.contains("tx=create")) {
      try {
        byte[] echo = args.getBytes();
        X_OCTET buffer = (X_OCTET) connection.tpalloc("X_OCTET", null,
            echo.length);
        buffer.setByteArray(echo);

        log.info("Invoking TxCreateService...");
        Response response = connection.tpcall("TxCreateService",
            buffer, 0);
        X_OCTET rcvd = (X_OCTET) response.getBuffer();
        String responseData = new String(rcvd.getByteArray());
        log.info("TxCreateService response: " + responseData);

        // check that the remote service created a transaction
        JABTransaction tx = JABTransaction.current();
        if (tx != null) {
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
      }
    }
  }

  public Response tpservice(TPSVCINFO svcinfo) throws ConnectionException {
    X_OCTET rcv = (X_OCTET) svcinfo.getBuffer();
    String rcvd = new String(rcv.getByteArray());
    String resp;
    try {
      resp = serviceRequest(svcinfo.getConnection(), new String(rcvd));
    } catch (javax.naming.NamingException e) {
      log.warn("error: " + e, e);
      resp = e.getMessage();
    }
    X_OCTET buffer = (X_OCTET) svcinfo.getConnection().tpalloc("X_OCTET",
        null, resp.length());
    buffer.setByteArray(resp.getBytes());
    return new Response(Connection.TPSUCCESS, 0, buffer, 0);
  }
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
32
33
      Thread.sleep(timeout * 1000);
      log.info("test_tpcall_TPETIME_service, slept for " + timeout
          + " seconds");

      int len = 60;
      X_OCTET toReturn = (X_OCTET) svcinfo.getConnection().tpalloc(
          "X_OCTET", null, len);
      toReturn.setByteArray("test_tpcall_TPETIME_service".getBytes());
      return new Response(Connection.TPSUCCESS, 0, toReturn, 0);
    } catch (InterruptedException e) {
      return new Response(Connection.TPFAIL, 0, null, 0);
    }
  }
View Full Code Here
TOP

Related Classes of org.jboss.narayana.blacktie.jatmibroker.xatmi.X_OCTET

  • org.jboss.narayana.blacktie.administration.BlacktieAdminServiceXATMI
  • org.jboss.narayana.blacktie.administration.BlacktieStompAdministrationService
  • org.jboss.narayana.blacktie.administration.BlacktieStompAdministrationServiceTest
  • org.jboss.narayana.blacktie.administration.core.AdministrationProxy
  • org.jboss.narayana.blacktie.example.mdb.EchoServiceTestService
  • org.jboss.narayana.blacktie.example.mdb.TxEchoServiceTestService
  • org.jboss.narayana.blacktie.examples.integration1.xatmi_adapter.CreditAdapterService
  • org.jboss.narayana.blacktie.examples.integration1.xatmi_adapter.DebitAdapterService
  • org.jboss.narayana.blacktie.jatmibroker.admin.AdministrationTest
  • org.jboss.narayana.blacktie.jatmibroker.BarService
    • 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.