test/STOMP_test.ttcn

module STOMP_test 
{


import from STOMP_Types all;




//*******************************************************************************************
//Templates


template STOMPFrame t_message:=
{

  command:=MESSAGE,
  headers:={ {header_name:="foo", header_value:="Hello"}, {header_name:="foo", header_value:="World"}},
  payload:=omit 


}


template STOMPFrame t_send:=
{

  command:=SEND,
  headers:={ {header_name:="destination", header_value:="/queue/a"}, {header_name:="receipt", header_value:="message-12345"}},
  payload:="hello queue a" 


}


template STOMPFrame t_connect:=
{

  command:=CONNECT,
  headers:={ {header_name:="accept-version", header_value:="1.2"}, {header_name:="host", header_value:="stomp.github.org"}},
  payload:=omit


}


template STOMPFrame t_connected:=
{

  command:=CONNECTED,
  headers:={ {header_name:="version", header_value:="1.2"}},
  payload:=omit


}


template STOMPFrame t_error:=
{

  command:=ERROR,
  headers:={ {header_name:="version", header_value:="1.2,2.1"},{header_name:="content-type", header_value:="text/plain"} },
  payload:="Supported protocol versions are 1.2 2.1"


}


template STOMPFrame t_subscribe:=
{

  command:=SUBSCRIBE,
  headers:={ {header_name:="id", header_value:="0"},{header_name:="destination", header_value:="/queue/foo"},{header_name:="ack", header_value:="client"} },
  payload:=omit


}


template STOMPFrame t_unsubscribe:=
{

  command:=UNSUBSCRIBE,
  headers:={ {header_name:="id", header_value:="0"} },
  payload:=omit


}


template STOMPFrame t_begin:=
{

  command:=BEGIN,
  headers:={ {header_name:="transaction", header_value:="tx1"} },
  payload:=omit


}

template STOMPFrame t_ack:=
{

  command:=ACK,
  headers:={{header_name:="id", header_value:="0"}, {header_name:="transaction", header_value:="tx1"} },
  payload:=omit


}


template STOMPFrame t_nack:=
{

  command:=NACK,
  headers:={{header_name:="id", header_value:="0"}, {header_name:="transaction", header_value:="tx1"} },
  payload:=omit


}

template STOMPFrame t_commit:=
{

  command:=COMMIT,
  headers:={ {header_name:="transaction", header_value:="tx1"} },
  payload:=omit


}


template STOMPFrame t_abort:=
{

  command:=ABORT,
  headers:={ {header_name:="transaction", header_value:="tx1"} },
  payload:=omit


}

template STOMPFrame t_disconnect:=
{

  command:=DISCONNECT,
  headers:={ {header_name:="receipt", header_value:="77"} },
  payload:=omit


}


template STOMPFrame t_receipt:=
{

  command:=RECEIPT,
  headers:={ {header_name:="receipt-id", header_value:="77"} },
  payload:=omit


}


template STOMPFrame t_message1:=
{

  command:=MESSAGE,
  headers:={ {header_name:="subscription", header_value:="0"}, {header_name:="message-id", header_value:="007"},{header_name:="destination", header_value:="/queue/a"}, {header_name:="content-type", header_value:="text/plain"}},
  payload:="hello queue a"


}



template STOMPFrame t_error1:=
{

  command:=ERROR,
  headers:={ {header_name:="receipt-id", header_value:="message@12345"},{header_name:="content-type", header_value:="text/plain"}, {header_name:="content-length", header_value:="171"},{header_name:="message", header_value:="malformed frame received"} },
  payload:="The message:
  -----
  MESSAGE
  destined:/queue/a
  receipt:message@12345

  Hello queue a!
  -----
  Did not contain a destination header, which is REQUIRED
  for message propagation."


}




control {
  
  var charstring v_char

  log(f_dec_stomp(f_enc_stomp(valueof(t_message))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_send))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_connect))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_connected))))


  log(f_dec_stomp(f_enc_stomp(valueof(t_error))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_subscribe))))


  log(f_dec_stomp(f_enc_stomp(valueof(t_unsubscribe))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_begin))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_ack))))
  log(f_dec_stomp(f_enc_stomp(valueof(t_nack))))


  log(f_dec_stomp(f_enc_stomp(valueof(t_commit))))
  log(f_dec_stomp(f_enc_stomp(valueof(t_abort))))


  log(f_dec_stomp(f_enc_stomp(valueof(t_disconnect))))
  log(f_dec_stomp(f_enc_stomp(valueof(t_receipt))))
  log(f_dec_stomp(f_enc_stomp(valueof(t_message1))))

  log(f_dec_stomp(f_enc_stomp(valueof(t_error1))))

  v_char:="MESSAGE\nsubscription:0\nmessage-id:007\r\ndestination:/queue/a\ncontent-type:text/plain\n\r\nhello queue a@@"

  log(dec_STOMP(v_char))

  


 

}


}