ibm mq - perl mqseries read event messages -

-

i want read system.admin.qmgr.event event messages. can receive messages, output format not readable.

this perl sub use reading:

    sub readeventmessage() {     $self         = shift; $qmgr         = shift; # name of queue manager $sourceq      = shift; $nmessages    = shift; $count      = 0; $sourcequeue = mqseries::queue->new     (      queuemanager       => $qmgr,      queue              => $sourceq,      #mode               => 'input',      options            => mqoo_input_shared | mqoo_browse,     )|| die ("unable instantiate $qmgr::$sourceq object\n");  while (1)    {    #my $returned_message = mqseries::message->new( data =>"" );   $returned_message = mqseries::message->new(),           #data => {         #   format  => mqevent,         #},         getmsgopts => {                  options => mqseries::mqgmo_browse_next | mqseries::mqgmo_accept_truncated_msg | mqseries::mqgmo_fail_if_quiescing          }      ;    $rc=$sourcequeue->get( message => $returned_message);    if ($rc == 1)       {        $msg_data = $returned_message->data();        #print "returned event message\t======>\n";        #print dumper($msg_data);        #print $msg_data."\n";        $count++;        $msg_header = $returned_message->msgdesc();        $msg_header->{data}=$msg_data;        foreach (keys %$msg_header)                {                 $arg  = "$_:$msg_header->{$_}";                   #                 # encode data                  #                 $arg=~s/\\/\\\\/g;                 $arg=~s/\n/\\n/g;                 if  ( $arg=~/^\s*$/  )                     {                      next;                     }                 print "\n$arg";                }                    if ( defined $nmessages )            {             if ( $nmessages  < ($count +1))                {                 last;                }                }         }     elsif ($rc == -1)        {         $status="\nno more messages found on $sourceq\n \n";          last;               }     else             {         $status="\nerror retrieving messages $sourceq." .         "\ncompcode =" . $sourcequeue->compcode() .          "\nreason   =" . $sourcequeue->reason() . "\n";         last;               }    } }

the output i'm getting is:

 puttime:12065823 replytoq: groupid: useridentifier: encoding:546 applidentitydata: backoutcount:0 format:mqevent msgflags:0 applorigindata: putapplname:qm_h35299 msgtype:8 msgseqnumber:1 codedcharsetid:850 accountingtoken: offset:0 correlid: replytoqmgr:qm_h35299 persistence:1 putdate:20120607 originallength:-1 putappltype:7 expiry:-1 version:2 priority:0 data:   $   ☺   ,   ☺   ☺   ☺    ☻   ♦   d   ▀      0   qm_h35299                                       ♥   ►   ³♥  ♣

data format mqevent, ccsi 850, , encoding 546.

any appreciated.

event messages in programmable message format (pcf). format set of name/type/value triplets in linked list. necessary walk list in order read messages. fortunately, mqseries perl module includes mqseries::message::event class this. various parameters , attributes returned perl hash easy enumerate or access values.


Comments

Post a Comment

Popular posts from this blog

django - How can I change user group without delete record -

-
on website user have 1 group. , user can change group. it's made user.groups.clear() and user.groups.add(new_group) but it's not efficient, because there 2 sql query: delete, insert. how can change group update query? user , group related each other using manytomanyfield . means intersection table exists relating both entities, , if don't specify model map (using through attribute) django creates 1 you. looking @ sources django.contrib.auth.models see that's case. fortunatly, can access intermediary model using through attribute of manager (in case, user.groups.through ). can use regular model. example: >>> alice = user.objects.create_user('alice', 'alice@example.com', 'alicepw') >>> employee = group.objects.create(name='employee') >>> manager = group.objects.create(name='manager') >>> alice.groups.add(employee) >>> alice.groups.all() [<group: employee...
Read more

java - Need to add SOAP security token -

-
i need set custom soap header attribute on jax-ws generated webservice client. case webservice calls must go through proxy server requiring specific token (recieved web request header) present in soap request header. e.g.: 1 carserviceservice service = null; 2 service = new carserviceservice(new url(url), new qname(qname); 3 carserviceendpoint port = service.getcarserviceport(); it seems in line 3 wsdl retrieved , call fails due missing security token. 1 point direction on how done? a detailed example has been mentioned here: creating , deploying jax-ws web service on tomcat 6 this article shows how create , use security token .
Read more

java - EclipseLink JPA Object is not a known entity type -

-
i have strange problem eclipselink , object want persist. have 1 object (keypointlistimpl) stores object keypointimpl in list. persisting keypointimpl objects works great if try persist keypointlistimpl object java.lang.illegalargumentexception says object keypointimpl isn't known entity type. here keypointimpl code: @entity @table(name="keypoints") public class keypointimpl implements keypoint { @id @generatedvalue(strategy = generationtype.identity) private int id; @enumerated(enumtype.string) private detectortype keypointtype; private float x; private float y; private float size; private float angle; private float response; private int octave; private int classid; ... } here keypointlistimpl code: @entity @table(name="keypointlists") public class keypointlistimpl implements keypointlist { @id @generatedvalue(strategy = generationtype.identity) private int id; @onetoone(cascade={ca...
Read more