javamqmsgque 9.0
Loading...
Searching...
No Matches
Example: MyTransaction

Documentation of the MyTransaction tool used for example.test.

INTRODUCTION

The MyTransaction tool is used to test the longterm-transaction-feature of javamqmsgque.

To test this feature the client connect to the server and send two service-calls:

  • one longterm-transaction-service-call using the low-api
  • one longterm-transaction-service-call using the high-api

The service-call itself is quite simple:

  • the private part is a string : Privat_Data_1 or Privat_Data_2
  • the public part is an integer : 1111 or 2222

The GOAL for this test is:

  • test the longterm-transaction-feature
  • test the BufferListCheckOptionC with and without default-value
  • test the callback-feature with and without error

CODE client

package example;

import javamsgque.mqmsgque.*;
import javamsgque.mkkernel.*;

final class MyTransaction extends MqContextC {

  static class CallbackC implements ICallback {
    public void Callback(MqContextC ctx) {
      ctx.ReadT_START();
      String myPrivateHandle = ctx.ReadC();
      ctx.ReadT_END();
      int myServiceResult = ctx.ReadI();

      System.out.println("myPrivateHandle=" + myPrivateHandle + ", myServiceResult=" + myServiceResult);
    }
  }

  public static void main(String[] argv) {
    MyTransaction ctx = new MyTransaction();
    try {
      ctx.ConfigSetName("MyTransaction");

      // setup commandline arguments used for parsing
      MkBufferListC args = new MkBufferListC(argv);

      // check if the '--token' option is available, default "SRVC"
      String token = args.CheckOptionC("--token", "SRVC");

      // connect to the server
      ctx.LinkCreate(args);

      // register callback
      ctx.ServiceCreate("CLB1", new CallbackC());
       
      // send block using the LOW-Api
      ctx.SendSTART();
      ctx.SendT_START();
      ctx.SendC("Privat_Data_1");
      ctx.SendT_END();
      ctx.SendI(11111);
      ctx.SendEND_AND_TRANSACTION(token, "CLB1");
       
      // send block using the HIGN-Api -> same as above, but shorter
      ctx.Send("T", "CLB1", token + ":(C)I", "Privat_Data_2", 22222);
       
      // now we wait for exact ONE result of the "ctx"
      ctx.ProcessEvent(MqWaitOnEventE.OWN);

    } catch (Throwable e) {
      ctx.ErrorCatch(e);
    }
    ctx.Exit();
  }
}