TP1/Message Queue - Access 使用の手引

Transcription

1 OpenTP1 Version 7 TP1/Message Queue - Access D94-10

2 P-1M64-C771 ucosminexus TP1/Message Queue - Access OSAIX 5L V5.1AIX 5L V5.2 AIX 5L V5.3 P-1J64-C871 ucosminexus TP1/Message Queue - Access OSHP-UX 11i V2IPF P-9S64-C771 ucosminexus TP1/Message Queue - Access OSRed Hat Enterprise Linux AS 4Red Hat Enterprise Linux ES 4x86AMD64Intel EM64T P-9V64-C771 ucosminexus TP1/Message Queue - Access OSRed Hat Enterprise Linux AS 4IPF P-2464-C774 ucosminexus TP1/Message Queue - Access OSWindows Server 2003 x64 EditionsWindows Server 2003Windows XPWindows Vista32 ISO9001 TickIT AIX International Business Machines Corp. HP-UX Hewlett-Packard Company IBM International Business Machines Corp. Java Java Sun Microsystems, Inc. Linux Linus Torvalds Microsoft Microsoft Corp. MQSeries International Business Machines Corp. MS-DOS Microsoft Corp. OS/2 International Business Machines Corp. Red Hat Red Hat,Inc. UNIX X/Open Company Limited Visual C++ Microsoft Corp. WebSphere International Business Machines Corp. Windows Microsoft Corp. Windows Server Microsoft Corporation Windows Vista Microsoft Corporation X/Open X/Open Company Limited

3 D D94-10 All Rights Reserved. Copyright (C) 2006, 2007, Hitachi, Ltd. (C) Copyright International Business Machines Corporation 1994, All rights reserved.

4 ( D94-10)uCosminexus TP1/Message Queue - Access07-01 OS Solaris mqcapiout OS HP-UX 11i V2PA-RISC 2.1 JMS XA TP1/Server Base $DCCONFPATH/ env DCMQCSRVHOSTNAME DCMQCTIMEGET (4) 2.2.1(4)(a) 2.2.1(1)2.2.1(2) 2.2.1(3)2.2.1(6) 2.2.2(3)2.2.5 A (5) 2.2.2(1) 2.2.2(1) JMSPRF 2-12 MDB JMSPRF mqcapioutapi mqcapiout 7-6 InvalidSelectorException public boolean hasmoreelements public Object nextelement KFCA30952-E KFCA30954-WKFCA30981-EKFCA30982-E KFCA30960-EKFCA30961-EKFCA30963-EKFCA30964-E KFCA30975-IKFCA31341-W MessageConsumer QueueBrowser getmessageselector QueueSession createbrowser QueueSession createreceiver B-2 Enumeration

5

6

7 TP1/Message Queue - Access TP1/Message Queue - Access International Business Machines Corporation WebSphere MQ MQI TP1/Message Queue - Access OpenTP1 OpenTP D50 OpenTP D51 OpenTP D52 OpenTP D53 TP1/Message Queue D90 TP1/Message Queue D92 TP1/Message Queue D93 1 TP1/Message Queue - AccessMQCMQC MQC 2 MQC MQC 3 MQC MQC 4 MQC MQI C COBOL MQI 5 MQC C++ MQC C++ 6 MQC Java MQC Java I

8 7 MQC JMS MQC JMS 8 MQC A MQC BJMS MQC JMS Sun Microsystems, Inc. JMS 1.0 MQC JMS CMQMessage MQMessage D II

9 III

10 AIX 5L V5.1 AIX AIX 5L V5.2 AIX 5L V5.3 IV

11 HP-UX 11i V2IPF Java TM JavaBeans TM Red Hat Enterprise Linux AS 4 HP-UX Java JavaBeans Linux Red Hat Enterprise Linux AS 4IPF Red Hat Enterprise Linux ES 4x86 Red Hat Enterprise Linux ES 4AMD64 Red Hat Enterprise Linux ES 4 Intel EM64T Microsoft (R) Visual C++ (R) Visual C++ Microsoft (R) Windows Server (R) 2003, Datacenter Edition Windows Server 2003 Microsoft (R) Windows Server (R) 2003, Datacenter x64 Edition Microsoft (R) Windows Server (R) 2003, Enterprise Edition Microsoft (R) Windows Server (R) 2003, Enterprise x64 Edition Microsoft (R) Windows Server (R) 2003, Standard Edition Microsoft (R) Windows Server (R) 2003, Standard x64 Edition Microsoft (R) Windows Vista (R) Microsoft (R) Windows (R) XP Professional Operating System ucosminexus TP1/Message Queue Windows Vista Windows XP TP1/Message Queue ucosminexus TP1/Message Queue64 ucosminexus TP1/Message Queue - Access TP1/Message Queue - Access ucosminexus TP1/Message Queue - Access64 AIXHP-UX Linux UNIX Windows Server 2003Windows XP Windows Vista Windows V

12 (()) A Fa f -e -e { } { -p -s } -p -s VI

13 trn_crm_use = Y N Y N API DNS EBCDIC EJB EUC J2EE J2SE JAR JIS JMS JNDI JNI JTA LAN MDB MQA MQC MQI OS PTP RM RPC SUP TCP/IP TM TP1/Message Queue UAP Application Programming Interface Domain Name Server Extended Binary Coded Decimal Interchange Code Enterprise JavaBeans Extended UNIX Code Java 2 Platform Enterprise Edition Java 2 Standard Edition Java Archive Japan Industrial Standard Java Message Service Java Naming and Directory Interface Java Native Interface Java Transaction API Local Area Network Message-Driven Bean Message Queue - Access TP1/Message Queue - Access Message Queue Interface Operating System Point to Point Resource Manager Remote Procedure Call Service Using Program Transmission Control Protocol /Internet Protocol Transaction Manager OpenTP1/Message Queue User Application Program VII

14 UTF-8 8-bit UCS Transformation Format KB 1KB1MB1GB1TB 1,024 1, , ,024 4 COBOL CODASYLthe Conference on Data Systems Languages CODASYL COBOL CODASYL COBOL JOURNAL OF DEVELOPMENT 1984 COBOL "COBOL" COBOL CODASYLCOBOL FLOW-MATICSperry Rand Corporation Programming for the UnivacRI and II Data Automation SystemsSperry Rand Corporation IBM Commercial Translator Form No.F IBM 1959 ; FACTDSI 27A Minneapolis-Honeywell 1960 COBOL COBOL VIII

15 TP1/Message Queue - Access 2 1.2TP1/Message Queue - Access MQC MQC JMS Windows 11 2 MQC MQC MQC MQC MQC JMS XA MQC API JavaEnvironment JMSAPI JMSPRF 55 3 MQC 63 MQC 64 mqcapioutapi 65 i

16 4 MQC MQI 97 MQI 98 MQBACK 100 MQBEGIN 103 MQCMIT 106 MQBO 109 MQI 111 MQI C 113 MQI COBOL MQC C MQC C C ImqBinary C ImqCache C ImqDeadLetterHeader C ImqDistributionList C ImqError C ImqGetMessageOptions C ImqHeader C ImqItem C ImqMessage C ImqMessageTracker C ImqObject C ImqProcess C ImqPutMessageOptions C ImqQueue C ImqQueueManager C ImqReferenceHeader C ImqString C ImqTrigger C C C ii

17 6 MQC Java 215 MQC Java 217 MQC Java 218 Java 219 MQDistributionList Java 220 MQDistributionListItem Java 222 MQEnvironment Java 223 MQException Java 225 MQGetMessageOptions Java 233 MQManagedObject Java 235 MQMessage Java 237 MQMessageTracker Java 248 MQProcess Java 249 MQPutMessageOptions Java 251 MQQueue Java 253 MQQueueManager Java 260 MQC Java 264 Java 276 Java MQC JMS 279 JMS Java 281 MQC JMS 282 JMS 284 JMS MQI 286 JMS JMS 294 JMS 296 BytesMessage JMS 298 ConnectionMetaData JMS 307 DeliveryMode JMS 310 Destination Queue JMS 311 iii

18 Message JMS 312 MessageConsumer QueueReceiver JMS 327 MessageProducer QueueSender JMS 330 QueueBrowser JMS 338 QueueConnection JMS 340 QueueConnectionFactory JMS 344 QueueSession JMS 346 TemporaryQueue JMS 354 Enumeration J2SE 355 MQC JMS 356 JMS 361 JMS ID A 398 BJMS MQC JMS 405 CMQMessage 412 D iv

19 1-1MQC MQC 3 1-2XA 7 1-3JTA 8 1-4MQC MQC C C Java Java JMS JMS TP1/Message Queue JMS 362 v

20 2-1MQC AIX MQC HP-UX 11i V2.0 IPF MQC Linux MQC Windows JMS DCMQCEXPTRN XA RM C COBOL C MQC JMSAPI JMSPRF JMSPRF ID MQC MQC MQI CompCode MQCC_OK MQBACK CompCode MQCC_WARNING MQBACK CompCode MQCC_FAILED MQBACK CompCode MQCC_OK MQBEGIN CompCode MQCC_FAILED MQBEGIN CompCode MQCC_OK MQCMIT CompCode MQCC_WARNING MQCMIT CompCode MQCC_FAILED MQCMIT MQBO C Java Java JavaEnvironment JMS JMS 282 vi

21 7-3JMS MQI JMS MQMD JMS MQMD JMS A B B C-1MQMessage 412 vii

22

23 1 TP1/Message Queue - AccessMQC MQC MQC 1.1TP1/Message Queue - Access 1.2TP1/Message Queue - Access 1.3Windows 1

24 1. 1.1TP1/Message Queue - Access TP1/Message Queue - AccessMQC TP1/Message Queue TP1/Message Queue - Access MQC TP1/Message Queue MQC MQC OpenTP1 MQC MQC 2

25 1. 1-1MQC MQC TP1/Message Queue - Access TCP/IP MQC MQC MQC MQC MQC MQC MQC MQC TCP/IP 1 1 3

26 1. MQC TCP/IP MQC DCMQCSEGSIZE MQC MQC MQC 4

27 1. 1.2TP1/Message Queue - Access TP1/Message Queue - Access 1.2.1MQC MQC MQC TP1/Message Queue MQIC COBOL C++ Java JMS Java API TM X/Open XA 1.2.2MQC MQC MQC MQC MQC TP1/Message Queue MQC TP1/ Message Queue MQC MQC TP1/Message Queue MQC MQC MQC MQC OpenTP1 MQC MQC 1 1 TP1/Message Queue TP1/Message Queue MQC MQC Mqcgw0c MQCONN MQRC_Q_MGR_NOT_AVAILABLE2059TP1/ Message Queue MQC 5

28 TP1/Message Queue - Access 3 XA XA JTA 1 XA XA XA MQC OpenTP1 TM TPBroker XA MQC OpenTP1 TM XA 6

29 1. 1-2XA XA 1-2 XA 2 XA MQC OpenTP1 TM XA 3 XA TM 2 JTA JTA Cosminexus Component Container TM 7

30 1. Cosminexus EJB JMS API MQC JNI MQI MQI MQC TP1/Message Queue JTA 1-3JTA MQC MQC MQC 2.2MQC MQC TP1/Message Queue 8

31 1. 1-4MQC MQC 9

32 1. DCMQCTIMEREQ DCMQCTIMEGET MQGET 1.2.5JMS JMS EJB Cosminexus Component Container TP1/Message Queue JTA 1 JMS Cosminexus 2 Message-Driven Bean Message-Driven Bean Cosminexus Component Container EJB Enterprise Bean JMS Bean TP1/Message Queue - Access Message-Driven Bean EJB Message-Driven Bean 1. TP1/Message Queue - Access TP1/ Message Queue 2. Message-Driven Bean 3. Message-Driven Bean EJB 4. EJB RM 10

33 1. 1.3Windows Windows TP1/Message Queue - Access Windows $DCDIR %DCDIR% UNIX Windows UNIX Windows Windows OpenTP1 -a -A 11

34

35 2 MQC MQC 2.1MQC 2.2MQC MQC 13

36 2.MQC 2.1MQC MQC OS AIX LIBPATH HP-UX SHLIB_PATH Linux LD_LIBRARY_PATH Windows LIB Windows PATH " bin" MQC OS $MQCDIR %MQCDIR% TP1/Message Queue - Access 2-1MQC AIX C XA $MQCDIR/lib libmqcx.a XA $MQCDIR/lib libmqc.a $MQCDIR/include cmqc.h cmqcfc.h AP $MQCDIR/examples/c mqcsample.c makefile COBOL XA $MQCDIR/lib libmqccbx.a XA $MQCDIR/lib libmqccb.a COBOL AP $MQCDIR/include/ COBOL $MQCDIR/examples/ cobol CMQ*.cbl MQCSAMPLE.cbl makefile makefile2002 C++ XA $MQCDIR/lib libmqccpp.a $MQCDIR/include/ cplus imq*.hpp imqtype.h AP $MQCDIR/examples/cpp mqcsample.cpp makefile 14

37 2.MQC Java XA $MQCDIR/lib libmqcj.a Java $MQCDIR/lib mqc.jar AP $MQCDIR/examples/ java MQAccessSample. java makefile Java JMS Java $MQCDIR/lib mqcadpt.rar mqcadptdef.jar AP $MQCDIR/examples/ jms/sessionbean1 JMSSample1.java JMSSample1.Clie nt.java JMSSample1EJB.j ava JMSSample1Home. java compilebean compileclient testclient QueueConfig config.xml deployapp undeployapp APMQC $MQCDIR/examples/ jms/sessionbean1/dd/ META-INF $MQCDIR/examples/ jms/sessionbean2 $MQCDIR/examples/ jms/sessionbean2/dd/ META-INF ejb-jar.xml application.xml JMSSample2.java JMSSample2.Clie nt.java JMSSample2EJB.j ava JMSSample2Home. java compilebean compileclient testclient QueueConfig config.xml deployapp undeployapp ejb-jar.xml application.xml $MQCDIR/bin mqcapiout 15

38 2.MQC 2-2MQC HP-UX 11i V2.0IPF64 C XA $MQCDIR/lib libmqc.a XA $MQCDIR/lib libmqc.so $MQCDIR/ include cmqc.h cmqcfc.h AP $MQCDIR/ examples/c mqcsample.c makefile C++ XA $MQCDIR/lib libmqccpp.a XA $MQCDIR/lib libmqccpp.s o $MQCDIR/ include/cplus imq*.hpp imqtype.h AP $MQCDIR/ examples/cpp mqcsample.c pp makefile Java XA $MQCDIR/lib libmqcj.so Java $MQCDIR/lib mqc.jar AP $MQCDIR/ examples/java MQAccessSam ple.java makefile 16

39 2.MQC Java JMS Java $MQCDIR/lib mqcadpt.rar mqcadptdef. jar AP APMQC $MQCDIR/ examples/jms/ SessionBean1 $MQCDIR/ examples/jms/ SessionBean1/ DD/META-INF $MQCDIR/ examples/jms/ SessionBean2 $MQCDIR/ examples/jms/ SessionBean2/ DD/META-INF JMSSample1. java JMSSample1. Client.java JMSSample1E JB.java JMSSample1H ome.java compilebean compileclie nt testclient QueueConfig config.xml deployapp undeployapp ejb-jar.xml application.xml JMSSample2. java JMSSample2. Client.java JMSSample2E JB.java JMSSample2H ome.java compilebean compileclie nt testclient QueueConfig config.xml deployapp undeployapp ejb-jar.xml application.xml $MQCDIR/bin mqcapiout 17

40 2.MQC 2-3MQC Linux C XA 1 $MQCDIR/lib libmqcx.a XA 1 $MQCDIR/lib libmqcx.so XA $MQCDIR/lib libmqc.a XA $MQCDIR/lib libmqc.so $MQCDIR/include cmqc.h cmqcfc.h AP $MQCDIR/examples/c mqcsample.c makefile COBOL 2 XA $MQCDIR/lib libmqccbx.a XA $MQCDIR/lib libmqccbx.so XA $MQCDIR/lib libmqccb.a XA COBOL AP $MQCDIR/lib $MQCDIR/include/ COBOL $MQCDIR/examples/ cobol libmqccb.so CMQ*.cbl MQCSAMPLE.cbl makefile C++ XA $MQCDIR/lib libmqccpp.a XA $MQCDIR/lib $MQCDIR/include/ cplus libmqccpp.so imq*.hpp imqtype.h AP $MQCDIR/examples/cpp mqcsample.cpp makefile Java XA $MQCDIR/lib libmqcj.so Java $MQCDIR/lib mqc.jar AP $MQCDIR/examples/ java MQAccessSample. java makefile 18

41 2.MQC Java JMS Java $MQCDIR/lib mqcadpt.rar mqcadptdef.jar AP $MQCDIR/examples/ jms/sessionbean1 JMSSample1.java JMSSample1.Clie nt.java JMSSample1EJB.j ava JMSSample1Home. java compilebean compileclient config.xml deployapp testclient QueueConfig undeployapp APMQC $MQCDIR/examples/ jms/sessionbean1/dd/ META-INF $MQCDIR/examples/ jms/sessionbean2 $MQCDIR/examples/ jms/sessionbean2/dd/ META-INF ejb-jar.xml application.xml JMSSample2.java JMSSample2.Clie nt.java JMSSample2EJB.j ava JMSSample2Home. java compilebean compileclient config.xml deployapp testclient QueueConfig undeployapp ejb-jar.xml application.xml $MQCDIR/bin mqcapiout 1 IPF64 C XA 2 Red Hat Enterprise Linux 4 19

42 2.MQC 2-4MQC Windows C XA %MQCDIR% bin libmqcx.dll %MQCDIR% lib libmqcx.lib XA %MQCDIR% bin libmqc.dll %MQCDIR% lib libmqc.lib AP %MQCDIR% examples c mqcsample.c makefile %MQCDIR% include cmqc.h cmqcfc.h COBOL XA %MQCDIR% bin libmqccbx.dll %MQCDIR% lib libmqccbx.lib XA %MQCDIR% bin libmqccb.dll COBOL AP %MQCDIR% lib %MQCDIR% include COB OL %MQCDIR% examples co bol libmqccb.lib CMQ*.cbl MQCSAMPLE.cbl makefile C++ XA %MQCDIR% bin libmqcppx.dll %MQCDIR% lib libmqcppx.lib XA %MQCDIR% bin libmqcpp.dll %MQCDIR% lib libmqcpp.lib %MQCDIR% include cpl us imq*.hpp imqtype.h AP %MQCDIR% examples cp p mqcsample.cpp makefile Java XA %MQCDIR% bin mqcj.dll XA Java %MQCDIR% lib mqc.jar AP %MQCDIR% examples ja va MQAccessSample. java makefile 20

43 2.MQC Java JMS Java %MQCDIR% lib mqcadpt.rar mqcadptdef.jar AP %MQCDIR% examples jm s SessionBean1 JMSSample1.java JMSSample1Clien t.java JMSSample1EJB.j ava JMSSample1Home. java compilebean.bat compileclient.b at testclient.bat QueueConfig deployapp undeployapp config.xml AP MQC %MQCDIR% examples jms SessionBean1 DD META-INF %MQCDIR% examples jms SessionBean2 %MQCDIR% examples jms SessionBean2 DD META-INF ejb-jar.xml application.xml JMSSample2.java JMSSample2Clien t.java JMSSample2EJB.j ava JMSSample2Home. java compilebean.bat compileclient.b at testclient.bat QueueConfig deployapp undeployapp config.xml ejb-jar.xml application.xml %MQCDIR% bin mqcapiout.exe readme %MQCDIR% readme readme.txt 21

44 2.MQC 2.2MQC MQC Java JMS XA 2.2.1MQC UNIX MQC MQC /etc/profile $HOME/.profile C /etc/cshrc $HOME/.cshrc Windows Java JMS ucosminexus Application Server 1 UNIX $ DCMQCSRVHOSTNAME = MQC $ DCMQCSRVHOSTIP = MQCIP $ DCMQCSRVSERVNAME = MQC $ DCMQCSRVPORT = MQC $ DCMQCCLTHOSTIP = IP $ DCMQCCLTPORT = $ DCMQCTIMEREQ = MQCMQC $ DCMQCTIMEGET = MQCMQGET $ DCMQCTIMESEG = MQCMQC $ DCMQCTIMECON = MQCMQC $ DCMQCSEGSIZE = $ DCMQCAPITRCOUT = API $ DCMQCAPITRCFILNUM = API $ DCMQCAPITRCSIZE = API $ DCMQCAPITRCWRITE = API $ DCMQCEXPTRN = $ DCMQCDEFCON = $ DCMQCDEFCONPATH = $ export DCMQCSRVHOSTNAME DCMQCSRVHOSTIP DCMQCSRVSERVNAME DCMQCSRVPORT DCMQCCLTHOSTIP DCMQCCLTPORT DCMQCTIMEREQ DCMQCTIMEGET DCMQCTIMESEG DCMQCTIMECON DCMQCSEGSIZE DCMQCAPITRCOUT DCMQCAPITRCFILNUM DCMQCAPITRCSIZE DCMQCAPITRCWRITE 22

45 2.MQC DCMQCEXPTRN DCMQCDEFCON DCMQCDEFCONPATH 2 CUNIX % setenv DCMQCSRVHOSTNAME MQC % setenv DCMQCSRVHOSTIP MQCIP % setenv DCMQCSRVSERVNAME MQC % setenv DCMQCSRVPORT MQC % setenv DCMQCCLTHOSTIP IP % setenv DCMQCCLTPORT % setenv DCMQCTIMEREQ MQCMQC % setenv DCMQCTIMEGET MQCMQGET % setenv DCMQCTIMESEG MQCMQC % setenv DCMQCTIMECON = MQCMQC % setenv DCMQCSEGSIZE % setenv DCMQCAPITRCOUT API % setenv DCMQCAPITRCFILNUM API % setenv DCMQCAPITRCSIZE API % setenv DCMQCAPITRCWRITE API % setenv DCMQCEXPTRN % setenv DCMQCDEFCON % setenv DCMQCDEFCONPATH 3 Windows DCMQCSRVHOSTNAMEMQC DCMQCSRVHOSTIPMQCIP DCMQCSRVSERVNAMEMQC DCMQCSRVPORTMQC DCMQCCLTHOSTIPIP DCMQCCLTPORT DCMQCTIMEREQMQCMQC DCMQCTIMEGETMQCMQGET DCMQCTIMESEGMQCMQC DCMQCTIMECONMQCMQC DCMQCSEGSIZE DCMQCAPITRCOUTAPI DCMQCAPITRCFILNUMAPI DCMQCAPITRCSIZEAPI DCMQCAPITRCWRITEAPI DCMQCEXPTRN DCMQCDEFCON = DCMQCDEFCONPATH = 4 JMS JMS (1) (3) MQC JMS 23

46 2.MQC ucosminexus Application Server Cosminexus a JMS TP1/Message Queue - Access mqcadpt.rar mqcadpt.rar TP1/Message Queue - Access lib TP1/Message Queue - Access TP1/Message Queue - Access TP1/Message Queue - Access TP1/MessageQueue - Access TP1/Message Queue - Access TP1/Message Queue - Access Cosminexus TP1/Message Queue - Access TP1/Message Queue - Access TP1/ Message Queue - Access b JMS JMS 24

47 2.MQC 2-5JMS MQC JMS DCMQCSRVHOSTN AME DCMQCSRVHOSTIP DCMQCSRVSERVNA ME DCMQCSRVPORT DCMQCCLTHOSTIP DCMQCCLTPORT DCMQCTIMEREQ DCMQCTIMEGET DCMQCTIMESEG DCMQCTIMECON DCMQCSEGSIZE DCMQCAPITRCOUT DCMQCAPITRCFIL NUM DCMQCAPITRCSIZE DCMQCAPITRCWRI TE ModelQueueName TraceLevel PrfTraceLevel QueueConfigFileNam e MQC MQC IP MQC MQC IP MQC MQC MQC MQGET MQC MQC MQC MQC API API API API TemporaryQueue JMSAPI JMSPRF JMS MQC TraceLevel PrfTraceLeveljava.lang.Integer java.lang.string 5 TP1/Server Base TP1/Server Base $DCCONFPATH/env 25

48 2.MQC putenv DCMQCSRVHOSTIP nnn.nnn.nnn.nnn putenv DCMQCSRVPORT nnnnn 2.2.2(1) XA dc_rpc_open xa_open dc_rpc_close xa_close set trn_rm_open_close_scope=process OpenTP1 TP1/Message Queue - Access DCMQCDEFCON=Y DCMQCDEFCON=N 2-6 DCMQCDEFCON=Y DCMQCDEFCON=N OS OS DCMQCDEFCON DCMQCDEFCONPATH DCMQCMGRNAME DCMQCSRVHOSTNAM E DCMQCSRVHOSTIP DCMQCSRVSERVNAM E DCMQCSRVPORT MQ MQC MQC IP MQC MQC 26

49 2.MQC DCMQCDEFCON=Y DCMQCDEFCON=N OS OS DCMQCCLTHOSTIP DCMQCCLTPORT DCMQCTIMEREQ DCMQCTIMEGET DCMQCTIMESEG DCMQCTIMECON DCMQCSEGSIZE DCMQCAPITRCOUT DCMQCAPITRCFILNU M DCMQCAPITRCSIZE DCMQCAPITRCWRITE DCMQCEXPTRN IP MQC MQC MQC MQGET MQC MQC MQC MQC API API API API 27

50 2.MQC 2.2.2MQC MQC 1 UNIX Windows DCMQCSRVHOSTNAME = MQC MQC DNS KFCA30951-E MQC DCMQCSRVHOSTIP MQC IP DCMQCSRVHOSTNAME DCMQCSRVHOSTIP DCMQCSRVHOSTIP DCMQCSRVHOSTIP = MQC IP nnn.nnn.nnn.nnn((0 255)) MQC IP nnn.nnn.nnn.nnn nnn. nnn DCMQCSRVHOSTNAME MQC DCMQCSRVHOSTNAME DCMQCSRVHOSTIP DCMQCSRVHOSTIP DCMQCSRVSERVNAME = MQC 1 32 MQC KFCA30951-E MQC DCMQCSRVPORT MQC DCMQCSRVPORT DCMQCSRVSERVNAME DCMQCSRVPORT /TCP 28

51 2.MQC DCMQCSRVPORT = MQC (( )) MQC DCMQCSRVSERVNAME MQC DCMQCSRVPORT DCMQCSRVSERVNAME DCMQCSRVPORT DCMQCCLTHOSTIP = IP nnn.nnn.nnn.nnn((0 255)) IP nnn.nnn.nnn.nnn nnn "." nnn IP MQC MQC DCMQCCLTPORT = (( )) OS OS OS OS OS DCMQCTIMEREQ = MQC MQC (( ))180 MQC MQC MQC MQGMO_WAIT MQGET DCMQCTIMEGET MQGET WaitInterval MQGET API XA DCMQCTIMEGET = MQC MQGET ((1 60))1 MQC MQGET 29

52 2.MQC MQGET WaitInterval DCMQCTIMEGET MQC WaitInterval MQGET MQGET WaitInterval DCMQCTIMEGET MQC DCMQCTIMEGET MQGET MQC MQGET DCMQCTIMEGET MQGET WaitInterval MQGET MQGET MQGMO_WAIT DCMQCTIMESEG = MQC MQC (( ))30 MQC DCMQCTIMECON = MQC MQC ((10 180))10 MQC MQC MQC TCP/IP MQC TCP/IP DCMQCTIMECON TCP/IP TCP/IP API DCMQCSEGSIZE = (( ))16384 TCP/IP 2 30

53 2.MQC TCP/IP 2 TCP/IP setsockopt API DCMQCAPITRCOUT = API ON OFFOFF API ONAPI OFFAPI API API API mpc.api.ppp.n ppp ID n0-1 DCMQCAPITRCFILNUM = API (( ))5 API API DCMQCAPITRCOUT ON 5 DCMQCAPITRCSIZE = API (( ))1024 API API API API DCMQCAPITRCOUT ON 1024 DCMQCAPITRCWRITE = API ((0 1024)) UNIX 0Windows 1 API API API API MQDISC API DCMQCAPITRCOUT ON API MQCONN MQDISC MQCONN MQDISC 31

54 2.MQC MQCONN MQDISC MQCONN MQDISC API MQCONN MQDISC OS Windows 1 UNIX 0 API MQDISC API DCMQCEXPTRN = Y NY XA Y XA N XA DCMQCEXPTRN XA 2-7DCMQCEXPTRN XA DCMQCEXPTRN XA Y MQCONN MQC MQDISC MQC MQCONN Y XA_OPEN MQC XA_CLOSE MQC XA MQCONN 2 MQCONN MQCC_WARNING MQRC_ALREADY_CONNECTED MQCONN MQCONN N MQCONN MQC MQDISC MQC MQCONN 32

55 2.MQC DCMQCEXPTRN XA N MQCONN MQC MQDISC MQC MQCONN XA 2 JMS ModelQueueName = TemporaryQueue java.lang.string TemporaryQueue 48 TraceLevel = JMSAPI java.lang.integer ((0 4))3 JMSAPI JMSAPI 2.4.3JMSAPI PrfTraceLevel = JMSPRF java.lang.integer ((0 2))1 JMSPRF JMSPRF 2.4.4JMSPRF QueueConfigFileName = java.lang.string JMS 33

56 2.MQC TP1/Message Queue - Access JMS 3 DCMQCDEFCON = Y NN Y MQ 16 XA AP XA JMS MQCONN Name DCMQCMGRNAME MQCONN MQRC_Q_MGR_NAME_ERR2058 N DCMQCDEFCONPATH = OS 2.2.3JMS JMS TP1/ Message Queue - Access QueueConfigFileName TP1/Message Queue - Access 34

57 2.MQC TP1/Message Queue - Access 1 QueueImplClass=QImpl 1 Queue. 2.DisplayName= 3 Queue..QueueName= 4 Queue..QueueManagerName= 5 1 QImpl jp.co.hitachi.soft.mqadaptor.queueimpl Cosminexus NameSpace TP1_Message_Queue_Access que QueueImplClass=jp.co.Hitachi.soft.mqadaptor.QueueImpl Queue.1.DisplayName=Que1 Queue.1.QueueName=Queue1 Queue.1.QueueManagerName=QMgr1 Queue.2.DisplayName=Que2 Queue.2.QueueName=Queue2 Queue.2.QueueManagerName=QMgr2 Queue.3.DisplayName=Que3 Queue.3.QueueName=Queue3 Queue.3.QueueManagerName=QMgr3 3 java.util.properties load QueueImplClass QueueImplClass DisplayNameQueueName QueueManagerName Queue.n.DisplayName Queue.n.DisplayName n-1 35

58 2.MQC n QueueName QueueName QueueManagerName QueueManagerName DisplayName A Za z0 9 _ createsendercreatereceiver createbrowser Queue send InvalidDestinationException 2.2.4XA MQC XA TM 1 RM MQClient RM dc_xa_mqc_switch RM OS RM 2-8RM OS RM AIX libmqcx.a -brtl -lpthread -lc HP-UX libmqcxp.sl -lpthread Linux libmqcx.so -lpthread 36

59 2.MQC OS RM Windows libmqcx.lib 2 XA XA 1 MQCONN TP1/Message Queue - Access TP1/Message Queue - Access DCMQCEXPTRN=N MQCONN MQCC_OKMQRC_NONE TP1/Message Queue - Access DCMQCEXPTRN=Y 2 MQCONN MQCC_WARNING MQRC_ALREADY_CONNECTED TP1/Message Queue - Access TP1/Message Queue - Access DCMQCEXPTRN=N TP1/Message Queue - Access DCMQCEXPTRN=Y MQC TP1/Message Queue - Access TP1/Message Queue - Access DCMQCEXPTRN=N MQCONN MQC MQDISC MQC TP1/Message Queue - Access DCMQCEXPTRN=Y XA_OPEN MQC XA_CLOSE MQC 3 XA TM xa_open MQI C++ MQI 37

60 2.MQC xa_open TP1/Message Queue - Access RM MQC MQC 2-6 DCMQCMGRNAME = MQ 1 48 MQ MQ MQA mqaquemgr -n IP 2 MGR DCMQCMGRNAME= 1 DCMQCSRVHOSTIP=MQCIP 2 DCMQCSRVHOSTNAME=MQC 2 DCMQCSRVPORT=MQC 3 DCMQCSRVSERVNAME=MQC 3 DCMQCCLTHOSTIP=IP DCMQCCLTPORT= DCMQCTIMEREQ=MQCMQC DCMQCTIMEGET=MQCMQGET DCMQCTIMESEG=MQCMQC DCMQCTIMECON=MQCMQC DCMQCSEGSIZE= MGREND 1 38

61 2.MQC 2 DCMQCSRVHOSTIP 3 DCMQCSRVPORT 3 1. MGRMGREND MGR MGRENDMGR MGR # 5. # DCMQCMGRNAME DCMQCSRVHOSTIP === = 11. = = #=# 39

62 2.MQC 12.MGRMGREND MQCONN MQRC_UNEXPECTED_ERROR

63 2.MQC

64 2.MQC 2 DCMQCSRVHOSTNAME DCMQCSRVSERVNAME DCMQCSRVHOSTIP DCMQCSRVPORT 3 20 DCMQCMGRNAME 25 DCMQCMGRNAME DCMQCMGRNAME DCMQCTIMEGET=60 DCMQCTIMECON= DCMQCSEGSIZE DCMQCTIMEREQ DCMQCMGRNAME TESTMGR DCMQCMGRNAME

65 2.MQC 2.3 MQC MQC C C MQI 4.MQC MQI C 2-9C OS AIX XA -lmqcx -brtl -lpthread -lc XA -lmqc -brtl -lpthread -lc HP-UXLinux XA -lmqcx -lpthread XA -lmqc -lpthread Windows XA libmqcx.lib XA libmqc.lib COBOL COBOL MQI 4.MQC MQI COBOL 2-10COBOL OS AIX XA -lmqccbx -brtl -lpthread -lc XA -lmqccb -brtl -lpthread -lc HP-UXLinux XA -lmqccbx -lpthread XA -lmqccb -lpthread 43

66 2.MQC OS Windows XA libmqccbx.lib XA libmqccb.lib C++ C++ 5.MQC C++ C C++ OS AIX XA -brtl -lmqccpp -lmqcx -lpthread XA -brtl -lmqccpp -lmqc -lpthread HP-UXLinux XA -lmqccpp -lmqcx -lpthread XA -lmqccpp -lmqc -lpthread Windows XA libmqcppx.lib XA libmqcpp.lib Java Java 6.MQC Java JTA Java JMS 7.MQC JMS TP1/Message Queue - Access JMS Sun Microsystems, Inc. JMS 1.0 JMS 1.0 MQC JMS BJMS MQC JMS TP1/Message Queue - Access 2 1 XA 44

67 2.MQC XA xa_open MQC MQC MQC TM MQC MQC MQC TM TP1/Message Queue - Access MQRC_CONNECTION_BROKEN MQI MQCONN MQDISCMQOPENMQCLOSEMQGETMQPUTMQPUT1MQSET MQINQMQCMIT MQBACK TP1/Message Queue - Access UAP MQGMO Options MQGMO_WAIT MQGET UAP UAP Java Java SIGSEGV Java Java -mxxxmxx TP1/Message Queue - Access XA MQPUT MQPUT1 MQGET MQCONN MQRC_ALREADY_CONNECTED TP1/Message Queue - Access MQDISC MQC MQCONN MQRC_Q_MGR_NOT_AVAILABLE MQDISC MQCONN UAP MQCONN MQC MQCONN TP1/Message Queue - Access UAP MQCONN 45

68 2.MQC MQRC_UNEXPECTED_ERROR MQC MQRC_Q_MGR_NOT_AVAILABLE UAP MQCONN 1. OpenTP1 trnls -t MQCGWP 2. MQCGWP dcsvstop MQCGWP mqccontrn -f XA 1 1 JMS API JMS API MQI JMS MQI 46

69 2.MQC 2.4MQC MQC 2-12MQC.core 1 API mqc.api.xxx.zz 2 API mqcapiout Java Java JavaEnvironment Java JMSAPI Cosminexus /CC/server/public/ejb/ /logs/connectors/ TP1_Message_Queue_Access*.log 3 JMSPRF (prfspool)/ utt/prf/prf /dcopltrc/prf_* JMS JMS Cosminexus Performance Tracer cprfflush cprfed TP1/Message Queue - Access 1 OS Windows 2 XXX ID ZZ Windows "/" " " 47

70 2.MQC 2.4.1API API mqcapiout 3 mqcapioutapi 2.4.2JavaEnvironment JavaEnvironment Java JavaEnvironment JavaEnvironment MQEnvironment enabletracing 6 MQEnvironment Java 1 XX...XX YY...YY Value = AA...AA MQ MQGMO MQPMO 2 XX...XX # YY...YY Start End AA...AA 3 MQ MQ *** MQMessage Variable aa...aa report = bb...bb messagetype = cc...cc expiry = dd...dd feedback = ee...ee encoding = ff...ff characterset = gg...gg 48

71 2.MQC format = hh...hh priority = ii...ii persistence = jj...jj messageid = kk...kk correlationid = ll...ll backoutcount = mm...mm replytoqueuename = nn...nn replytoqueuemanagername = oo...oo userid = pp...pp accountingtoken = qq...qq applicationiddata = rr...rr putapplicationtype = ss...ss putapplicationname = tt...tt putdatetime = uu...uu applicationorigindata = vv...vv groupid = ww...ww messagesequencenumber = xx...xx offset = yy...yy messageflags = zz...zz originallength = AA...AA MQ aa...aa 16 bb...bb 10 cc...cc 10 dd...dd 10 ee...ee 10 ff...ff 10 gg...gg 10 hh...hh ii...ii 10 jj...jj 10 kk...kk 16 49

72 2.MQC ll...ll 16 mm...mm 10 nn...nn oo...oo pp...pp qq...qq 16 rr...rr ss...ss 10 tt...tt uu...uu vv...vv ww...ww 16 xx...xx 10 yy...yy 10 zz...zz 10 AA...AA 10 4 MQGMO MQGMO *** MQGetMessageOptions Variable aa...aa 50

73 2.MQC options = bb...bb waitinterval = cc...cc resolvedqueuename = dd...dd matchoptions = ee...ee groupstatus = ff...ff segmentstatus = gg...gg segmentation = hh...hh MQGMO aa...aa 16 bb...bb 10 cc...cc 10 dd...dd ee...ee 10 ff...ff gg...gg hh...hh 5 MQPMO MQPMO *** MQPutMessageOptions Variable aa...aa options = bb...bb resolvedqueuename= cc...cc resolvedqueuemanagername= dd...dd knowndestcount= ee...ee unknowndestcount= ff...ff invaliddestcount= gg...gg contextreference= hh...hh recordfields = ii...ii MQPMO aa...aa 16 51

74 2.MQC bb...bb 10 cc...cc dd...dd ee...ee 10 ff...ff 10 gg...gg 10 hh...hh ii...ii MQPMR 10 6 aa...aa message size: bb...bb aa...aa message: cc...cc aa...aa GetGet PutPut bb...bb 10 cc...cc JMSAPI JMSAPI API Cosminexus JMSAPI 52

75 2.MQC 1 JMSAPI JMSAPI API Cosminexus Message Message 0 API Cosminexus KFCA TP1/Message Queue - Access 2 a (AA...AA)yyyy-mm-dd hh:mi:ss.mss Xid = [0x CC...CC] [0x CC...CC] XX...XX # YY...YY START QueueName = DD...DD Value1 = EE...EE Value2 = EE...EE : : MessageObject = FF...FF Hconn = BB...BB b 53

76 2.MQC (AA...AA)yyyy-mm-dd hh:mi:ss.mss Xid = [0x CC...CC] [0x CC...CC] XX...XX # YY...YY END QueueName = DD...DD Value1 = EE...EE Value2 = EE...EE : : MessageObject = FF...FF Hconn = BB...BB c (AA...AA)yyyy-mm-dd hh:mi:ss.mss Xid = [0x CC...CC] [0x CC...CC] XX...XX # YY...YY ERR QueueName = DD..DD Value1 = EE...EE Value2 = EE...EE : : MessageObject = FF...FF CompletionCode = GG...GG ReasonCode = HH...HH Hconn = BB...BB d AA...AA APIAPI COSCosminexus yyyy-mm-dd 10 hh:mi:ss.mss 10 BB...BB 10 CC...CC ID16 XX...XX YY...YY 54

77 2.MQC DD...DD EE...EE int String long float double boolean short char byte Object FF...FF Message GG...GG 10 HH...HH 10 e <<<----- Message Data ----->>> message size = aa...aa message = bb...bb [0x cc...cc] aa...aa 10 bb...bb 64 MQ. cc...cc JMSPRF JMSPRF JMSPRF Cosminexus Performance Tracer cprfflush cprfed Cosminexus 55

78 2.MQC JMSPRF ID 1 JMSPRF 1 0JMSPRF 1 ID 0x9200x9210x92A0x92B 2 ID ID TP1/Message Queue - Access JMSPRF 2-14JMSPRF ID 0x9200 send(message only) 0 0x9210 send(message only) 152 0x9201 send(message and 3 parameters) 0 0x9211 send(message and 3 parameters) 152 0x9202 send(queue, message) 0 0x9212 send(queue, message) 152 0x9203 send(queue, message and 3 parameters) 0 0x9213 send(queue, message and 3 parameters) 152 0x9204 receive() 0 0x9214 receive() 152 0x9205 receive(long timeout) 0 0x9215 receive(long timeout) 152 0x9206 receivenowait() 0 0x9216 receivenowait() 152 0x9207 nextelement() 0 0x9217 nextelement() 152 0x92A0 MQCONN 0 0x92B0 MQCONN 152 0x92A1 MQOPEN 0 56

79 2.MQC ID 0x92B1 MQOPEN 152 0x92A2 MQGET( ) 1 0 0x92B2 MQGET( ) x92A3 MQGET( ) 0 0x92B3 MQGET( ) 152 0x92A4 MQGET( ) 0 0x92B4 MQGET( ) 152 0x92A5 MQCLOSE 0 0x92B5 MQCLOSE 152 0x92A6 MQDISC 0 0x92B6 MQDISC 152 0x92A7 MQBEGIN 0 0x92B7 MQBEGIN 152 0x92A8 MQCMIT 0 0x92B8 MQCMIT 152 0x92A9 MQBACK 0 0x92B9 MQBACK 152 0x92AA onmessage 0 0x92BA onmessage 152 0x92AB beforedelivery 0 0x92BB beforedelivery 152 0x92AC afterdelivery 0 0x92BC afterdelivery MQGET( ) MQRC_NO_MSG_AVAILABLE MQGET( ) 0x92A2 2 MQGET( ) MQRC_NO_MSG_AVAILABLE 0x92B2 3 ID JMSPRF ID 57

80 2.MQC MQC 2-15JMSPRF ID ID x9200 0x9210 0x9201 0x9211 0x9202 0x9212 0x9203 0x9213 0x9204 0x9214 0x9205 0x9215 0x9206 0x9216 0x9207 0x9217 0x92A0 0x92B0 0x92A1 0x92B1 0x92A2 0x92B2 0x92A3 0x92B3 0x92A4 58

81 2.MQC ID x92B4 0x92A5 0x92B5 0x92A6 0x92B6 0x92A7 0x92B7 0x92A8 0x92B8 0x92A9 0x92B9 0x92AA 0x92BA 0x92AB 0x92BB 0x92AC 0x92BC 1 cprfed -Dump -CSV 2 Cosminexus cprfed 59

82 2.MQC 4 a JMSPRF cprfed Rc ID 0x x9210x x92B0 0x92B9 0 MQI 0x92BA 0x92BC 0-1 INTMQAccess: ID 0x92000x9210 0x92010x9211 0x92020x9212 0x92030x9213 0x92040x9214 0x92050x9215 0x92060x9216 0x92070x9217 0x92A00x92B0 0x92A10x92B1 0x92A20x92B2 0x92A30x92B3 0x92A40x92B4 0x92A50x92B5 0x92A60x92B6 MQAccess:send(message only) MQAccess:send(msg, 3param) MQAccess:send(queue, message) MQAccess:send(que, msg, 3param) MQAccess:receive(no argument) MQAccess:receive(timeout) MQAccess:receiveNoWait MQAccess:browse(nextElement) MQAccess:run MQCONN MQAccess:run MQOPEN MQAccess:run MQGET(browse) MQAccess:run MQGET(delete) MQAccess:run MQGET(garbage) MQAccess:run MQCLOSE MQAccess:run MQDISC 60

83 2.MQC ID 0x92A70x92B7 0x92A80x92B8 0x92A90x92B9 0x92AA0x92BA 0x92AB0x92BB 0x92AC0x92BC MQAccess:run MQBEGIN MQAccess:run MQCMIT MQAccess:run MQBACK MQAccess:run onmessage MQAccess:run beforedelivery MQAccess:run afterdelivery OPR & ID 0x92000x92100x9201 0x92110x92020x9212 0x92030x9213 0x92040x92140x9205 0x92150x92060x9216 0x92070x9217 0x92A00x92B00x92A1 0x92B10x92A20x92B2 0x92A30x92B30x92A4 0x92B40x92A50x92B5 0x92A60x92B60x92A7 0x92B70x92A80x92B8 0x92A90x92B90x92AA 0x92BA0x92AB 0x92BB0x92AC0x92BC b JMSPRF cprfed -Dump -CSV CSV OPT aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa48 61

84 2.MQC bbbbbbbbbbbbbbbbbbbbbbbb ID:ID:24 cccccccccccccccccccccccc ID:ID:24 dddddddddddddddddddddddddddddddd eeeeeeee416 4 ffffffff

85 3 MQC MQC MQC mqcapioutapi 63

86 3.MQC MQC MQC MQC MQC 3-1MQC API mqcapiout TP1/Message Queue - Access Windows TP1/Message Queue - Access UNIX Windows UNIX Windows Windows OpenTP1 -a -A 64

87 3.MQC mqcapioutapi mqcapioutapi mqcapiout { -i ID -k -x -s -t } { -c } UAP API API API ID -i ID 10 ID API ID -x ID -k ((0x x7FFFFFFF )) API -s & 0x x7FFFFFFF KFCA30971-E 64bit OS 0x x FFFFFFF -x ID -s MQI MQCONN MQDISC API 2 KFCA30982-E 0x xFFFFFFFF 64bit OS 0x x FFFFFFFF 65

88 3.MQC mqcapioutapi -t API -c UAP UAP API API API ON UAP mqc.api.ppp.n ppp ID n0-1 LANG API HP-UX ja_jp.sjis AIX Ja_JP Windows ja_jp.sjis Red Hat Enterprise Linux AS 3x86/IPFja_JP.eucJP ja_jp Red Hat Enterprise Linux AS 4/ES 4x86ja_JP.UTF-8ja_JP.UTF8 ja_jp.utf-8 ja_jp.utf8 MQCONN MQCONN () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC DD...DD [0x EE...EE] 1 FF...FF (GG...GG) 1 HH...HH (GG...GG)

89 3.MQC mqcapioutapi yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD EE...EE 16 FF...FF 10 GG...GG HH...HH 10 MQOPEN MQOPEN () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0xDD...DD] [0xEE...EE] 1 FF...FF (GG...GG) HH...HH (GG...GG) II...II (GG...GG) JJ...JJ KK...KK LL...LL MM...MM NN...NN (GG...GG) : 67

90 3.MQC mqcapioutapi (GG...GG) OO...OO (MQCC_OK) 1 PP...PP (MQRC_NON) 1 QQ...QQ 23 RR...RR 123 SS...SS 123 TT...TT 123 UU...UU 23 VV...VV 23 [0x WW...WW] 23 [0x XX...XX] [0x YY...YY YY...YY YY...YY YY...YY] aa...aa [0x YY...YY YY...YY YY...YY YY...YY] aa...aa [0x YY...YY YY...YY] aa...aa 3 bb...bb 3 cc...cc MQOD MQOD_VERSION_2 3 MQOD MQOD_VERSION_3 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 68

91 3.MQC mqcapioutapi EE...EE 16 FF...FF GG...GG HH...HH 10 II...II 10 JJ...JJ KK...KK LL...LL MM...MM NN...NN 10 OO...OO 10 PP...PP 10 QQ...QQ 10 RR...RR 10 SS...SS 10 TT...TT 10 69

92 3.MQC mqcapioutapi UU...UU 16 VV...VV 16 WW...WW 16 XX...XX 16 YY...YY 16 aa...aa bb...bb cc...cc MQPUT MQPUT () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] [0x EE...EE] FF...FF [0x GG...GG GG...GG GG...GG] HH...HH II...II (JJ...JJ) 1 KK...KK(JJ...JJ) 1 LL...LL (JJ...JJ) MM...MM (JJ...JJ) NN...NN(JJ...JJ) OO...OO(JJ...JJ) PP...PP (JJ...JJ) QQ...QQ (JJ...JJ) RR...RR(JJ...JJ) SS...SS TT...TT (JJ...JJ) UU...UU (JJ...JJ) VV...VV (JJ...JJ) [0x WW...WW WW...WW WW...WW WW...WW] XX...XX 70

93 3.MQC mqcapioutapi [0x WW...WW WW...WW] XX...XX [0x YY...YY YY...YY YY...YY YY...YY] aa...aa [0x YY...YY YY...YY ] aa...aa bb... bb cc...cc dd...dd ee...ee [0x ff...ff ff...ff ff...ff ff...ff] gg...gg [0x ff...ff ff...ff ff...ff ff...ff] gg...gg hh...hh ii...ii (JJ...JJ) jj...jj kk...kk ll...ll mm...mm [0x nn...nn nn...nn nn...nn nn...nn] oo...oo [0x nn...nn nn...nn] oo...oo 2 pp...pp 2 qq...qq 2 rr...rr (JJ...JJ) 2 ss...ss 2 MQPMOMM...MM (JJ...JJ) MQPMOMM...MM (JJ...JJ) tt...tt (JJ...JJ) [0x uu...uu] vv...vv ww...ww xx...xx 3 yy...yy zz...zz a1...a1 MQPMRb1...b1 (JJ...JJ) 3 c1...c1 3 d1...d1 3 [0x e1...e1] 3 [0x f1...f1] MQMD MQMD_VERSION_2 3 MQPMO MQPMO_VERSION_2 71

94 3.MQC mqcapioutapi yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 16 FF...FF 10 GG...GG HH...HH II...II 10 JJ...JJ KK...KK 10 72

95 3.MQC mqcapioutapi LL...LL MM...MM 10 NN...NN 10 OO...OO 10 PP...PP 10 QQ...QQ 10 RR...RR 10 SS...SS 10 TT...TT UU...UU 10 VV...VV 10 WW...WW 16 XX...XX YY...YY 16 aa...aa bb...bb 10 73

96 3.MQC mqcapioutapi cc...cc dd...dd ee...ee ff...ff 16 gg...gg hh...hh ii...ii 10 jj...jj kk...kk 8 ll...ll 8 mm...mm nn...nn 16 oo...oo pp...pp 10 qq...qq 16 rr...rr 10 74

97 3.MQC mqcapioutapi ss...ss 10 tt...tt 10 uu...uu 16 vv...vv 10 ww...ww 10 xx...xx 10 yy...yy zz...zz a1...a1 10 b1...b1 MQPMR 10 c1...c1 16 d1...d1 16 e1...e1 16 f1...f1 16 MQGET MQGET () yy/mm/dd hh:mm:ss AA...AA 75

98 3.MQC mqcapioutapi BB...BB IDCC...CC [0x DD...DD] [0x EE...EE] FF...FF [0x GG...GG GG...GG GG...GG GG...GG] HH...HH [0x GG...GG GG...GG GG...GG GG...GG] HH...HH II...II (JJ...JJ) 1 KK...KK (JJ...JJ) 1 LL...LL (JJ...JJ) MM...MM (JJ...JJ) NN...NN (JJ...JJ) OO...OO (JJ...JJ) PP...PP (JJ...JJ) QQ...QQ (JJ...JJ) RR...RR (JJ...JJ) SS...SS TT...TT (JJ...JJ) UU...UU VV...VV (JJ...JJ) [0x WW...WW WW...WW WW...WW WW...WW] XX...XX [0x WW...WW WW...WW] XX...XX [0x YY...YY YY...YY YY...YY YY...YY] aa...aa [0x YY...YY YY...YY] aa...aa bb...bb cc...cc dd...dd ee...ee [0x ff...ff ff...ff ff...ff ff...ff] gg...gg [0x ff...ff ff...ff ff...ff ff...ff] gg...gg hh...hh ii...ii (JJ...JJ) jj...jj kk...kk ll...ll mm...mm [0x nn...nn nn...nn nn...nn nn...nn] oo...oo [0x nn...nn nn...nn] oo...oo 2 pp...pp 2 qq...qq 2 rr...rr (JJ...JJ) 2 ss...ss 2 MQGMOLL...LL(JJ...JJ) MQGMOMM...MM (JJ...JJ) tt...tt (JJ...JJ) : 76

99 3.MQC mqcapioutapi (JJ...JJ) uu...uu vv...vv ww...ww xx...xx yy...yy (JJ...JJ) 3 zz...zz (JJ...JJ) 3 a1...a1 (JJ...JJ) 3 b1...b1 (JJ...JJ) MQMD MQMD_VERSION_2 3 MQGMO MQGMO_VERSION_2 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 16 FF...FF 10 GG...GG 16 77

100 3.MQC mqcapioutapi HH...HH II...II 10 JJ...JJ KK...KK 10 LL...LL MM...MM 10 NN...NN 10 OO...OO 10 PP...PP 10 QQ...QQ 10 RR...RR 10 SS...SS 10 TT...TT UU...UU 10 78

101 3.MQC mqcapioutapi VV...VV 10 WW...WW 16 XX...XX YY...YY 16 aa...aa bb...bb 10 cc...cc dd...dd ee...ee ff...ff 16 gg...gg hh...hh ii...ii 10 jj...jj kk...kk 8 ll...ll 8 79

102 3.MQC mqcapioutapi mm...mm nn...nn 16 oo...oo pp...pp 10 qq...qq 16 rr...rr 10 ss...ss 10 tt...tt 10 uu...uu 10 vv...vv 10 ww...ww xx...xx 10 yy...yy 10 zz...zz a1...a1 b1...b1 80

103 3.MQC mqcapioutapi MQCLOSE MQCLOSE () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] [0x EE...EE] FF...FF (GG...GG) HH...HH(GG...GG) 1 II...II (GG...GG) 1 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 16 FF...FF 10 GG...GG HH...HH 10 81

104 3.MQC mqcapioutapi II...II 10 MQDISC MQDISC () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] EE...EE (FF...FF) 1 GG...GG (FF...FF) 1 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 10 FF...FF GG...GG 10 82

105 3.MQC mqcapioutapi MQPUT1 MQPUT1 () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] EE...EE GG...GG GG...GG WW...WW YY...YY ff...ff ff...ff nn...nn [0x FF...FF FF...FF FF...FF FF...FF] [0x FF...FF FF...FF FF...FF FF...FF] HH...HH(II...II) 1 JJ...JJ (II...II) 1 KK...KK (II...II) LL...LL (II...II) MM...MM (II...II) NN...NN (II...II) OO...OO (II...II) PP...PP (II...II) QQ...QQ (II...II) RR...RR (II...II) SS...SS (II...II) TT...TT (II...II) UU...UU (II...II) [0x VV...VV VV...VV VV...VV VV...VV] [0x VV...VV VV...VV] WW...WW [0x XX...XX XX...XX XX...XX XX...XX] [0x XX...XX XX...XX] YY...YY aa...aa bb...bb cc...cc dd...dd [0x ee...ee ee...ee ee...ee ee...ee] [0x ee...ee ee...ee ee...ee ee...ee] gg...gg hh...hh (II...II) ii...ii jj...jj kk...kk ll...ll [0x mm...mm mm...mm mm...mm mm...mm] [0x mm...mm mm...mm] nn...nn oo...oo 83

106 3.MQC mqcapioutapi 2 pp...pp qq...qq (II...II) rr...rr MQPMOKK...KK (II...II) MQPMOLL...LL (II...II) ss...ss (II...II) [0x tt...tt] uu...uu vv...vv ww...ww xx...xx yy...yy zz...zz MQPMRa1...a1 (II...II) 2 b1...b1 2 c1...c1 2 [0x d1...d1] 2 [0x e1...e1] 2 MQODKK...KK (II...II) MQODLL...LL (II...II) f1...f1 g1...g1 h1...h1 i1...i1 j1...j1 k1...k1 34 uu...uu 134 vv...vv 134 l1...l1 134 b1...b1 34 c1...c1 34 [0x d1...d1] 34 [0x e1...e1] [0x m1...m1 m1...m1 m1...m1 m1...m1] n1...n [0x m1...m1 m1...m1 m1...m1 m1...m1] n1...n [0x m1...m1 m1...m1] n1...n1 4 o1...o1 4 p1...p MQPMO MQPMO_VERSION_2 84

107 3.MQC mqcapioutapi 3 MQOD MQOD_VERSION_2 4 MQOD MQOD_VERSION_3 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 10 FF...FF GG...GG HH...HH 10 II...II JJ...JJ 10 85

108 3.MQC mqcapioutapi KK...KK LL...LL 10 MM...MM 10 NN...NN 10 OO...OO 10 PP...PP 10 QQ...QQ 10 RR...RR 10 SS...SS TT...TT 10 UU...UU 10 VV...VV 16 WW...WW XX...XX 16 YY...YY aa...aa 10 86

109 3.MQC mqcapioutapi bb...bb cc...cc dd...dd ee...ee 16 ff...ff gg...gg hh..hh 10 ii...ii jj...jj 8 kk...kk 8 ll...ll mm...mm 16 nn...nn oo...oo 10 pp...pp 10 qq...qq 16 87

110 3.MQC mqcapioutapi rr...rr 10 ss...ss 10 tt...tt 16 uu...uu 10 vv...vv 10 ww...ww 10 xx...xx yy...yy zz...zz 10 a1...a1 MQPMR b1...b1 c1...c1 d1...d1 16 e1...e1 16 f1...f1 10 g1...g1 88

111 3.MQC mqcapioutapi h1...h1 i1...i1 j1...j1 k1...k1 10 l1...l1 10 m1...m1 16 n1...n1 o1...o1 p1...p1 MQINQ MQINQ () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] [0x EE...EE] FF...FF GG...GG (HH...HH) GG...GG (HH...HH) GG...GG (HH...HH) II...II JJ...JJ KK...KK (HH...HH) 1 LL...LL (HH...HH)

112 3.MQC mqcapioutapi yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 16 FF...FF 10 GG...GG 10 HH...HH II...II 10 JJ...JJ 10 KK...KK 10 LL...LL 10 MQSET MQSET () 90

113 3.MQC mqcapioutapi yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] [0x EE...EE] FF...FF GG...GG (HH...HH) GG...GG (HH...HH) GG...GG (HH...HH) II...II JJ...JJ KK...KK (HH...HH) 1 LL...LL (HH...HH) 1 MM...MM MM...MM MM...MM NN...NN 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 16 FF...FF 10 91

114 3.MQC mqcapioutapi GG...GG 10 HH...HH II...II 10 JJ...JJ 10 KK...KK 10 LL...LL 10 MM...MM 10 NN...NN MQBEGIN MQBEGIN () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] EE...EE (FF...FF) 1 GG...GG (FF...FF) 1 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 92

115 3.MQC mqcapioutapi BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 10 FF...FF GG...GG 10 MQCMIT MQCMIT () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] EE...EE (FF...FF) 1 GG...GG (FF...FF) 1 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 93

116 3.MQC mqcapioutapi DD...DD 16 EE...EE 10 FF...FF GG...GG 10 MQBACK MQBACK () yy/mm/dd hh:mm:ss AA...AA BB...BB IDCC...CC [0x DD...DD] EE...EE (FF...FF) 1 GG...GG (FF...FF) 1 1 yy/mm/dd 2 8 hh:mm:ss 8 AA...AA 10 BB...BB 10 CC...CC ID10 DD...DD 16 EE...EE 10 94

117 3.MQC mqcapioutapi FF...FF GG...GG 10 ID ID IDAA...AA IDAA...AA : IDAA...AA AA...AA ID10 [0xAA...AA] (BB...BB) [0xAA...AA] (BB...BB) : [0xAA...AA] (BB...BB) AA...AA 16 BB...BB 95

118

119 4 MQC MQI C COBOL MQI MQI MQBACK MQBEGIN MQCMIT MQBO MQI MQI C MQI COBOL 97

120 4.MQC MQI MQI MQI MQC OpenTP1 TM MQC TP1/Message Queue MQI MQI TM X/Open XA MQC MQI TM MQC MQI 1 MQCLOSE 2 MQCONN 3 MQDISC 4 MQGET 5 MQINQ 6 MQOPEN 7 MQPUT 8 MQPUT1 1 9 MQSET 10 MQBACK 11 MQBEGIN 12 MQCMIT MQCONN TP1/Message Queue - Access MQI 1 9 TP1/Message Queue MQC 98

121 4.MQC MQI MQI 2.1MQC 99

122 4.MQC MQI MQBACK MQBACK MQBACK C MQBACK (MQHCONN Hconn, MQLONG *CompCode, MQLONG *Reason) COBOL CALL 'MQBACK' USING HCONN, COMPCODE, REASON. HconnMQHCONN input MQCONN CompCodeMQLONG output MQCC_OK MQCC_WARNING MQCC_FAILED ReasonMQLONG output 4-2CompCode MQCC_OK MQBACK MQRC_NONE 100

123 4.MQC MQI MQBACK 4-3CompCode MQCC_WARNING MQBACK MQRC_OUTCOME_PENDING 4-4CompCode MQCC_FAILED MQBACK MQRC_CALL_IN_PROGRESS MQRC_CONNECTION_BROKEN MQRC_ENVIRONMENT_ERROR MQRC_HCONN_ERROR MQRC_OBJECT_DAMAGED MQRC_OUTCOME_MIXED MQRC_Q_MGR_STOPPING MQRC_RESOURCE_PROBLEM MQRC_STORAGE_NOT_AVAILABLE MQRC_UNEXPECTED_ERROR MQI TP1/Message Queue TM MQBEGIN TM MQBACK 1 MQI TP1/Message Queue MQCONN 101

124 4.MQC MQI MQBACK 1 MQGET MQPUT MQPUT1 MQBACK MQRC_HCONN_ERROR 102

125 4.MQC MQI MQBEGIN MQBEGIN MQBEGIN C MQBEGIN (MQHCONN Hconn, MQBO *BeginOptions, MQLONG *CompCode, MQLONG *CompReason) COBOL CALL 'MQBEGIN' USING HCONN, BEGINOPTIONS, COMPCODE, REASON. HconnMQHCONN input MQCONN BeginOptionsMQBO input MQBEGIN MQBO BeginOptions C MQBO NULL CompCodeMQLONG output MQCC_OK MQCC_FAILED ReasonMQLONG output 103

126 4.MQC MQI MQBEGIN 4-5CompCode MQCC_OK MQBEGIN MQRC_NONE 4-6CompCode MQCC_FAILED MQBEGIN MQRC_BO_ERROR MQRC_CALL_IN_PROGRESS MQRC_CONNECTION_BROKEN MQRC_ENVIRONMENT_ERROR MQRC_HCONN_ERROR MQRC_OPTIONS_ERROR MQRC_Q_MGR_STOPPING MQRC_RESOURCE_PROBLEM MQRC_STORAGE_NOT_AVAILABLE MQRC_UNEXPECTED_ERROR MQRC_UOW_IN_PROGRESS MQI TP1/Message Queue MQBEGIN 1. TM MQPUTMQPUT1 MQGET MQPMO_SYNCPOINT MQGMO_SYNCPOINT MQBEGIN MQCMIT MQBACK MQDISC 104

127 4.MQC MQI MQBEGIN MQDISC 2. TM TM TM MQBEGIN MQRC_ENVIRONMENT_ERROR TM MQCMIT MQBACK MQBEGIN MQRC_UOW_IN_PROGRESS 105

128 4.MQC MQI MQCMIT MQCMIT C MQCMIT (MQHCONN Hconn, MQLONG *CompCode, MQLONG *Reason) COBOL CALL 'MQCMIT' USING HCONN, COMPCODE, REASON. HconnMQHCONN input MQCONN CompCodeMQLONG output MQCC_OK MQCC_WARNING MQCC_FAILED ReasonMQLONG output 4-7CompCode MQCC_OK MQCMIT MQRC_NONE 106

129 4.MQC MQI MQCMIT 4-8CompCode MQCC_WARNING MQCMIT MQRC_BACKED_OUT MQRC_OUTCOME_PENDING 4-9CompCode MQCC_FAILED MQCMIT MQRC_CALL_IN_PROGRESS MQRC_CONNECTION_BROKEN MQRC_ENVIRONMENT_ERROR MQRC_HCONN_ERROR MQRC_OBJECT_DAMAGED MQRC_OUTCOME_MIXED MQRC_Q_MGR_STOPPING MQRC_RESOURCE_PROBLEM MQRC_STORAGE_NOT_AVAILABLE MQRC_UNEXPECTED_ERROR MQI TP1/Message Queue TM MQBEGIN TM MQCMIT 1 MQI 107

130 4.MQC MQI MQCMIT TP1/Message Queue MQCONN MQCMIT MQBACK MQDISC MQDISC MQBACK 1 MQGET MQPUT MQPUT1 Reason MQRC_CONNECTION_BROKEN CompCode MQCC_FAILED MQCMIT MQRC_HCONN_ERROR 108

131 4.MQC MQI MQBO MQBO MQBO MQBEGIN 4-10MQBO StrucIdMQCHAR4 MQBO_STRUC_ID VersionMQLONG MQBO_VERSION_1 OptionsMQLONG MQBO_NONE StructIdMQCHAR4 MQBO_STRUC_ID C MQBO_STRUC_ID_ARRAY MQBO_STRUC_ID MQBO_STRUC_ID VersionMQLONG MQBO_VERSION_1 MQBO_VERSION_1 OptionsMQLONG MQBEGIN MQBO_NONE 109

132 4.MQC MQI MQBO MQBO_NONE 110

133 4.MQC MQI MQI MQI

134 4.MQC MQI MQI MQI xa_end(tm_suspend) DCMQCEXPTRN=Y MQCONN MQCONN 112

135 4.MQC MQI MQI C MQI C C /* All Rights Reserved, Copyright (C) 2003, Hitachi, Ltd. */ /*********************************************************** ** mqcsample.c ** functions = main() ***********************************************************/ /*********************************************************** ** name = main() ** func = main function of UAP ** (1)start UAP(output start message) ** (2)MQCONN(Connect queue manager) ** (3)MQOPEN(Open queue) ** (4)MQBEGIN(begin local transaction) ** (5)MQPUT(Put message) ** (6)MQBACK(rollback local transaction) ** (7)MQCMIT(commit local transaction) ** (8)MQBEGIN(begin local transaction) ** (9)MQGET(Get message) ** (10)MQBACK(rollback local transaction) ** (11)MQCMIT(commit local transaction) ** (12)MQCLOSE(Close queue) ** (13)MQDISC(Disconnect queue manager) ** (14)finish UAP(output end message) ***********************************************************/ #include <stdio.h> #include <string.h> #include <cmqc.h> #define PUT_DATA "******** sample put data ********" int main(void) { MQCHAR48 QueueManager = " "; /* queue manager name */ MQLONG comp_code, /* completion code */ reason; /* reason code */ MQHCONN qm_handle; /* connection handle */ MQCHAR message_data[200]; /* buffer */ MQHOBJ que_handle; /* object handle */ MQLONG buffer_length; /* buffer length */ MQLONG data_length; /* message length */ MQLONG open_options; /* open options */ MQOD obj_desc = { MQOD_DEFAULT }; /* object descriptor */ MQMD msg_desc = { MQMD_DEFAULT }; /* message descriptor */ MQPMO put_options = { MQPMO_DEFAULT }; /* put message options */ MQGMO get_options = { MQGMO_DEFAULT }; /* get message options */ MQBO begin_options = { MQBO_DEFAULT }; /* begin options */ 113

136 4.MQC MQI MQI C /* set the queue name */ strcpy(obj_desc.objectname, "dynq1"); /* set the message data */ strcpy(message_data, PUT_DATA) ; buffer_length = strlen(message_data); printf("mqtrn:start service. n"); /* MQCONN( connect to the queue manager ) */ MQCONN(QueueManager, &qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQCONN. CODE = %ld n", reason); goto PROG_END; } /* MQOPEN( open the queue ) */ open_options = MQOO_OUTPUT MQOO_INPUT_AS_Q_DEF; MQOPEN(qm_handle, &obj_desc, open_options, &que_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQOPEN. CODE = %ld n", reason); goto MQ_END; } /* MQBEGIN( begin local transaction ) */ MQBEGIN(qm_handle, &begin_options, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQBEGIN. CODE = %ld n",reason); goto MQ_END; } /* MQPUT( put the message ) */ put_options.options = MQPMO_SYNCPOINT; MQPUT(qm_handle, que_handle, &msg_desc, &put_options, buffer_length, (PMQBYTE)message_data,&comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQPUT. CODE = %ld n", reason); /* MQBACK( rollback local transaction ) */ MQBACK(qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQBACK. CODE = %ld n",reason); } goto MQ_END; } /* MQCMIT( commit local transaction ) */ MQCMIT(qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQCMIT. CODE = %ld n", reason); 114

137 4.MQC MQI MQI C } goto MQ_END; /* MQBEGIN( begin local transaction ) */ MQBEGIN(qm_handle, &begin_options, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQBEGIN. CODE = %ld n",reason); goto MQ_END; } /* MQGET( get the message ) */ get_options.options = MQGMO_SYNCPOINT MQGMO_NO_WAIT; MQGET(qm_handle, que_handle, &msg_desc, &get_options, buffer_length, (PMQBYTE)message_data, &data_length, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQGET. CODE = %ld n", reason); /* MQBACK( rollback local transaction ) */ MQBACK(qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQBACK. CODE = %ld n",reason); } goto MQ_END; } /* MQCMIT( commit local transaction ) */ MQCMIT(qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQCMIT. CODE = %ld n", reason); goto MQ_END; } /* MQCLOSE( close the queue ) */ MQCLOSE(qm_handle, &que_handle, MQCO_NONE, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQCLOSE. CODE = %ld n",reason); } MQ_END: /* MQDISC( disconnect from the queue manager ) */ MQDISC(&qm_handle, &comp_code, &reason); if (comp_code!= MQCC_OK) { printf("mqtrn:failed at MQDISC. CODE = %ld n", reason); } PROG_END: printf("mqtrn:terminate service. n"); return(0); } 115

138 4.MQC MQI MQI COBOL MQI COBOL COBOL ***************************************************** * MQ-ACCESS SAMPLE * ***************************************************** * IDENTIFICATION DIVISION. * PROGRAM-ID. MAIN. * ***************************************************** * INITIALIZE * ***************************************************** * DATA DIVISION. WORKING-STORAGE SECTION. * 01 MQ-MGRNAME PIC X(48) VALUE SPACES. 01 MQ-HCONN PIC S9(9) BINARY. 01 MQ-COMPCODE PIC S9(9) BINARY. 01 MQ-REASON PIC S9(9) BINARY. 01 MQ-HOBJ PIC S9(9) BINARY. 01 MQ-OPTIONS PIC S9(9) BINARY. 01 MQ-BUFFLEN PIC S9(9) BINARY. 01 MQ-DATALEN PIC S9(9) BINARY. 01 MQ-BUFFER PIC X(200) VALUE SPACE. * 01 PUT-DATA PIC X(33) VALUE '***** COBOL sample put data *****'. 01 QUEUENAME PIC X(48) VALUE 'dynq1 * 01 MQ-OBJECT-DESC. COPY CMQODV. * 01 MQ-MESSAGE-DESCRIPTOR. COPY CMQMDV. * 01 MQ-PUT-MESSAGE-OPTIONS. COPY CMQPMOV. * 01 MQ-GET-MESSAGE-OPTIONS. COPY CMQGMOV. * 01 MQ-BEGIN-OPTIONS. COPY CMQBOV. * 01 MQ-CONSTANTS. COPY CMQV SUPPRESS. * PROCEDURE DIVISION. * '. 116

139 4.MQC MQI MQI COBOL ***************************************************** * CONNECT TO THE QUEUE MANAGER * ***************************************************** * CALL 'MQCONN' USING MQ-MGRNAME MQ-HCONN MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQCONN FAILED. REASON CODE = ' MQ-REASON STOP RUN END-IF. * ***************************************************** * OPEN THE QUEUE * ***************************************************** * MOVE QUEUENAME TO MQOD-OBJECTNAME. * COMPUTE MQ-OPTIONS = MQOO-OUTPUT + MQOO-INPUT-AS-Q-DEF. * CALL 'MQOPEN' USING MQ-HCONN MQOD MQ-OPTIONS MQ-HOBJ MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQOPEN FAILED. REASON CODE = ' MQ-REASON GO TO PROG-END END-IF. * ***************************************************** * SET THE PUT MESSAGE OPTIONS * ***************************************************** * MOVE MQPMO-SYNCPOINT TO MQPMO-OPTIONS. MOVE 33 TO MQ-BUFFLEN. * MOVE PUT-DATA TO MQ-BUFFER. * ***************************************************** * SET THE GET MESSAGE OPTIONS * ***************************************************** * MOVE MQGMO-SYNCPOINT TO MQGMO-OPTIONS. * ***************************************************** * BEGIN LOCAL TRANSACTION * ***************************************************** * CALL 'MQBEGIN' USING MQ-HCONN MQ-BEGIN-OPTIONS MQ-COMPCODE 117

140 4.MQC MQI MQI COBOL MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQBEGIN FAILED. REASON CODE = ' MQ-REASON STOP RUN END-IF. * ***************************************************** * PUT THE MESSAGE * ***************************************************** * CALL 'MQPUT' USING MQ-HCONN MQ-HOBJ MQMD MQPMO MQ-BUFFLEN MQ-BUFFER MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQPUT FAILED. REASON CODE = ' MQ-REASON END-IF. * ***************************************************** * COMMIT LOCAL TRANSACTION * ***************************************************** * CALL 'MQCMIT' USING MQ-HCONN MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQCMIT FAILED. REASON CODE = ' MQ-REASON MQ-COMPCODE STOP RUN END-IF. * ***************************************************** * BEGIN LOCAL TRANSACTION * ***************************************************** * CALL 'MQBEGIN' USING MQ-HCONN MQ-BEGIN-OPTIONS MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQBEGIN FAILED. REASON CODE = ' MQ-REASON STOP RUN END-IF. * ***************************************************** * GET THE MESSAGE * ***************************************************** * CALL 'MQGET' USING MQ-HCONN MQ-HOBJ 118

141 4.MQC MQI MQI COBOL MQMD MQGMO MQ-BUFFLEN MQ-BUFFER MQ-DATALEN MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQGET FAILED. REASON CODE = ' MQ-REASON END-IF. * ***************************************************** * COMMIT LOCAL TRANSACTION * ***************************************************** * CALL 'MQCMIT' USING MQ-HCONN MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQCMIT FAILED. REASON CODE = ' MQ-REASON MQ-COMPCODE STOP RUN END-IF. * ***************************************************** * CLOSE THE QUEUE * ***************************************************** * MOVE MQCO-NONE TO MQ-OPTIONS. * CALL 'MQCLOSE' USING MQ-HCONN MQ-HOBJ MQ-OPTIONS MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQCLOSE FAILED. REASON CODE = ' MQ-REASON END-IF. * PROG-END. * ***************************************************** * DISCONNECT FROM THE QUEUE MANAGER * ***************************************************** * CALL 'MQDISC' USING MQ-HCONN MQ-COMPCODE MQ-REASON. IF MQ-COMPCODE NOT = MQCC-OK THEN DISPLAY 'MQTRN:MQDISC FAILED. REASON CODE = ' MQ-REASON END-IF. * STOP RUN. END PROGRAM MAIN. 119

142

143 5 MQC C++ MQC C++ MQC C++ C++ ImqBinary C++ ImqCache C++ ImqDeadLetterHeader C++ ImqDistributionList C++ ImqError C++ ImqGetMessageOptions C++ ImqHeader C++ ImqItem C++ ImqMessage C++ ImqMessageTracker C++ ImqObject C++ ImqProcess C++ ImqPutMessageOptions C++ ImqQueue C++ 121

144 5.MQC C++ ImqQueueManager C++ ImqReferenceHeader C++ ImqString C++ ImqTrigger C++ C++ C++ 122

145 5.MQC C++ MQC C++ MQC C++ MQC C++ 5-1C++ ImqBinary ImqCache ImqDeadLetterHeader ImqDistributionList ImqError ImqGetMessageOptions ImqHeader ImqItem ImqMessage ImqMessageTracker ImqObject ImqProcess ImqPutMessageOptions ImqQueue ImqQueueManager ImqReferenceHeader ImqString ImqTrigger 2 MQDLH MQGMO MQDLH MQMD ImqMessage ImqQueue MQPMO MQRMH MQTM 123

146 5.MQC C++ C++ C++ 5-1C++ 124

147 5.MQC C++ ImqBinary C++ ImqBinary C++ ImqMessageTracker accounting tokencorrelation id message id 2 imqbin.hpp data 2 data length data pointer data ImqBinary( ); ImqBinary(const ImqBinary & binary ); ImqBinary( const void * dataconst size_t length ); data length virtual ImqBoolean copyout( ImqMessage & msg ); ImqItem data msg format MQFMT_NONE ImqItem C++ virtual ImqBoolean pastein( ImqMessage & msg ); ImqItem data data 125

148 5.MQC C++ ImqBinary C++ ImqMessage format MQFMT_NONE ImqItem C++ void operator = ( const ImqBinary & binary ); binary ImqBoolean operator == ( const ImqBinary & binary ); binary 0 0 datalength ImqBoolean copyout( void * bufferconst size_t lengthconst char pad = 0 ); length data pointer buffer data length buffer pad length 0 buffer 0 length TRUE size_t datalength( ) const ; data length ImqBoolean setdatalength( const size_t length ); data length data length TRUE void * datapointer( ) const ; data pointer ImqBoolean isnull( ) const ; data length 0 data 0 TRUE FALSE ImqBoolean set( const void * bufferconst size_t length ); buffer length TRUE protected void clear( ); data length 0 126

149 5.MQC C++ ImqBinary C++ ImqItem ImqMessage MQRC_NO_BUFFER MQRC_STORAGE_NOT_AVAILABLE ATP1/ Message Queue 127

150 5.MQC C++ ImqCache C++ ImqCache C++ imqcac.hpp automatic buffer TRUE FALSE TRUE buffer length 0 buffer pointer data length data pointer message length 0 data offset data pointer message length 0 data pointer message length 0 ImqCache( ); 128

151 5.MQC C++ ImqCache C++ ImqCache( const ImqCache & cache ); void operator = ( const ImqCache & cache ); message length cache automatic buffer FALSE buffer length ImqBoolean automaticbuffer( ) const ; automatic buffer size_t bufferlength( ) const ; buffer length char * bufferpointer( ) const ; buffer pointer void clearmessage( ); message length data offset 0 size_t datalength( ) const ; data length size_t dataoffset( ) const ; data offset ImqBoolean setdataoffset( const size_t offset ); data offset message length data offset message length TRUE char * datapointer( ) const ; data pointer size_t messagelength( ) const ; message length ImqBoolean setmessagelength( const size_t length ); message length 129

152 5.MQC C++ ImqCache C++ message length buffer length buffer length data offset message length data offset TRUE ImqBoolean morebytes( const size_t bytes-required ); data pointer bytes-required TRUE automatic buffer TRUE buffer length ImqBoolean read( const size_t lengthchar * & external-buffer ); length data pointer external-buffer data offset length TRUE ImqBoolean resizebuffer( const size_t length ); automatic buffer TRUE buffer length message length length buffer pointer message length data offset TRUE automatic buffer FALSE FALSE MQRC_STORAGE_NOT_AVAILABLE ImqBoolean useemptybuffer( const char * external-bufferconst size_t length ); buffer pointer external-buffer buffer length length message length 0 clearmessage usefullbuffer setmessagelength TRUE external-buffer length 0 automatic buffer FALSE external-buffer length 0 automatic buffer TRUE 130

153 5.MQC C++ ImqCache C++ ImqBoolean usefullbuffer( const char * externalbufferconst size_t length ); ImqBoolean useemptybuffer message length length TRUE ImqBoolean write( const size_t lengthconst char * external-buffer ); length external-buffer data1 pointer data offset length message length data offset message length TRUE automatic buffer TRUE data offset buffer length ImqError MQRC_BUFFER_NOT_AUTOMATIC MQRC_DATA_TRUNCATED MQRC_INSUFFICIENT_BUFFER MQRC_INSUFFICIENT_DATA MQRC_NULL_POINTER MQRC_STORAGE_NOT_AVAILABLE MQRC_ZERO_LENGTH ATP1/ Message Queue 131

154 5.MQC C++ ImqDeadLetterHeader C++ ImqDeadLetterHeader C++ MQDLH imqdlh.hpp dead-letter reason code MQRC_NONE MQDLH Reason destination queue manager name MQDLH DestQMgrName destination queue name MQDLH DestQName put application name MQDLH PutApplName put application type 0 MQDLH PutApplType put date MQDLH PutDate 132

155 5.MQC C++ ImqDeadLetterHeader C++ put time MQDLH PutTime ImqDeadLetterHeader( ); ImqDeadLetterHeader( const ImqDeadLetterHeader & header ); virtual ImqBoolean copyout( ImqMessage & msg ); ImqItem MQDLH msg format MQFMT_DEAD_LETTER_HEADER ImqHeader C++ virtual ImqBoolean pastein( ImqMessage & msg ); ImqItem MQDLH ImqMessage format MQFMT_DEAD_LETTER_HEADER ImqHeader C++ void operator = ( const ImqDeadLetterHeader & header ); header MQLONG deadletterreasoncode( ) const ; dead-letter reason code void setdeadletterreasoncode( const MQLONG reason ); dead-letter reason code ImqString destinationqueuemanagername( ) const ; destination queue manager name 133

156 5.MQC C++ ImqDeadLetterHeader C++ void setdestinationqueuemanagername( const char * name ); destination queue manager name ImqString destinationqueuename( ) const ; destination queue name void setdestinationqueuename( const char * name ); destination queue name ImqString putapplicationname( ) const ; put application name void setputapplicationname( const char * name = 0 ); put application name MQLONG putapplicationtype( ) const ; put application type void setputapplicationtype( const MQLONG type = MQAT_NO_CONTEXT ); put application type ImqString putdate( ) const ; put date void setputdate( const char * date = 0 ); put date ImqString puttime( ) const ; put time void setputtime( const char * time = 0 ); put time protected MQDLH omqdlh MQDLH ImqHeader 134

157 5.MQC C++ ImqDeadLetterHeader C++ ImqItem ImqMessage ImqString 135

158 5.MQC C++ ImqDistributionList C++ ImqDistributionList C++ imqdst.hpp first distributed queue ImqQueue ImqQueue distribution list reference 0 ImqDistributionList ImqQueue ImqDistributionList(); ImqDistributionList(const ImqDistributionList & list); void operator = (const ImqDistributionList & list); ImqQueue ImqQueue ImqQueue * firstdistributedqueue() const; first distributed queue protected void setfirstdistributedqueue(imqqueue * queue = 0); first distributed queue ImqMessage 136

159 5.MQC C++ ImqDistributionList C++ ImqQueue 137

160 5.MQC C++ ImqError C++ ImqError C++ imqerr.hpp completion code 0 reason code 0 ImqError( ); ImqError( const ImqError & error ); void operator = ( const ImqError & error ); error void clearerrorcodes( ); completion code reason code 0 MQLONG completioncode( ) const ; completion code MQLONG reasoncode( ) const ; reason code 138

161 5.MQC C++ ImqError C++ protected ImqBoolean checkreadpointer( const void * pointerconst size_t length ); pointer length TRUE ImqBoolean checkwritepointer( const void * pointerconst size_t length ); pointer length TRUE void setcompletioncode( const MQLONG code = 0 ); completion code void setreasoncode( const MQLONG code = 0 ); reason code MQRC_BUFFER_ERROR TP1/Message Queue 139

162 5.MQC C++ ImqGetMessageOptions C++ ImqGetMessageOptions C++ MQGMO imqgmo.hpp group status MQGS_NOT_IN_GROUP MQGMO GroupStatus match options MQMO_MATCH_MSG_ID MQMO_MATCH_CORREL_ID MQGMO MatchOptions options MQGMO_NO_WAIT MQGMO Options resolved queue name 48 MQGMO ResolvedQName segmentation MSEG_INHIBITED MQGMO Segmentation segment status MQSS_NOT_A_SEGMENT MQGMO SegmentStatus 140

163 5.MQC C++ ImqGetMessageOptions C++ sync-point participation TRUE wait interval ImqQueue get 0 options MQGMO_WAIT MQGMO WaitInterval ImqGetMessageOptions( ); ImqGetMessageOptions( const ImqGetMessageOptions & gmo ); void operator = ( const ImqGetMessageOptions & gmo ); gmo MQCHAR groupstatus() const ; group status void setgroupstatus( const MQCHAR status); group status MQLONG matchoptions() const ; match options void setmatchoptions( const MQLONG options); match options MQLONG options( ) const ; options void setoptions( const MQLONG options ); sync-point participation options 141

164 5.MQC C++ ImqGetMessageOptions C++ ImqString resolvedqueuename( ) const ; resolved queue name MQCHAR segmentation( ) const ; segmentation void setsegmentation( const MQCHAR value ); segmentation MQCHAR segmentstatus( ) const ; segment status void setsegmentstatus( const MQCHAR status ); segment status ImqBoolean syncpointparticipation( ) const ; sync-point participation options MQGMO_SYNCPOINT TRUE void setsyncpointparticipation( const ImqBoolean sync ); sync-point participation options MQGMO_SYNCPOINT MQLONG waitinterval( ) const ; wait interval void setwaitinterval( const MQLONG interval ); wait interval protected PMQGMO opgmo MQGMO MQLONG olversion opgmo MQGMO ImqString 142

165 5.MQC C++ ImqHeader C++ ImqHeader C++ MQDLH MQRMH imqhdr.hpp character set MQCCSI_Q_MGR MQDLH MQRMH CodedCharSetId encoding MQENC_NATIVE MQDLH MQRMH Encoding format MQFMT_NONE MQDLH MQRMH Format header flags ImqDeadLetterHeader 0 ImqIMSBridgeHeader MQIIH_NONE ImqReferenceHeader MQRMHF_LAST MQRMH Flags ImqHeader( ); ImqHeader( const ImqHeader & header ); 143

166 5.MQC C++ ImqHeader C++ void operator=( const ImqHeader & header ); header virtual MQLONG characterset( ) const; character set virtual void setcharacterset( const MQLONG ccsid = MQCCSI_Q_MGR ); character set virtual MQLONG encoding( ) const ; encoding virtual void setencoding( const MQLONG encoding = MQENC_NATIVE ); encoding virtual ImqString format( ) const ; format virtual void setformat( const char * name = 0 ); format 8 virtual MQLONG headerflags() const ; header flags virtual void setheaderflags( const MQLONG flags = 0 ); header flags ImqDeadLetterHeader ImqItem ImqMessage ImqReferenceHeader ImqString 144

167 5.MQC C++ ImqItem C++ ImqItem C++ ID ImqMessage readitem writeitem imqitm.hpp structure id 4 MQ* StrucId ImqItem( ); ImqItem( const ImqItem & item ); static ImqBoolean structureidis( const char * structure-id-to-testconst ImqMessage & msg ); msg ImqItem structure id structure-id-to-test TRUE ImqCache data pointer void operator = ( const ImqItem & item ); item virtual ImqBoolean copyout( ImqMessage & msg ) = 0 ; 145

168 5.MQC C++ ImqItem C++ ImqCache data length TRUE virtual ImqBoolean pastein( ImqMessage & msg ) = 0 ; msg structure id msg encoding MQENC_NATIVE ImqMessage encoding MQENC_NATIVE ImqGetMessageOptions ImqCache data length TRUE ImqCache ImqError ImqMessage MQRC_ENCODING_ERROR MQRC_STRUC_ID_ERROR MQRC_INCONSISTENT_FORMAT MQRC_INSUFFICIENT_BUFFER MQRC_INSUFFICIENT_DATA A 146

169 5.MQC C++ ImqMessage C++ ImqMessage C++ MQMD imqmsg.hpp application id data ID MQMD ApplIdentityData application origin data MQMD ApplOriginData backout count 0 MQMD BackoutCount character set ID MQCCSI_Q_MGR MQMD CodedCharSetId encoding MQENC_NATIVE MQMD Encoding expiry TP1/Message Queue - Access MQEI_UNLIMITED MQMD Expiry 147

170 5.MQC C++ ImqMessage C++ format MQFMT_NONE MQMD Format message flags MQMF_SEGMENTATION_INHIBITED MQMD MsgFlags message type MQMT_DATAGRAM MQMD MsgType offset 0 MQMD Offset original length MQOL_UNDEFINED MQMD OriginalLength persistence MQPER_PERSISTENCE_AS_Q_DEF MQMD Persistence priority MQPRI_PRIORITY_AS_Q_DEF MQMD Priority put application name 148

171 5.MQC C++ ImqMessage C++ MQMD PutApplName put application type MQAT_NO_CONTEXT MQMD PutApplType put date MQMD PutDate put time MQMD PutTime reply-to queue manager name MQMD ReplyToQMgr reply-to queue name MQMD ReplyToQ report MQRO_NONE MQMD Report sequence number 1 MQMD MsgSeqNumber total message length 0 ImqCache message length 149

172 5.MQC C++ ImqMessage C++ user id ID MQMD UserIdentifier ImqMessage( ); ImqMessage( const ImqMessage & msg ); operator void operator = ( const ImqMessage & msg ); msg MQMD ImqString applicationiddata( ) const ; application id data void setapplicationiddata( const char * data = 0 ); application id data ImqString applicationorigindata( ) const ; application origin data void setapplicationorigindata( const char * data = 0 ); application origin data MQLONG backoutcount( ) const ; backout count MQLONG characterset( ) const ; character set 150

173 5.MQC C++ ImqMessage C++ void setcharacterset( const MQLONG ccsid = MQCCSI_Q_MGR ); character set MQLONG encoding( ) const ; encoding void setencoding( const MQLONG encoding = MQENC_NATIVE ); encoding MQLONG expiry( ) const ; expiry void setexpiry( const MQLONG expiry ); expiry ImqString format( ) const ; format ImqBoolean formatis( const char * format-to-test ) const ; format format-to-test TRUE void setformat( const char * name = 0 ); format 8 MQLONG messageflags() const ; message flags void setmessageflags( const MQLONG flags); message flags MQLONG messagetype( ) const ; message type void setmessagetype( const MQLONG type ); message type MQLONG offset() const ; offset 151

174 5.MQC C++ ImqMessage C++ void setoffset( const MQLONG offset); offset MQLONG originallength() const ; original length void setoriginallength( const MQLONG length); original length MQLONG persistence( ) const ; persistence void setpersistence( const MQLONG persistence ); persistence MQLONG priority( ) const ; priority void setpriority( const MQLONG priority ); priority ImqString putapplicationname( ) const ; put application name void setputapplicationname( const char * name = 0 ); put application name MQLONG putapplicationtype( ) const ; put application type void setputapplicationtype( const MQLONG type = MQAT_NO_CONTEXT ); put application type ImqString putdate( ) const ; put date void setputdate( const char * date = 0 ); put date 152

175 5.MQC C++ ImqMessage C++ ImqString puttime( ) const ; put time void setputtime( const char * time = 0 ); put time ImqBoolean readitem( ImqItem & item ); ImqItem pastein item TRUE ImqString replytoqueuemanagername( ) const ; reply-to queue manager name void setreplytoqueuemanagername( const char * name = 0 ); reply-to queue manager name ImqString replytoqueuename( ) const ; reply-to queue name void setreplytoqueuename( const char * name = 0 ); reply-to queue name MQLONG report( ) const ; report void setreport( const MQLONG report ); report MQLONG sequencenumber() const ; sequence number void setsequencenumber( const MQLONG number); sequence number size_t totalmessagelength( ) const ; total message length ImqString userid( ) const ; user id 153

176 5.MQC C++ ImqMessage C++ void setuserid( const char * id = 0 ); user id ImqBoolean writeitem( ImqItem & item ); ImqItem copyout item item TRUE protected MQMD omqmd MQMD ImqCache ImqItem ImqMessageTracker ImqString MQRC_ENCODING_ERROR MQRC_STRUC_ID_ERROR MQRC_INSUFFICIENT_BUFFER MQRC_INSUFFICIENT_DATA A 154

177 5.MQC C++ ImqMessageTracker C++ ImqMessageTracker C++ ImqMessage ImqQueue imqmtr.hpp accounting token MQ_ACCOUNTING_TOKEN_LENGTH 2 MQBYTE32 MQACT_NONE MQMD MQPMR AccountingToken correlation id MQ_CORREL_ID_LENGTH 2 MQBYTE24 MQCI_NONE MQMD MQPMR CorrelId feedback MQFB_NONE MQMD MQPMR Feedback group id MQ_GROUP_ID_LENGTH 2 MQBYTE24 MQGI_NONE MQMD MQPMR GroupId message id MQ_MSG_ID_LENGTH 2 MQBYTE24 MQMI_NONE MQMD MQPMR MsgId 155

178 5.MQC C++ ImqMessageTracker C++ ImqMessageTracker( ); ImqMessageTracker( const ImqMessageTracker & tracker ); operator void operator = ( const ImqMessageTracker & tracker ); tracker ImqBinary accountingtoken( ) const ; accounting token ImqBoolean setaccountingtoken( const ImqBinary & token ); accounting token token data length 0 MQ_ACCOUNTING_TOKEN_ID_LENGTH TRUE void setaccountingtoken( const MQBYTE32 token = 0 ); accounting token token 0 MQACT_NONE token 0 MQ_ACCOUNTING_TOKEN_LENGTH 2 MQACT_NONE (MQBYTE *)MQACT_NONE ImqBinary correlationid( ) const ; correlation id ImqBoolean setcorrelationid( const ImqBinary & token ); correlation id token data length 0 MQ_CORREL_ID_LENGTH TRUE 156

179 5.MQC C++ ImqMessageTracker C++ void setcorrelationid( const MQBYTE24 id = 0 ); correlation id id 0 MQCI_NONE id 0 MQ_CORREL_ID_LENGTH 2 MQCI_NONE (MQBYTE *)MQCI_NONE MQLONG feedback( ) const ; feedback void setfeedback( const MQLONG feedback ); feedback ImqBinary groupid() const ; group id ImqBoolean setgroupid( const ImqBinary & token); group id token data length 0 MQ_GROUP_ID_LENGTH TRUE void setgroupid( const MQBYTE24 id = 0); group id id 0 MQGI_NONE id 0 MQ_GROUP_ID_LENGTH 2 MQGI_NONE (MQBYTE *)MQGI_NONE ImqBinary messageid( ) const ; message id ImqBoolean setmessageid( const ImqBinary & token ); message id token data length 0 MQ_MSG_ID_LENGTH TRUE void setmessageid( const MQBYTE24 id = 0 ); message id id 0 MQMI_NONE id 0 MQ_MSG_ID_LENGTH 2 MQMI_NONE 157

180 5.MQC C++ ImqMessageTracker C++ (MQBYTE*)MQMI_NONE ImqBinary ImqError ImqMessage ImqQueue MQRC_BINARY_DATA_LENGTH_ERROR A 158

181 5.MQC C++ ImqObject C++ ImqObject C++ ImqQueueManager imqobj.hpp alternate user id MQ_USER_ID_LENGTH MQOD AlternateUserId close options MQCO_NONE MQCO_NONE connection reference ImqQueueManager ImqQueueManager connection reference ImqQueue queue manager name description 64 name 48 open MQOD MQOR ObjectName ObjectQMgrName 159

182 5.MQC C++ ImqObject C++ next managed object connection reference 0 open options MQOO_INQUIRE 2 1. open options open TP1/Message Queue - Access open options TP1/Message Queue - Access openfor open options 2. MQI open options open options open open options open TP1/Message Queue - Access setopenoptions(open options) open( ) openfor(open options) open status TRUEFALSE FALSE previous managed object connection reference 0 ImqObject( ); 160

183 5.MQC C++ ImqObject C++ ImqObject( const ImqObject & object ); open status FALSE void operator = ( const ImqObject & object ); object open status FALSE ImqString alternateuserid( ) const ; alternate user id ImqBoolean setalternateuserid( const char * id ); alternate user id alternate user id open status FALSE TRUE ImqBoolean close( ); open status FALSE TRUE MQCLOSE MQLONG closeoptions( ) const ; close options void setcloseoptions( const MQLONG options ); close options ImqQueueManager * connectionreference( ) const ; connection reference void setconnectionreference( ImqQueueManager & manager ); connection reference void setconnectionreference( ImqQueueManager * manager = 0 ); connection reference virtual ImqBoolean description( ImqString & description ) = 0 ; description TRUE MQINQ MQCA_Q_MGR_DESC MQCA_Q_DESC MQCA_PROCESS_DESC 161

184 5.MQC C++ ImqObject C++ ImqString description( ); description MQINQ MQCA_Q_MGR_DESC MQCA_Q_DESC MQCA_PROCESS_DESC ImqObject * nextmanagedobject( ) const ; next managed object virtual ImqBoolean name( ImqString & name ); name TRUE MQINQ MQCA_Q_MGR_NAME MQCA_Q_NAME MQCA_PROCESS_NAME ImqString name( ); name MQINQ MQCA_Q_MGR_NAME MQCA_Q_NAME MQCA_PROCESS_NAME ImqBoolean setname( const char * name = 0 ); name name open status FALSE ImqQueueManager connection status FALSE TRUE ImqBoolean open( ); open options name open status TRUE ImqQueueManager connection status TRUE connection reference ImqQueueManager connect open status MQOPEN ImqBoolean openfor( const MQLONG required-options = 0 ); required-options open options required-options 0 open options MQOO_INPUT_AS_Q_DEFMQOO_INPUT_SHARED MQOO_INPUT_EXCLUSIVE open options 162

185 5.MQC C++ ImqObject C++ open options MQOO_INPUT_AS_Q_DEFMQOO_INPUT_SHARED MQOO_INPUT_EXCLUSIVE open options MQOO_INPUT_AS_Q_DEF required-options 0 open options open options MQOO_INPUT_AS_Q_DEFMQOO_INPUT_SHARED MQOO_INPUT_EXCLUSIVE open options open options TRUE MQOPEN MQLONG openoptions( ) const ; open options ImqBoolean setopenoptions( const MQLONG options ); open options open options open status FALSE TRUE ImqBoolean openstatus( ) const ; open status ImqObject * previousmanagedobject( ) const ; previous managed object protected MQHCONN connectionhandle( ) const ; connection reference MQHCONN connection reference ImqQueueManager 0 ImqBoolean inquire( const MQLONG int-attrmqlong & value ); MQIA_* MQIAV_UNDEFINED 163

186 5.MQC C++ ImqObject C++ ImqBoolean inquire( const MQLONG char-attrchar * & bufferconst size_t length ); MQCA_* MQC C++ MQINQ virtual void openinformationdisperse( ); MQOPEN MQOD virtual ImqBoolean openinformationprepare( ); MQOPEN MQOD TRUE ImqBoolean set( const MQLONG int-attrconst MQLONG value ); TP1/Message Queue - Access ImqBoolean set( const MQLONG char-attrconst char * bufferconst size_t required-length ); TP1/Message Queue - Access void setnextmanagedobject( const ImqObject * object = 0 ); next managed object void setpreviousmanagedobject( const ImqObject * object = 0 ); previous managed object protected MQHOBJ ohobj TP1/Message Queue - Access open status TRUE MQOD omqod MQOD ImqBinary ImqError 164

187 5.MQC C++ ImqObject C++ ImqQueue ImqQueueManager ImqString MQRC_ATTRIBUTE_LOCKED MQRC_INCONSISTENT_OBJECT_STATE MQRC_NO_CONNECTION_REFERENCE MQRC_STORAGE_NOT_AVAILABLE MQCLOSE MQCONN MQINQ MQOPEN ATP1/ Message Queue 165

188 5.MQC C++ ImqProcess C++ ImqProcess C++ MQOT_PROCESS imqpro.hpp application id ID application type environment data user data ImqProcess( ); ImqProcess( const ImqProcess & process ); ImqObject open status FALSE ImqProcess( const char * name ); ImqObject name void operator = ( const ImqProcess & process ); process ImqObject open status FALSE ImqBoolean applicationid( ImqString & id ); application id TRUE 166

189 5.MQC C++ ImqProcess C++ MQINQ MQCA_APPL_ID ImqString applicationid( ); application id MQINQ MQCA_APPL_ID ImqBoolean applicationtype( MQLONG & type ); application type TRUE MQINQ MQIA_APPL_TYPE MQLONG applicationtype( ); application type MQINQ MQIA_APPL_TYPE ImqBoolean environmentdata( ImqString & data ); environment data TRUE MQINQ MQCA_ENV_DATA ImqString environmentdata( ); environment data MQINQ MQCA_ENV_DATA ImqBoolean userdata( ImqString & data ); user data TRUE MQINQ MQCA_USER_DATA ImqString userdata( ); user data MQINQ MQCA_USER_DATA ImqObject 167

190 5.MQC C++ ImqPutMessageOptions C++ ImqPutMessageOptions C++ MQPMO imqpmo.hpp context reference ImqQueue MQPMO Context options MQPMO_NONE MQPMO Options record fields PUT MQPMRF_NONE ImqMessageTracker ImqQueue ImqMessageTracker ImqMessage MQPMO PutMsgRecFields resolved queue manager name MQPMO ResolvedQMgrName resolved queue name MQPMO ResolvedQName sync-point participation TRUE 168

191 5.MQC C++ ImqPutMessageOptions C++ ImqPutMessageOptions( ); ImqPutMessageOptions( const ImqPutMessageOptions & pmo ); void operator = ( const ImqPutMessageOptions & pmo ); pmo ImqQueue * contextreference( ) const ; context reference void setcontextreference( const ImqQueue & queue ); context reference void setcontextreference( const ImqQueue * queue = 0 ); context reference MQLONG options( ) const ; options void setoptions( const MQLONG options ); sync-point participation options MQLONG recordfields() const ; record fields void setrecordfields( const MQLONG fields); record fields ImqString resolvedqueuemanagername( ) const ; resolved queue manager name ImqString resolvedqueuename( ) const ; resolved queue name 169

192 5.MQC C++ ImqPutMessageOptions C++ ImqBoolean syncpointparticipation( ) const ; sync-point participation options MQPMO_SYNCPOINT TRUE void setsyncpointparticipation( const ImqBoolean sync ); sync-point participation options MQPMO_SYNCPOINT protected MQPMO omqpmo MQPMO ImqError ImqMessage ImqQueue ImqString MQRC_STORAGE_NOT_AVAILABLE TP1/Message Queue 170

193 5.MQC C++ ImqQueue C++ ImqQueue C++ MQOT_Q imqque.hpp base queue name cluster name creation date creation time current depth default bind default input open option default persistence default priority definition type 171

194 5.MQC C++ ImqQueue C++ distribution list reference ImqDistributionList ImqQueue ImqQueue ImqDistributionList distribution lists dynamic queue name UNIX "AMQ.*" MQOD DynamicQName harden get backout inhibit get inhibit put initiation queue name maximum depth maximum message length message delivery sequence 172

195 5.MQC C++ ImqQueue C++ next distributed queue ImqQueue ImqDistributionList distribution list reference 0 open input count ImqQueue open output count ImqQueue previous distributed queue ImqQueue ImqDistributionList distribution list reference 0 process name queue manager name ImqObject connection reference MQOD MQOR ObjectQMgrName queue type remote queue manager name remote queue name resolved queue manager name 173

196 5.MQC C++ ImqQueue C++ MQOD ResolvedQMgrName resolved queue name MQOD ResolvedQName scope shareability transmission queue name trigger control trigger data trigger depth trigger message priority trigger type usage ImqQueue( ); 174

197 5.MQC C++ ImqQueue C++ ImqQueue( const ImqQueue & queue ); ImqObject open status FALSE ImqQueue( const char * name ); ImqObject name void operator = ( const ImqQueue & queue ); queue ImqObject open status FALSE ImqBoolean basequeuename( ImqString & name ); base queue name TRUE MQINQ MQCA_BASE_Q_NAME ImqString basequeuename( ); base queue name MQINQ MQCA_BASE_Q_NAME ImqBoolean clustername( ImqString & name ); cluster name TRUE MQINQ MQCA_CLUSTER_NAME ImqString clustername(); cluster name MQINQ MQCA_CLUSTER_NAME ImqBoolean creationdate( ImqString & date ); creation date TRUE MQINQ MQCA_CREATION_DATE ImqString creationdate( ); creation date MQINQ MQCA_CREATION_DATE 175

198 5.MQC C++ ImqQueue C++ ImqBoolean creationtime( ImqString & time ); creation time TRUE MQINQ MQCA_CREATION_TIME ImqString creationtime( ); creation time MQINQ MQCA_CREATION_TIME ImqBoolean currentdepth( MQLONG & depth ); current depth TRUE MQINQ MQIA_CURRENT_Q_DEPTH MQLONG currentdepth( ); current depth MQINQ MQIA_CURRENT_Q_DEPTH ImqBoolean defaultinputopenoption( MQLONG & option ); default input open option TRUE MQINQ MQIA_DEF_INPUT_OPEN_OPTION MQLONG defaultinputopenoption( ); default input open option MQINQ MQIA_DEF_INPUT_OPEN_OPTION ImqBoolean defaultpersistence( MQLONG & persistence ); default persistence TRUE MQINQ MQIA_DEF_PERSISTENCE MQLONG defaultpersistence( ); default persistence MQINQ MQIA_DEF_PERSISTENCE ImqBoolean defaultpriority( MQLONG & priority ); default priority TRUE 176

199 5.MQC C++ ImqQueue C++ MQINQ MQIA_DEF_PRIORITY MQLONG defaultpriority( ); default priority MQINQ MQIA_DEF_PRIORITY ImqBoolean defaultbind( MQLONG & bind ); default bind TRUE MQINQ MQIA_DEF_BIND MQLONG defaultbind(); default bind MQINQ MQIA_DEF_BIND ImqBoolean definitiontype( MQLONG & type ); definition type TRUE MQINQ MQIA_DEFINITION_TYPE MQLONG definitiontype( ); definition type MQINQ MQIA_DEFINITION_TYPE ImqDistributionList * distributionlistreference() const ; distribution list reference void setdistributionlistreference( ImqDistributionList & list ); distribution list reference void setdistributionlistreference( ImqDistributionList * list = 0 ); distribution list reference ImqBoolean distributionlists( MQLONG & support ); distribution lists TRUE MQINQ MQIA_DIST_LISTS MQLONG distributionlists(); distribution lists 177

200 5.MQC C++ ImqQueue C++ MQINQ MQIA_DIST_LISTS ImqBoolean setdistributionlists( const MQLONG support ); distribution lists TRUE MQSET MQIA_DIST_LISTS ImqString dynamicqueuename( ) const ; dynamic queue name ImqBoolean setdynamicqueuename( const char * name ); dynamic queue name dynamic queue name ImqObject open status FALSE TRUE ImqBoolean get( ImqMessage & msg ); ImqObject open options MQOO_INPUT_* ImqObject openfor msg clearmessage TRUE MQGET MQRC_TRUNCATED_MSG_FAILED ImqObject reason code ImqCache message length ImqBoolean get( ImqMessage & msgimqgetmessageoptions & options ); ImqGetMessageOptions options ImqObject open options MQOO_INPUT_* MQOO_BROWSE ImqObject openfor msg clearmessage TRUE MQGET MQRC_TRUNCATED_MSG_FAILED ImqObject reason code ImqCache message length 178

201 5.MQC C++ ImqQueue C++ ImqBoolean get( ImqMessage & msg, ImqGetMessageOptions & options, const size_t buffer-size ); buffer size ImqBoolean get( ImqMessage & msg ); ImqBoolean get( ImqMessage & msgimqgetmessageoptions & options ); msg ImqCache automatic buffer msg resizebuffer MQGET ImqBoolean get( ImqMessage & msg, const size_t buffer-size ); ImqBoolean get( ImqMessage & msg, ImqGetMessageOptions & options, const size_t buffer-size ); MQGET ImqBoolean hardengetbackout( MQLONG & harden ); harden get backout TRUE MQINQ MQIA_HARDEN_GET_BACKOUT MQLONG hardengetbackout( ); harden get backout MQINQ MQIA_HARDEN_GET_BACKOUT ImqBoolean inhibitget( MQLONG & inhibit ); inhibit get TRUE MQINQ MQIA_INHIBIT_GET MQLONG inhibitget( ); inhibit get MQINQ MQIA_INHIBIT_GET ImqBoolean setinhibitget( const MQLONG inhibit ); inhibit get TRUE MQSET MQIA_INHIBIT_GET 179

202 5.MQC C++ ImqQueue C++ ImqBoolean inhibitput( MQLONG & inhibit ); inhibit put TRUE MQINQ MQIA_INHIBIT_PUT MQLONG inhibitput( ); inhibit put MQINQ MQIA_INHIBIT_PUT ImqBoolean setinhibitput( const MQLONG inhibit ); inhibit put TRUE MQSET MQIA_INHIBIT_PUT ImqBoolean initiationqueuename( ImqString & name ); initiation queue name TRUE MQINQ MQCA_INITIATION_Q_NAME ImqString initiationqueuename( ); initiation queue name MQINQ MQCA_INITIATION_Q_NAME ImqBoolean maximumdepth( MQLONG & depth ); maximum depth TRUE MQINQ MQIA_MAX_Q_DEPTH MQLONG maximumdepth( ); maximum depth MQINQ MQIA_MAX_Q_DEPTH ImqBoolean maximummessagelength( MQLONG & length ); maximum message length TRUE MQINQ MQIA_MAX_MSG_LENGTH MQLONG maximummessagelength( ); maximum message length 180

203 5.MQC C++ ImqQueue C++ MQINQ MQIA_MAX_MSG_LENGTH ImqBoolean messagedeliverysequence( MQLONG & sequence ); message delivery sequence TRUE MQINQ MQIA_MSG_DELIVERY_SEQUENCE MQLONG messagedeliverysequence( ); message delivery sequence MQINQ MQIA_MSG_DELIVERY_SEQUENCE ImqQueue * nextdistributedqueue() const ; next distributed queue ImqBoolean openinputcount( MQLONG & count ); open input count TRUE MQINQ MQIA_OPEN_INPUT_COUNT MQLONG openinputcount( ); open input count MQINQ MQIA_OPEN_INPUT_COUNT ImqBoolean openoutputcount( MQLONG & count ); open output count TRUE MQINQ MQIA_OPEN_OUTPUT_COUNT MQLONG openoutputcount( ); open output count MQINQ MQIA_OPEN_OUTPUT_COUNT ImqQueue * previousdistributedqueue() const ; previous distributed queue ImqBoolean processname( ImqString & name ); process name TRUE MQINQ MQCA_PROCESS_NAME 181

204 5.MQC C++ ImqQueue C++ ImqString processname( ); process name MQINQ MQCA_PROCESS_NAME ImqBoolean put( ImqMessage & msg ); ImqObject open options MQOO_OUTPUT ImqObject openfor TRUE MQPUT ImqBoolean put( ImqMessage & msgimqputmessageoptions & pmo ); pmo MQOO_*_CONTEXT ImqObject openfor ImqObject open options MQOO_OUTPUT pmo options MQPMO_PASS_IDENTITY_CONTEXT MQPMO_PASS_ALL_CONTEXTMQPMO_SET_IDENTITY_CONTEXT MQPMO_SET_ALL_CONTEXT TRUE MQPUT pmo context reference ImqString queuemanagername( ) const ; queue manager name ImqBoolean setqueuemanagername( const char * name ); queue manager name queue manager name ImqObject open status FALSE TRUE ImqBoolean queuetype( MQLONG & type ); queue type TRUE MQINQ MQIA_Q_TYPE 182

205 5.MQC C++ ImqQueue C++ MQLONG queuetype( ); queue type MQINQ MQIA_Q_TYPE ImqBoolean remotequeuemanagername( ImqString & name ); remote queue manager name TRUE MQINQ MQCA_REMOTE_Q_MGR_NAME ImqString remotequeuemanagername( ); remote queue manager name MQINQ MQCA_REMOTE_Q_MGR_NAME ImqBoolean remotequeuename( ImqString & name ); remote queue name TRUE MQINQ MQCA_REMOTE_Q_NAME ImqString remotequeuename( ); remote queue name MQINQ MQCA_REMOTE_Q_NAME ImqBoolean resolvedqueuemanagername( ImqString & name ); resolved queue manager name TRUE ImqString resolvedqueuemanagername() const ; resolved queue name ImqBoolean resolvedqueuename( ImqString & name ); resolved queue name TRUE ImqString resolvedqueuename() const ; resolved queue name ImqBoolean scope( MQLONG & scope ); scope TRUE 183

206 5.MQC C++ ImqQueue C++ MQINQ MQIA_SCOPE MQLONG scope( ); scope MQINQ MQIA_SCOPE ImqBoolean shareability( MQLONG & shareability ); shareability TRUE MQINQ MQIA_SHAREABILITY MQLONG shareability( ); shareability MQINQ MQIA_SHAREABILITY ImqBoolean transmissionqueuename( ImqString & name ); transmission queue name TRUE MQINQ MQCA_XMIT_Q_NAME ImqString transmissionqueuename( ); transmission queue name MQINQ MQCA_XMIT_Q_NAME ImqBoolean triggercontrol( MQLONG & control ); trigger control TRUE MQINQ MQIA_TRIGGER_CONTROL MQLONG triggercontrol( ); trigger control MQINQ MQIA_TRIGGER_CONTROL ImqBoolean settriggercontrol( const MQLONG control ); trigger control TRUE MQSET MQIA_TRIGGER_CONTROL 184

207 5.MQC C++ ImqQueue C++ ImqBoolean triggerdata( ImqString & data ); trigger data TRUE MQINQ MQCA_TRIGGER_DATA ImqString triggerdata( ); trigger data MQINQ MQCA_TRIGGER_DATA ImqBoolean settriggerdata( const char * data ); trigger data TRUE MQSET MQCA_TRIGGER_DATA ImqBoolean triggerdepth( MQLONG & depth ); trigger depth TRUE MQINQ MQIA_TRIGGER_DEPTH MQLONG triggerdepth( ); trigger depth MQINQ MQIA_TRIGGER_DEPTH ImqBoolean settriggerdepth( const MQLONG depth ); trigger depth TRUE MQSET MQIA_TRIGGER_DEPTH ImqBoolean triggermessagepriority( MQLONG & priority ); trigger message priority TRUE MQINQ MQIA_TRIGGER_MSG_PRIORITY MQLONG triggermessagepriority( ); trigger message priority MQINQ MQIA_TRIGGER_MSG_PRIORITY ImqBoolean settriggermessagepriority( const MQLONG priority ); trigger message priority TRUE 185

208 5.MQC C++ ImqQueue C++ MQSET MQIA_TRIGGER_MSG_PRIORITY ImqBoolean triggertype( MQLONG & type ); trigger type TRUE MQINQ MQIA_TRIGGER_TYPE MQLONG triggertype( ); trigger type MQINQ MQIA_TRIGGER_TYPE ImqBoolean settriggertype( const MQLONG type ); trigger type TRUE MQSET MQIA_TRIGGER_TYPE ImqBoolean usage( MQLONG & usage ); usage TRUE MQINQ MQIA_USAGE MQLONG usage( ); usage MQINQ MQIA_USAGE protected void setnextdistributedqueue( ImqQueue * queue = 0 ); next distributed queue void setpreviousdistributedqueue( ImqQueue * queue = 0 ); previous distributed queue ImqCache ImqDistributionList ImqGetMessageOptions ImqMessage ImqMessageTracker 186

209 5.MQC C++ ImqQueue C++ ImqObject ImqPutMessageOptions ImqQueueManager ImqString MQRC_CONTEXT_OBJECT_NOT_VALID MQRC_CONTEXT_OPEN_ERROR MQRC_CURSOR_NOT_VALID MQRC_NO_BUFFER MQRC_REOPEN_EXCL_INPUT_ERROR MQRC_REOPEN_INQUIRE_ERROR MQRC_REOPEN_SAVED_CONTEXT_ERR MQRC_REOPEN_TEMPORARY_Q_ERROR MQGET MQPUT ATP1/ Message Queue 187

210 5.MQC C++ ImqQueueManager C++ ImqQueueManager C++ MQOT_Q_MGR imqmgr.hpp authority event begin options begin MQBO_NONE MQBO Options character set command input queue name command level connect options connect MQCNO_NONE connection status TRUE FALSE TRUE dead-letter queue name default transmission queue name 188

211 5.MQC C++ ImqQueueManager C++ distribution lists first managed object ImqObject connection reference 0 inhibit event local event maximum handles maximum message length maximum priority maximum uncommitted messages performance event platform remote event repository name start-stop event 189

212 5.MQC C++ ImqQueueManager C++ sync-point availability trigger interval ImqQueueManager( ); ImqQueueManager( const ImqQueueManager & manager ); connection status FALSE ImqQueueManager( const char * name ); ImqObject name name ImqQueueManager void operator = ( const ImqQueueManager & mgr ); mgr connection status FALSE ImqBoolean backout( ); TRUE MQBACK ImqBoolean begin( ); begin options TRUE MQBEGIN MQLONG beginoptions( ) const ; begin options 190

213 5.MQC C++ ImqQueueManager C++ void setbeginoptions( const MQLONG options = MQBO_NONE ); begin options ImqBoolean characterset( MQLONG & ccsid ); character set TRUE MQINQ MQIA_CODED_CHAR_SET_ID MQLONG characterset( ); character set MQINQ MQIA_CODED_CHAR_SET_ID ImqBoolean commit( ); TRUE MQCMIT ImqBoolean connect( ); ImqObject name ImqObject setname connect options connection status TRUE TRUE MQCONN ImqQueueManager ImqBoolean connectionstatus( ) const ; connection status ImqBoolean deadletterqueuename( ImqString & name ); dead-letter queue name TRUE MQINQ MQCA_DEAD_LETTER_Q_NAME ImqString deadletterqueuename( ); dead-letter queue name 191

214 5.MQC C++ ImqQueueManager C++ MQINQ MQCA_DEAD_LETTER_Q_NAME ImqBoolean defaulttransmissionqueuename( ImqString & name ); default transmission queue name TRUE MQINQ MQCA_DEF_XMIT_Q_NAME ImqString defaulttransmissionqueuename( ); default transmission queue name MQINQ MQCA_DEF_XMIT_Q_NAME ImqBoolean disconnect( ); connection status FALSE ImqProcess ImqQueue connection reference ImqQueueManager TRUE MQDISC ImqBoolean distributionlists( MQLONG & support ); distribution lists TRUE MQINQ MQIA_DIST_LISTS MQLONG distributionlists(); distribution lists MQINQ MQIA_DIST_LISTS ImqObject * firstmanagedobject( ) const ; first managed object ImqBoolean maximumhandles( MQLONG & number ); maximum handles TRUE MQINQ MQIA_MAX_HANDLES 192

215 5.MQC C++ ImqQueueManager C++ MQLONG maximumhandles( ); maximum handles MQINQ MQIA_MAX_HANDLES ImqBoolean maximummessagelength( MQLONG & length ); maximum message length TRUE MQINQ MQIA_MAX_MSG_LENGTH MQLONG maximummessagelength( ); maximum message length MQINQ MQIA_MAX_MSG_LENGTH ImqBoolean maximumpriority( MQLONG & priority ); maximum priority TRUE MQINQ MQIA_MAX_PRIORITY MQLONG maximumpriority( ); maximum priority MQINQ MQIA_MAX_PRIORITY ImqBoolean maximumuncommittedmessages( MQLONG & number ); maximum uncommitted messages TRUE MQINQ MQIA_MAX_UNCOMMITTED_MSGS MQLONG maximumuncommittedmessages( ); maximum uncommitted messages MQINQ MQIA_MAX_UNCOMMITTED_MSGS ImqBoolean platform( MQLONG & platform ); platform TRUE MQINQ MQIA_PLATFORM MQLONG platform( ); platform 193

216 5.MQC C++ ImqQueueManager C++ MQINQ MQIA_PLATFORM ImqBoolean repositoryname( ImqString & name ); repository name TRUE MQINQ MQCA_REPOSITORY_NAME ImqString repositoryname(); repository name MQINQ MQCA_REPOSITORY_NAME ImqBoolean syncpointavailability( MQLONG & sync ); sync-point availability TRUE MQINQ MQIA_SYNCPOINT MQLONG syncpointavailability(); sync-point availability MQINQ MQIA_SYNCPOINT ImqBoolean triggerinterval( MQLONG & interval ); trigger interval TRUE MQINQ MQIA_TRIGGER_INTERVAL MQLONG triggerinterval( ); trigger interval MQINQ MQIA_TRIGGER_INTERVAL protected void setfirstmanagedobject( const ImqObject * object = 0 ); first managed object protected MQHCONN ohconn TP1/Message Queue - Access connection status TRUE 194

217 5.MQC C++ ImqQueueManager C++ ImqObject MQBACK MQBEGIN MQCMIT MQDISC ATP1/ Message Queue 195

218 5.MQC C++ ImqReferenceHeader C++ ImqReferenceHeader C++ MQRMH imqrfh.hpp destination environment destination name instance id MQ_OBJECT_INSTANCE_ID_LENGTH 2 MQBYTE24 MQOII_NONE MQRMH ObjectInstanceId logical length 0 MQRMH DataLogicalLength logical offset 0 MQRMH DataLogicalOffset logical offset2 logical offset 0 MQRMH DataLogicalOffset2 reference type MQRMH ObjectType 196

219 5.MQC C++ ImqReferenceHeader C++ source environment source name ImqReferenceHeader(); ImqReferenceHeader( const ImqReferenceHeader & header ); virtual ImqBoolean copyout( ImqMessage & msg ); ImqItem MQRMH msg format MQFMT_REF_MSG_HEADER ImqHeader C++ virtual ImqBoolean pastein( ImqMessage & msg ); ImqItem MQRMH ImqMessage format MQFMT_REF_MSG_HEADER ImqHeader C++ void operator = ( const ImqReferenceHeader & header ); ImqString destinationenvironment() const; destination environment void setdestinationenvironment( const char * environment = 0 ); destination environment 197

220 5.MQC C++ ImqReferenceHeader C++ ImqString destinationname() const ; destination name void setdestinationname( const char * name = 0 ); destination name ImqBinary instanceid() const ; instance id ImqBoolean setinstanceid( const ImqBinary & id ); instance id token data length 0 MQ_OBJECT_INSTANCE_ID_LENGTH TRUE void setinstanceid( const MQBYTE24 id = 0 ); instance id id 0 MQOII_NONE id 0 MQ_OBJECT_INSTANCE_ID_LENGTH 2 MQOII_NONE (MQBYTE *)MQOII_NONE MQLONG logicallength() const ; logical length void setlogicallength( const MQLONG length ); logical length MQLONG logicaloffset() const ; logical offset void setlogicaloffset( const MQLONG offset ); logical offset MQLONG logicaloffset2() const; logical offset2 void setlogicaloffset2( const MQLONG offset ); logical offset2 198

221 5.MQC C++ ImqReferenceHeader C++ ImqString referencetype() const ; reference type void setreferencetype( const char * name = 0 ); reference type ImqString sourceenvironment() const ; source environment void setsourceenvironment( const char * environment = 0 ); source environment ImqString sourcename() const ; source name void setsourcename( const char * name = 0 ); source name protected MQRMH omqrmh MQRMH ImqBinary ImqHeader ImqItem ImqMessage ImqString 199

222 5.MQC C++ ImqString C++ ImqString C++ char* char* ImqString imqstr.hpp characters storage length characters storage length 0 0 storage characters characters storage storage ImqString( ); ImqString( const ImqString & string); ImqString( const char c ); characters c ImqString( const char * text ); characters text ImqString( const void * bufferconst size_t length ); buffer length characters. 200

223 5.MQC C++ ImqString C++ static ImqBoolean copy( char * destination-bufferconst size_t lengthconst char* source-bufferconst char pad = 0 ); length source-buffer destination-buffer source-buffer destination-buffer pad source-buffer 0 length 0 destination-buffer TRUE virtual ImqBoolean copyout( ImqMessage & msg ); ImqItem characters msgformat MQFMT_STRING virtual ImqBoolean pastein( ImqMessage & msg ); ImqItem characters characters msg encoding MQENC_NATIVE MQGMO_CONVERT MQENC_NATIVE ImqMessage format MQFMT_STRING char & operator [ ] ( const size_t offset ) const ; storage offset ImqString operator ( ) ( const size_t offsetconst size_t length = 1 ) const ; offset characters length 0 characters offset length characters ImqString void operator = ( const ImqString & string ); string 201

224 5.MQC C++ ImqString C++ ImqString operator + ( const char c ) const ; c characters ImqString operator + ( const char * text ) const ; text characters strone + "string two" ; "string one" + strtwo; ImqString operator + ( const ImqString & string1 ) const ; string1 characters ImqString operator + ( const double number ) const ; number characters ImqString operator + ( const long number ) const ; number characters void operator += ( const char c ); c characters void operator += ( const char * text ); text characters void operator += ( const ImqString & string ); string characters void operator += ( const double number ); number characters void operator += ( const long number ); number characters void operator char * ( ) const ; storage 0 202

225 5.MQC C++ ImqString C++ ImqBoolean operator < ( const ImqString & string ) const ; ImqBoolean operator > ( const ImqString & string ) const ; ImqBoolean operator <= ( const ImqString & string ) const ; ImqBoolean operator >= ( const ImqString & string ) const ; ImqBoolean operator == ( const ImqString & string ) const ; ImqBoolean operator!= ( const ImqString & string ) const ; compare characters string TRUE FALSE short compare( const ImqString & string ) const ; characters string characters 0 ImqString ImqString ImqBoolean copyout( char * bufferconst size_t lengthconst char pad = 0 ); length characters buffer buffer characters buffer pad length 0 buffer 0 TRUE size_t copyout( long & number ) const ; characters number 0 number <blank(s)> <+ -> digit(s) size_t copyout( ImqString & tokenconst char c = ' ' ) const ; characters c token token c 0 token 203

226 5.MQC C++ ImqString C++ size_t cutout( long & number ); copy number characters cutout( number ) 3 strnumbers = " "; while ( strnumbers.cutout( number ) ); number becomes -1, then 0, then 55 leaving strnumbers == " " size_t cutout( ImqString & token, const char c = ' ' ); copyout token characters strtoken token c c token c cutout( token ) 3 token token strtext = "Program Version 1.1"; while ( strtext.cutout( token ) ); // token becomes "Program", then "Version", // then "1.1" leaving strtext == "" DOS strpath = "C: WINNT WINNT.BMP" strpath.cutout( strdrive, ':' ); strpath.stripleading( ':' ); while ( strpath.cutout( strfile, ' ' ) ); // strdrive becomes "C". // strfile becomes "WINNT", // then "WINNT.BMP" leaving strpath empty. ImqBoolean find( const ImqString & string ); characters string FALSE TRUE string TRUE ImqBoolean find( const ImqString & stringsize_t & offset ); offset characters string 204

227 5.MQC C++ ImqString C++ string offset TRUE FALSE offset TRUE offset characters string size_t length( ) const ; length ImqBoolean pastein( const double numberconst char * format = "%f" ); number characters TRUE format printf"%.3f" ImqBoolean pastein( const long number ); number characters TRUE ImqBoolean pastein( const void * bufferconst size_t length ); buffer characters length. TRUE ImqBoolean set( const char * bufferconst size_t length ); characters TRUE size_t storage( ) const ; storage ImqBoolean setstorage( const size_t length ); storage characters TRUE 205

228 5.MQC C++ ImqString C++ size_t stripleading( const char c = ' ' ); characters c size_t striptrailing( const char c = ' ' ); characters c ImqString uppercase( ) const ; characters protected ImqBoolean assign( const ImqString & string ); operator= TRUE ImqItem ImqMessage strone + "string two" Visual C++ strone + (char *)"string two" MQRC_DATA_TRUNCATED MQRC_NULL_POINTER MQRC_STORAGE_NOT_AVAILABLE ATP1/ Message Queue 206

229 5.MQC C++ ImqTrigger C++ ImqTrigger C++ MQTM TP1/Message Queue - Access imqtrg.hpp application id ID MQTM ApplId application type 0 MQTM ApplType environment data MQTM EnvData process name MQTM ProcessName queue name MQTM QName trigger data MQTM TriggerData 207

230 5.MQC C++ ImqTrigger C++ user data MQTM UserData ImqTrigger( ); ImqTrigger( const ImqTrigger & trigger ); virtual ImqBoolean copyout( ImqMessage & msg ); ImqItem MQTM msg format MQFMT_TRIGGER ImqItem C++ virtual ImqBoolean pastein( ImqMessage & msg ); ImqItem MQTM ImqMessage format MQFMT_TRIGGER ImqItem C++ void operator =( const ImqTrigger & trigger ); trigger ImqString applicationid( ) const ; application id void setapplicationid( const char * id ); application id MQLONG applicationtype( ) const ; application type 208

231 5.MQC C++ ImqTrigger C++ void setapplicationtype( const MQLONG type ); application type ImqBoolean copyout( MQTMC2 * ptmc2 ); MQTM MQTMC2 QMgrName QMgrName MQTM MQTMC2 TRUE ImqString environmentdata( ) const ; environment data void setenvironmentdata( const char * data ); environment data ImqString processname( ) const ; process name void setprocessname( const char * name ); process name ImqString queuename( ) const ; queue name void setqueuename( const char * name ); queue name ImqString triggerdata( ) const ; trigger data void settriggerdata( const char * data ); trigger data ImqString userdata( ) const ; user data 209

232 5.MQC C++ ImqTrigger C++ void setuserdata( const char * data ); user data protected MQTM omqtm MQTM ImqGetMessageOptions ImqItem ImqMessage ImqString MQRC_NULL_POINTER A 210

233 5.MQC C++ C++ C++ C++ 5-2C++ 211

234 5.MQC C++ C++ C++ #include <stdio.h> #include <imqi.hpp> // include MQAccess C++ class int main (void) { ImqQueueManager mgr(" "); /* queue manager name */ ImqQueue queue; /* queue */ ImqMessage msg; /* message */ ImqString str("****** C++ sample put data ******"); /* message data */ ImqGetMessageOptions getoption; /* get message options */ ImqPutMessageOptions putoption; /* put message options */ // connect to the queue manager if (! mgr.connect( ) ) { /* stop if it failed */ printf( "ImqQueueManager::connect ended with reason code %d n", (int)mgr.reasoncode( ) ); return ( (int)mgr.reasoncode( ) ); } // set the connection reference queue.setconnectionreference( mgr ); // set the queue name queue.setname("dynq1"); // set the message msg.writeitem( str ); // set the open options queue.setopenoptions(mqoo_output MQOO_INPUT_AS_Q_DEF); // open the queue queue.open( ); if ( queue.reasoncode( ) ) { printf( "ImqQueue::open ended with reason code %d n", (int)queue.reasoncode( ) ); return( (int)queue.reasoncode( ) ); } // set the get message options getoption.setsyncpointparticipation(true); // set the put message options putoption.setsyncpointparticipation(true); // begin local transaction if (! mgr.begin( ) ) { printf( "ImqQueueManager::begin ended with reason code %d n", (int)mgr.reasoncode( ) ); 212

235 5.MQC C++ C++ } return( (int)mgr.reasoncode( ) ); // put the message if (! queue.put( msg, putoption ) ) { printf( "ImqQueue::put ended with reason code %d n", (int)queue.reasoncode( ) ); } // commit local transaction if ( queue.reasoncode( ) == 0 ) { if (! mgr.commit( ) ) { printf( "ImqQueueManager::commit ended with reason code %d n", (int)mgr.reasoncode( ) ); return( (int)mgr.reasoncode( ) ); } } else { if (! mgr.backout( ) ) { printf( "ImqQueueManager::backout ended with reason code %d n", (int)mgr.reasoncode( ) ); return( (int)mgr.reasoncode( ) ); } } // begin local transaction if (! mgr.begin( ) ) { printf( "ImqQueueManager::begin ended with reason code %d n", (int)mgr.reasoncode( ) ); return( (int)mgr.reasoncode( ) ); } // get the message if (! queue.get( msg, getoption ) ) { printf( "ImqQueue::get ended with reason code %d n", (int)queue.reasoncode( ) ); } // commit local transaction if ( queue.reasoncode( ) == 0 ) { if (! mgr.commit( ) ) { printf( "ImqQueueManager::commit ended with reason code %d n", (int)mgr.reasoncode( ) ); return( (int)mgr.reasoncode( ) ); } } else { if (! mgr.backout( ) ) { printf( "ImqQueueManager::backout ended with reason code %d n", (int)mgr.reasoncode( ) ); return( (int)mgr.reasoncode( ) ); } } // close the queue 213

236 5.MQC C++ C++ if (! queue.close( ) ) { printf( "ImqQueue::close ended with reason code %d n", (int)queue.reasoncode( ) ); } // disconnect from the queue manager if (! mgr.disconnect( ) ) { printf( "ImqQueueManager::disconnect ended with reason code %d n", (int)mgr.reasoncode( ) ); } return (0); } 214

237 6 MQC Java MQC Java MQC Java MQC Java Java MQDistributionList Java MQDistributionListItem Java MQEnvironment Java MQException Java MQGetMessageOptions Java MQManagedObject Java MQMessage Java MQMessageTracker Java MQProcess Java MQPutMessageOptions Java MQQueue Java MQQueueManager Java MQC Java 215

238 6.MQC Java Java Java 216

239 6.MQC Java MQC Java MQC Java MQC Java XA JP.co.Hitachi.soft.MQ.Access XA 217

240 6.MQC Java MQC Java MQC Java MQC 6-1Java MQDistributionList MQDistributionListItem MQEnvironment MQException MQGetMessageOptions MQManagedObject MQMessage MQMessageTracker MQProcess MQPutMessageOptions MQQueue MQQueueManager Java MQ MQQueue:get MQQueueManagerMQQueueMQProcess MQ MQ MQQueue:put MQ MQ 6-2Java MQC TP1/Message Queue 218

241 6.MQC Java Java Java 6-1Java 219

242 6.MQC Java MQDistributionList Java MQDistributionList Java public MQDistributionList(MQQueueManager qmgr, MQDistributionListItem[] litems, Int openoptions, String alternateuserid) throws MQException MQDistributionList put() qmgr litems openoptions alternateuserid public synchronized void put(mqmessage message, MQPutMessageOptions putmessageoptions) throws MQException MQPUT message putmessageoptions MQPUT public MQDistributionListItem getfirstdistributionlistitem() null 220

243 6.MQC Java MQDistributionList Java public int getvaliddestinationcount() MQPUT MQPMO KnownDestCount UnknownDestCount public int getinvaliddestinationcount() MQPUT MQPMO InvalidDestCount 221

244 6.MQC Java MQDistributionListItem Java MQDistributionListItem Java public int completioncode public String queuename public String queuemanagername public int reasoncode public MQDistributionListItem() MQDistributionListItem 222

245 6.MQC Java MQEnvironment Java MQEnvironment Java Java public final static String version_notice MQC Java public static void disabletracing() public static void enabletracing(int level) JavaEnvironment JavaEnvironment Java System.err2.4.2 JavaEnvironment level JavaEnvironment JavaEnvironment MQ MQGMO MQPMO 223

246 6.MQC Java MQEnvironment Java public static void enabletracing(int level, OutputStream stream) level 1 5 enabletracing stream public MQEnvironment() MQEnvironment 224

247 6.MQC Java MQException Java MQException Java MQ public static java.io.outputstreamwriter log System.err null public Object exceptionsource public int completioncode TP1/Message Queue public int reasoncode TP1/Message Queue TP1/ Message Queue public static final int MQCC_WARNING public static final int MQCC_FAILED public static final int MQRC_ADAPTER_STORAGE_SHORTAGE public static final int MQRC_ADAPTER_CONN_LOAD_ERROR public static final int MQRC_ADAPTER_SERV_LOAD_ERROR public static final int MQRC_ADAPTER_DEFS_ERROR public static final int MQRC_ADAPTER_DEFS_LOAD_ERROR public static final int MQRC_ADAPTER_CONV_LOAD_ERROR public static final int MQRC_ADAPTER_DISC_LOAD_ERROR public static final int MQRC_ADAPTER_NOT_AVAILABLE public static final int MQRC_ALIAS_BASE_Q_TYPE_ERROR public static final int MQRC_ALREADY_CONNECTED public static final int MQRC_ANOTHER_Q_MGR_CONNECTED public static final int MQRC_API_EXIT_LOAD_ERROR public static final int MQRC_ASID_MISMATCH public static final int MQRC_BACKED_OUT 225

248 6.MQC Java MQException Java public static final int MQRC_BO_ERROR public static final int MQRC_BRIDGE_STARTED public static final int MQRC_BRIDGE_STOPPED public static final int MQRC_BUFFER_ERROR public static final int MQRC_BUFFER_LENGTH_ERROR public static final int MQRC_CALL_IN_PROGRESS public static final int MQRC_CFH_ERROR public static final int MQRC_CFIL_ERROR public static final int MQRC_CFIN_ERROR public static final int MQRC_CFSL_ERROR public static final int MQRC_CFST_ERROR public static final int MQRC_CHANNEL_AUTO_DEF_ERROR public static final int MQRC_CHANNEL_AUTO_DEF_OK public static final int MQRC_CHANNEL_ACTIVATED public static final int MQRC_CHANNEL_NOT_ACTIVATED public static final int MQRC_CHANNEL_STARTED public static final int MQRC_CHANNEL_STOPPED public static final int MQRC_CHANNEL_CONV_ERROR public static final int MQRC_CICS_WAIT_FAILED public static final int MQRC_CONNECTION_QUIESCING public static final int MQRC_CONNECTION_STOPPING public static final int MQRC_CONNECTION_NOT_AUTHORIZED public static final int MQRC_CORREL_ID_ERROR public static final int MQRC_CHAR_ATTR_LENGTH_ERROR public static final int MQRC_CHAR_ATTRS_ERROR public static final int MQRC_CHAR_ATTRS_TOO_SHORT public static final int MQRC_CLUSTER_PUT_INHIBITED public static final int MQRC_CLUSTER_RESOLUTION_ERROR public static final int MQRC_CONTEXT_HANDLE_ERROR public static final int MQRC_CONTEXT_NOT_AVAILABLE public static final int MQRC_COD_NOT_VALID_FOR_XCF_Q public static final int MQRC_CONVERTED_MSG_TOO_BIG public static final int MQRC_CNO_ERROR public static final int MQRC_CONN_ID_IN_USE public static final int MQRC_CONNECTION_BROKEN public static final int MQRC_DATA_LENGTH_ERROR public static final int MQRC_DBCS_ERROR public static final int MQRC_DEF_XMIT_Q_TYPE_ERROR public static final int MQRC_DEF_XMIT_Q_USAGE_ERROR public static final int MQRC_DEST_ENV_ERROR 226

249 6.MQC Java MQException Java public static final int MQRC_DEST_NAME_ERROR public static final int MQRC_DH_ERROR public static final int MQRC_DLH_ERROR public static final int MQRC_DUPLICATE_RECOV_COORD public static final int MQRC_DYNAMIC_Q_NAME_ERROR public static final int MQRC_ENVIRONMENT_ERROR public static final int MQRC_EXPIRY_ERROR public static final int MQRC_FEEDBACK_ERROR public static final int MQRC_FILE_SYSTEM_ERROR public static final int MQRC_FORMAT_ERROR public static final int MQRC_FUNCTION_ERROR public static final int MQRC_GET_INHIBITED public static final int MQRC_GMO_ERROR public static final int MQRC_GROUP_ID_ERROR public static final int MQRC_HANDLE_NOT_AVAILABLE public static final int MQRC_HCONFIG_ERROR public static final int MQRC_HCONN_ERROR public static final int MQRC_HEADER_ERROR public static final int MQRC_HOBJ_ERROR public static final int MQRC_INHIBIT_VALUE_ERROR public static final int MQRC_IIH_ERROR public static final int MQRC_INCOMPLETE_GROUP public static final int MQRC_INCOMPLETE_MSG public static final int MQRC_INCONSISTENT_BROWSE public static final int MQRC_INCONSISTENT_CCSID public static final int MQRC_INCONSISTENT_ENCODINGS public static final int MQRC_INCONSISTENT_PERSISTENCE public static final int MQRC_INCONSISTENT_UOW public static final int MQRC_INITIALIZATION_FAILED public static final int MQRC_INVALID_MSG_UNDER_CURSOR public static final int MQRC_INT_ATTR_COUNT_ERROR public static final int MQRC_INT_ATTR_COUNT_TOO_SMALL public static final int MQRC_INT_ATTRS_ARRAY_ERROR public static final int MQRC_MATCH_OPTIONS_ERROR public static final int MQRC_MAX_CONNS_LIMIT_REACHED public static final int MQRC_MD_ERROR public static final int MQRC_MDE_ERROR public static final int MQRC_MISSING_REPLY_TO_Q public static final int MQRC_MSG_ID_ERROR public static final int MQRC_MSG_FLAGS_ERROR 227

250 6.MQC Java MQException Java public static final int MQRC_MSG_SEQ_NUMBER_ERROR public static final int MQRC_MSG_TOO_BIG_FOR_CHANNEL public static final int MQRC_MSG_TOO_BIG_FOR_Q public static final int MQRC_MSG_TOO_BIG_FOR_Q_MGR public static final int MQRC_MSG_TYPE_ERROR public static final int MQRC_MULTIPLE_REASONS public static final int MQRC_NAME_IN_USE public static final int MQRC_NAME_NOT_VALID_FOR_TYPE public static final int MQRC_NOT_CONVERTED public static final int MQRC_NO_MSG_LOCKED public static final int MQRC_NO_DESTINATIONS_AVAILABLE public static final int MQRC_NO_EXTERNAL_PARTICIPANTS public static final int MQRC_NO_MSG_AVAILABLE public static final int MQRC_NO_MSG_UNDER_CURSOR public static final int MQRC_NOT_AUTHORIZED public static final int MQRC_NOT_OPEN_FOR_BROWSE public static final int MQRC_NOT_OPEN_FOR_INPUT public static final int MQRC_NOT_OPEN_FOR_INQUIRE public static final int MQRC_NOT_OPEN_FOR_OUTPUT public static final int MQRC_NOT_OPEN_FOR_SET public static final int MQRC_NOT_OPEN_FOR_PASS_ALL public static final int MQRC_NOT_OPEN_FOR_PASS_IDENT public static final int MQRC_NOT_OPEN_FOR_SET_ALL public static final int MQRC_NOT_OPEN_FOR_SET_IDENT public static final int MQRC_OBJECT_ALREADY_EXISTS public static final int MQRC_OBJECT_CHANGED public static final int MQRC_OBJECT_DAMAGED public static final int MQRC_OBJECT_IN_USE public static final int MQRC_OBJECT_NAME_ERROR public static final int MQRC_OBJECT_Q_MGR_NAME_ERROR public static final int MQRC_OBJECT_RECORDS_ERROR public static final int MQRC_OBJECT_TYPE_ERROR public static final int MQRC_OD_ERROR public static final int MQRC_OFFSET_ERROR public static final int MQRC_OPEN_FAILED public static final int MQRC_OPTION_NOT_VALID_FOR_TYPE public static final int MQRC_OPTIONS_ERROR public static final int MQRC_ORIGINAL_LENGTH_ERROR public static final int MQRC_OUTCOME_MIXED public static final int MQRC_OUTCOME_PENDING 228

251 6.MQC Java MQException Java public static final int MQRC_PARTICIPANT_NOT_AVAILABLE public static final int MQRC_PAGESET_FULL public static final int MQRC_PAGESET_ERROR public static final int MQRC_PCF_ERROR public static final int MQRC_PERSISTENCE_ERROR public static final int MQRC_PERSISTENT_NOT_ALLOWED public static final int MQRC_PMO_ERROR public static final int MQRC_PMO_RECORD_FLAGS_ERROR public static final int MQRC_PRIORITY_EXCEEDS_MAXIMUM public static final int MQRC_PRIORITY_ERROR public static final int MQRC_PUT_INHIBITED public static final int MQRC_PUT_MSG_RECORDS_ERROR public static final int MQRC_Q_ALREADY_EXISTS public static final int MQRC_Q_DEPTH_HIGH public static final int MQRC_Q_DEPTH_LOW public static final int MQRC_Q_DELETED public static final int MQRC_Q_FULL public static final int MQRC_Q_MGR_ACTIVE public static final int MQRC_Q_MGR_NAME_ERROR public static final int MQRC_Q_MGR_NOT_AVAILABLE public static final int MQRC_Q_MGR_NOT_ACTIVE public static final int MQRC_Q_MGR_QUIESCING public static final int MQRC_Q_SERVICE_INTERVAL_HIGH public static final int MQRC_Q_SERVICE_INTERVAL_OK public static final int MQRC_Q_MGR_STOPPING public static final int MQRC_Q_NOT_EMPTY public static final int MQRC_Q_SPACE_NOT_AVAILABLE public static final int MQRC_Q_TYPE_ERROR public static final int MQRC_RECS_PRESENT_ERROR public static final int MQRC_REPORT_OPTIONS_ERROR public static final int MQRC_RESOURCE_PROBLEM public static final int MQRC_RESPONSE_RECORDS_ERROR public static final int MQRC_REMOTE_Q_NAME_ERROR public static final int MQRC_RMH_ERROR public static final int MQRC_SECOND_MARK_NOT_ALLOWED public static final int MQRC_SECURITY_ERROR public static final int MQRC_SEGMENT_LENGTH_ZERO public static final int MQRC_SELECTOR_COUNT_ERROR public static final int MQRC_SELECTOR_LIMIT_EXCEEDED public static final int MQRC_SELECTOR_ERROR 229

252 6.MQC Java MQException Java public static final int MQRC_SELECTOR_NOT_FOR_TYPE public static final int MQRC_SERVICE_ERROR public static final int MQRC_SERVICE_NOT_AVAILABLE public static final int MQRC_SIGNAL_OUTSTANDING public static final int MQRC_SIGNAL_REQUEST_ACCEPTED public static final int MQRC_SIGNAL1_ERROR public static final int MQRC_SOURCE_BUFFER_ERROR public static final int MQRC_SOURCE_CCSID_ERROR public static final int MQRC_SOURCE_DECIMAL_ENC_ERROR public static final int MQRC_SOURCE_FLOAT_ENC_ERROR public static final int MQRC_SOURCE_INTEGER_ENC_ERROR public static final int MQRC_SOURCE_LENGTH_ERROR public static final int MQRC_SRC_ENV_ERROR public static final int MQRC_SRC_NAME_ERROR public static final int MQRC_STORAGE_CLASS_ERROR public static final int MQRC_STORAGE_NOT_AVAILABLE public static final int MQRC_SUPPRESSED_BY_EXIT public static final int MQRC_SYNCPOINT_LIMIT_REACHED public static final int MQRC_SYNCPOINT_NOT_AVAILABLE public static final int MQRC_TARGET_CCSID_ERROR public static final int MQRC_TARGET_DECIMAL_ENC_ERROR public static final int MQRC_TARGET_FLOAT_ENC_ERROR public static final int MQRC_TARGET_INTEGER_ENC_ERROR public static final int MQRC_TARGET_LENGTH_ERROR public static final int MQRC_TARGET_BUFFER_ERROR public static final int MQRC_TERMINATION_FAILED public static final int MQRC_TM_ERROR public static final int MQRC_TMC_ERROR public static final int MQRC_TRIGGER_CONTROL_ERROR public static final int MQRC_TRIGGER_DEPTH_ERROR public static final int MQRC_TRIGGER_MSG_PRIORITY_ERR public static final int MQRC_TRIGGER_TYPE_ERROR public static final int MQRC_TRUNCATED public static final int MQRC_TRUNCATED_MSG_ACCEPTED public static final int MQRC_TRUNCATED_MSG_FAILED public static final int MQRC_UNEXPECTED_ERROR public static final int MQRC_UNKNOWN_AUTH_ENTITY public static final int MQRC_UNKNOWN_DEF_XMIT_Q public static final int MQRC_UNKNOWN_ENTITY public static final int MQRC_UNKNOWN_Q_NAME 230

253 6.MQC Java MQException Java public static final int MQRC_UNKNOWN_REF_OBJECT public static final int MQRC_UNKNOWN_XMIT_Q public static final int MQRC_UNKNOWN_ALIAS_BASE_Q public static final int MQRC_UNKNOWN_OBJECT_NAME public static final int MQRC_UNKNOWN_OBJECT_Q_MGR public static final int MQRC_UNKNOWN_REMOTE_Q_MGR public static final int MQRC_UNKNOWN_REPORT_OPTION public static final int MQRC_UOW_IN_PROGRESS public static final int MQRC_UOW_NOT_AVAILABLE public static final int MQRC_USER_ID_NOT_AVAILABLE public static final int MQRC_WAIT_INTERVAL_ERROR public static final int MQRC_WRONG_GMO_VERSION public static final int MQRC_WRONG_MD_VERSION public static final int MQRC_XMIT_Q_TYPE_ERROR public static final int MQRC_XMIT_Q_USAGE_ERROR public static final int MQRC_XQH_ERROR public static final int MQRC_XWAIT_CANCELED public static final int MQRC_XWAIT_ERROR public MQException(int completioncode, int reasoncode, Object source) MQException completioncode reasoncode source public MQException(int completioncode, int reasoncode, Object source,string explanation) MQException completioncode 231

254 6.MQC Java MQException Java reasoncode source explanation 232

255 6.MQC Java MQGetMessageOptions Java MQGetMessageOptions Java MQQueue:get public int options MQQueue:get 0 2 OR MQGMO Options public int waitinterval MQQueue:get MQC.MQCC_FAILED MQException.MQRC_NO_MSG_AVAILABLE options MQC.MQGMO_WAIT waitinterval 0 MQC.MQWI_UNLIMITED MQGMO WaitInterval public String resolvedqueuename MQGMO ResolvedQName public int matchoptions MQGMO MatchOptions public char groupstatus MQGMO GroupStatus public char segmentstatus 233

256 6.MQC Java MQGetMessageOptions Java MQGMO SegmentStatus public char segmentation MQGMO Segmentation public MQGetMessageOptions() MQGetMessageOptions options MQC.MQGMO_NO_WAITwaitInterval 0resolvedQueueName 234

257 6.MQC Java MQManagedObject Java MQManagedObject Java MQQueueManagerMQQueueMQProcess public String alternateuserid MQMD AlternateUserId public String name public int openoption MQOPEN Options public boolean isopen public MQQueueManager connectionreference public int closeoption MQCLOSE Options protected MQManagedObject() MQManagedObject public String getdescription() throws MQException MQQueueManager MQQueue 235

258 6.MQC Java MQManagedObject Java MQProcess public void inquire(int selectors[], int intattrs[],byte charattrs[]) throws MQException MQINQ selectors intattrs charattrs public Boolean isopen() public synchronized void set(int selectors[], int intattrs[],byte charattrs[]) throws MQException MQSET selectors intattrs charattrs public synchronized void close() throws MQException MQCLOSE 236

259 6.MQC Java MQMessage Java MQMessage Java MQ TP1/Message Queue public int report MQMD Report public int messagetype MQMD MsgType public int expiry MQMD Expiry public int feedback MQMD Feedback public int encoding MQMD Encoding public int characterset MQMD CodedCharSetId public String format MQMD Format 237

260 6.MQC Java MQMessage Java public int priority MQMD Priority public int persistence MQMD Persistence public byte messageid[] MQMD MsgId public byte correlationid[] MQMD CorrelId public int backoutcount MQMD BackoutCount public String replytoqueuename MQMD ReplyToQ public String replytoqueuemanagername MQMD ReplyToQMgr public String userid MQMD UserIdentifier public byte accountingtoken[] token MQMD AccountingToken 238

261 6.MQC Java MQMessage Java public String applicationiddata MQMD ApplIdentityData public int putapplicationtype MQMD PutApplType public String putapplicationname MQMD PutApplName public GregorianCalender putdatetime MQMD PutDate,PutTime Java Date public String applicationorigindata MQMD ApplOriginData public byte[] groupid MQMD GroupId public int messagesequencenumber MQMD MsgSeqNumber public int offset MQMD Offset public int messageflags 239

262 6.MQC Java MQMessage Java MQMD MsgFlags public int originallength MQMD OriginalLength public MQMessage() MQMessage public int gettotalmessagelength() get MQQueue:get MQQueue:get public int getmessagelength() throws IOException get public int getdatalength() throws IOException get public void seek(int pos) throws IOException get pos public void setdataoffset(int offset) throws IOException get offset 240

263 6.MQC Java MQMessage Java public int getdataoffset() throws IOException get public void clearmessage() throws IOException put/get public int getversion() public void resizebuffer(int size) throws IOException get size public boolean readboolean() throws IOException, EOFException get boolean public char readchar() throws IOException, EOFException get Unicode char public double readdouble() throws IOException, EOFException get double public float readfloat() throws IOException, EOFException get float public void readfully(byte b[]) throws IOException, EOFException get b public void readfully(byte b[], int off,int len) throws IOException, EOFException get 241

264 6.MQC Java MQMessage Java b off len public int readint() throws IOException, EOFException get int public int readint4() throws IOException, EOFException get int public String readline() throws IOException get n r r n public long readlong() throws IOException, EOFException get long public long readint8() throws IOException, EOFException get long public short readshort() throws IOException, EOFException get short public short readint2() throws IOException, EOFException get short public String readutf() throws IOException get UTF public int readunsignedbyte() throws IOException, EOFException get unsigned byte public int readunsignedshort() throws IOException, EOFException get unsigned short 242

265 6.MQC Java MQMessage Java public int readuint2() throws IOException, EOFException get unsigned short public String readstring(int length) throws IOException, EOFException get String get characterset String Unicode C MQMessage length public void setversion(int version) version public int skipbytes(int n) throws IOException, EOFException get n public void write(int b) throws IOException put 1 b public void write(byte b[]) throws IOException put 243

266 6.MQC Java MQMessage Java b public void write(byte b[], int off, int len) throws IOException put b off len public void writeboolean(boolean v) throws IOException put boolean v public void writebyte(int v) throws IOException put byte v public void writebytes(string s) throws IOException put byte s public void writechar(int v) throws IOException put Unicode char 244

267 6.MQC Java MQMessage Java v public void writechars(string s) throws IOException put Unicode char s public void writedouble(double v) throws IOException put double v public void writefloat(float v) throws IOException put float v public void writeint(int v) throws IOException put int v public void writeint4(int v) throws IOException put int v public void writelong(long v) throws IOException put long 245

268 6.MQC Java MQMessage Java v public void writeint8(long v) throws IOException put long v public void writeshort(int v) throws IOException put short v public void writeint2(int v) throws IOException put short v public void writeutf(string str) throws IOException put UTF str public void writestring(string str) throws IOException str String characterset put C MQMessage 246

269 6.MQC Java MQMessage Java str 247

270 6.MQC Java MQMessageTracker Java MQMessageTracker Java public int feedback public byte messageid[] ID public byte correlationid[] public byte accountingtoken[] public byte[] groupid ID 248

271 6.MQC Java MQProcess Java MQProcess Java MQ public MQProcess(MQQueueManager qmgr, String processname, int openoptions, String queuemanagername, String alternateuserid) throws MQException MQProcess MQOPEN MQOT_PROCESS qmgr MQQueueManager processname openoptions queuemanagername alternateuserid public String getapplicationid() throws MQException MQINQ MQCA_APPL_ID public int getapplicationtype() throws MQException MQINQ MQIA_APPL_TYPE public String getenvironmentdata() throws MQException MQINQ MQCA_ENV_DATA 249

272 6.MQC Java MQProcess Java public String getuserdata() throws MQException MQINQ MQCA_USER_DATA 250

273 6.MQC Java MQPutMessageOptions Java MQPutMessageOptions Java MQQueue:put public int options MQQueue:put 0 2 OR MQPMO Options public MQQueue ContextReference MQPMO Context public int recordfields MQPMO PutMsgRecFields public String resolvedqueuename MQPMO ResolvedQName public String resolvedqueuemanagername MQPMO ResolvedQMgrName public int knowndestcount MQPMO knowndestcount public int unknowndestcount MQPMO unknowndestcount 251

274 6.MQC Java MQPutMessageOptions Java public int invaliddestcount MQPMO invaliddestcount public MQPutMessageOptions() MQPutMessageOptions options resolvedqueuename resolvedqueuemanagername 252

275 6.MQC Java MQQueue Java MQQueue Java MQ public MQQueue(MQQueueManager qmgr,string queuename,int openoptions, String queuemanagername,string dynamicqueuename,string alternateuserid) throws MQException MQQueue MQOPEN MQOT_Q qmgr MQQueueManager queuename openoptions queuemanagername dynamicqueuename alternateuserid public synchronized void get(mqmessage message, MQGetMessageOptions getmessageoptions, int MaxMsgSize) throws MQException MQGET message MQMessage 253

276 6.MQC Java MQQueue Java getmessageoptions MQGetMessageOptions MaxMsgSize public synchronized void get(mqmessage message, MQGetMessageOptions getmessageoptions ) throws MQException get 2 MQGET message MQMessage getmessageoptions MQGetMessageOptions public synchronized void get(mqmessage message) throws MQException get 2 public synchronized void get(mqmessage message, MQGetMessageOptions getmessageoptions ) throws MQException MQGET message MQMessage public synchronized void put(mqmessage message, MQPutMessageOptions putmessageoptions ) throws MQException MQPUT message MQMessage putmessageoptions MQPutMessageOptions 254

277 6.MQC Java MQQueue Java public synchronized void put(mqmessage message) throws MQException public synchronized void put(mqmessage message, MQPutMessageOptions putmessageoptions ) throws MQException MQPUT message MQMessage public GregorianCalender getcreationdatetime() throws MQException public int getqueuetype() throws MQException MQC.MQQT_ALIAS MQC.MQQT_LOCAL MQC.MQQT_MODEL MQC.MQQT_REMOTE MQINQ MQIA_Q_TYPE public int getcurrentdepth() throws MQException MQINQ MQIA_CURRENT_Q_DEPTH public int getdefinitiontype() throws MQException MQC.MQQDT_PREDEFINED MQC.MQQDT_PERMANENT_DYNAMIC MQC.MQQDT_TEMPORARY_DYNAMIC MQINQ MQIA_DEFINITION_TYPE public int getmaximumdepth () throws MQException MQINQ MQIA_MAX_Q_DEPTH 255

278 6.MQC Java MQQueue Java public int getmaximummessagelength() throws MQException MQINQ MQIA_MAX_MSG_LENGTH public int getopeninputcount() throws MQException MQINQ MQIA_OPEN_INPUT_COUNT public int getopenoutputcount() throws MQException MQINQ MQIA_OPEN_OUTPUT_COUNT public int getshareability() throws MQException MQC.MQQA_SHAREABLE MQC.MQQA_NOT_SHAREABLE MQINQ MQIA_SHAREABILITY public int getinhibitput() throws MQException MQC.MQQA_PUT_INHIBITED MQC.MQQA_PUT_ALLOWED MQINQ MQIA_INHIBIT_PUT public void setinhibitput(int inhibit) throws MQException MQSET MQIA_INHIBIT_PUT inhibit MQC.MQQA_PUT_INHIBITED MQC.MQQA_PUT_ALLOWED public int getinhibitget() throws MQException 256

279 6.MQC Java MQQueue Java MQC.MQQA_GET_INHIBITED MQC.MQQA_GET_ALLOWED MQINQ MQIA_INHIBIT_GET public void setinhibitget(int inhibit) throws MQException MQSET MQIA_INHIBIT_GET inhibit MQC.MQQA_GET_INHIBITED MQC.MQQA_GET_ALLOWED public int gettriggercontrol() throws MQException MQC.MQTC_OFF MQC.MQTC_ON MQINQ MQIA_TRIGGER_CONTROL public void settriggercontrol(int trigger) throws MQException MQSET MQIA_TRIGGER_CONTROL trigger MQC.MQTC_OFF MQC.MQTC_ON public String gettriggerdata() throws MQException MQINQ MQCA_TRIGGER_DATA public void settriggerdata(string data) throws MQException MQSET MQCA_TRIGGER_DATA 257

280 6.MQC Java MQQueue Java data MQC.MQ_TRIGGER_DATA_LENGTH public int gettriggerdepth() throws MQException MQC.MQTT_DEPTH MQINQ MQIA_TRIGGER_DEPTH public void settriggerdepth(int depth) throws MQException MQC.MQTT_DEPTH MQSET MQIA_TRIGGER_DEPTH depth public int gettriggermessagepriority() throws MQException MQINQ MQIA_TRIGGER_MSG_PRIORITY public void settriggermessagepriority(int priority) throws MQException MQSET MQIA_TRIGGER_MSG_PRIORITY priority public int gettriggertype() throws MQException MQC.MQTT_NONE MQC.MQTT_FIRST MQC.MQTT_EVERY 258

281 6.MQC Java MQQueue Java MQC.MQTT_DEPTH MQINQ MQIA_TRIGGER_TYPE public void settriggertype(int type) throws MQException MQSET MQIA_TRIGGER_TYPE type MQC.MQTT_NONE MQC.MQTT_FIRST MQC.MQTT_EVERY MQC.MQTT_DEPTH 259

282 6.MQC Java MQQueueManager Java MQQueueManager Java MQ public boolean isconnected public MQQueueManager(String queuemanagername ) throws MQException MQQueueManager MQOPEN MQOT_Q_MGR queuemanagername public int getcharacterset() throws MQException MQINQ MQIA_CODED_CHAR_SET_ID public int getmaximummessagelength() throws MQException MQINQ MQIA_MAX_MSG_LENGTH public int getmaximumpriority() throws MQException MQINQ MQIA_MAX_PRIORITY public int getsyncpointavailability() throws MQException MQC.MQSP_AVAILABLE MQC.MQSP_NOT_AVAILABLE MQINQ MQIA_SYNCPOINT 260

283 6.MQC Java MQQueueManager Java public boolean getdistributionlistcapable() MQINQ MQIA_DIST_LISTS public synchronized void disconnect() throws MQException MQDISC public synchronized void commit() throws MQException MQCMIT public synchronized void backout() throws MQException MQBACK public synchronized MQQueue accessqueue(string queuename, int openoptions, String queuemanagername, String dynamicqueuename, String alternateuserid) throws MQException MQOPEN MQOT_Q queuename openoptions queuemanagername dynamicqueuename alternateuserid 261

284 6.MQC Java MQQueueManager Java public synchronized MQQueue accessqueue(string queuename, int openoptions) throws MQException MQOPEN MQOT_Q queuename openoptions public synchronized MQProcess accessprocess(string processname, int openoptions, String queuemanagername, String alternateuserid) throws MQException MQOPEN MQOT_PROCESS processname openoptions queuemanagername alternateuserid public synchronized MQProcess accessprocess(string processname, int openoptions) throws MQException MQOPEN MQOT_PROCESS processname openoptions 262

285 6.MQC Java MQQueueManager Java public synchronized MQDistributionList accessdistributionlist(mqdistributionlistitem[] litems, int openoptions, String alternateuserid) throws MQException MQOPEN litems openoptions alternateuserid public synchronized MQDistributionList accessdistributionlist(mqdistributionlistitem[] litems, int openoptions) MQOPEN litems openoptions public synchronized void begin() throws MQException public Boolean isconnected() throws MQException isconnect 263

286 6.MQC Java MQC Java MQC Java TP1/Message Queue - Access TP1/Message Queue public final static int MQ_ACCOUNTING_TOKEN_LENGTH public final static int MQ_APPL_IDENTITY_DATA_LENGTH public final static int MQ_APPL_ORIGIN_DATA_LENGTH public final static int MQ_CHANNEL_NAME_LENGTH public final static int MQ_CLUSTER_NAME_LENGTH public final static int MQ_CORREL_ID_LENGTH public final static int MQ_CREATION_DATE_LENGTH public final static int MQ_CREATION_TIME_LENGTH public final static int MQ_FORMAT_LENGTH public final static int MQ_GROUP_ID_LENGTH public final static int MQ_MODE_NAME_LENGTH public final static int MQ_MSG_HEADER_LENGTH public final static int MQ_MSG_ID_LENGTH public final static int MQ_PROCESS_APPL_ID_LENGTH public final static int MQ_PROCESS_DESC_LENGTH public final static int MQ_PROCESS_ENV_DATA_LENGTH public final static int MQ_PROCESS_NAME_LENGTH public final static int MQ_PROCESS_USER_DATA_LENGTH public final static int MQ_PUT_TIME_LENGTH public final static int MQ_PUT_APPL_NAME_LENGTH public final static int MQ_PUT_DATE_LENGTH public final static int MQ_Q_DESC_LENGTH public final static int MQ_Q_MGR_DESC_LENGTH 264

287 6.MQC Java MQC Java public final static int MQ_Q_MGR_NAME_LENGTH public final static int MQ_Q_NAME_LENGTH public final static int MQ_TRIGGER_DATA_LENGTH public final static int MQ_USER_ID_LENGTH public final static byte MQACT_NONE[] public final static int MQAT_UNKNOWN public final static int MQAT_NO_CONTEXT public final static int MQAT_CICS public final static int MQAT_MVS public final static int MQAT_IMS public final static int MQAT_OS2 public final static int MQAT_DOS public final static int MQAT_AIX public final static int MQAT_UNIX public final static int MQAT_QMGR public final static int MQAT_OS400 public final static int MQAT_WINDOWS public final static int MQAT_CICS_VSE public final static int MQAT_VMS public final static int MQAT_GUARDIAN public final static int MQAT_VOS public final static int MQAT_OPEN_TP1 public final static int MQAT_XDM public final static int MQAT_TMS_4V public final static int MQAT_DEFAULT public final static int MQAT_USER_FIRST public final static int MQAT_USER_LAST public final static int MQAT_WINDOWS_NT public final static int MQCA_FIRST 265

288 6.MQC Java MQC Java public final static int MQCA_APPL_ID public final static int MQCA_BASE_Q_NAME public final static int MQCA_CREATION_DATE public final static int MQCA_CREATION_TIME public final static int MQCA_DEAD_LETTER_Q_NAME public final static int MQCA_ENV_DATA public final static int MQCA_INITIATION_Q_NAME public final static int MQCA_PROCESS_DESC public final static int MQCA_PROCESS_NAME public final static int MQCA_Q_DESC public final static int MQCA_Q_MGR_DESC public final static int MQCA_Q_MGR_NAME public final static int MQCA_Q_NAME public final static int MQCA_REMOTE_Q_MGR_NAME public final static int MQCA_REMOTE_Q_NAME public final static int MQCA_NAMES public final static int MQCA_USER_DATA public final static int MQCA_TRIGGER_DATA public final static int MQCA_XMIT_Q_NAME public final static int MQCA_DEF_XMIT_Q_NAME public final static int MQCA_LAST_USED public final static int MQCA_LAST public final static int MQCA_CLUSTER_NAME public final static int MQCA_REPOSITORY_NAME public final static int MQCCSI_EMBEDDED public final static int MQCCSI_DEFAULT public final static int MQCCSI_INHERIT public final static int MQCCSI_Q_MGR public final static byte MQCI_NONE[] 266

289 6.MQC Java MQC Java public final static int MQCO_NONE public final static int MQCO_DELETE public final static int MQCO_DELETE_PURGE public final static int MQDCC_NONE public final static int MQDL_NOT_SUPPORTED public final static int MQDL_SUPPORTED public final static int MQEI_UNLIMITED public final static int MQENC_NATIVE public final static int MQENC_INTEGER_MASK public final static int MQENC_DECIMAL_MASK public final static int MQENC_FLOAT_MASK public final static int MQENC_RESERVED_MASK public final static int MQENC_INTEGER_UNDEFINED public final static int MQENC_INTEGER_NORMAL public final static int MQENC_INTEGER_REVERSED public final static int MQENC_DECIMAL_UNDEFINED public final static int MQENC_DECIMAL_NORMAL public final static int MQENC_DECIMAL_REVERSED public final static int MQENC_FLOAT_UNDEFINED public final static int MQENC_FLOAT_IEEE_NORMAL public final static int MQENC_FLOAT_IEEE_REVERSED public final static int MQENC_FLOAT_S390 public final static int MQFB_NONE public final static int MQFB_SYSTEM_FIRST public final static int MQFB_EXPIRATION public final static int MQFB_COA public final static int MQFB_COD public final static int MQFB_QUIT public final static int MQFB_APPL_CANNOT_BE_STARTED 267

290 6.MQC Java MQC Java public final static int MQFB_TM_ERROR public final static int MQFB_APPL_TYPE_ERROR public final static int MQFB_STOPPED_BY_MSG_EXIT public final static int MQFB_XMIT_Q_MSG_ERROR public final static int MQFB_SYSTEM_LAST public final static int MQFB_APPL_FIRST public final static int MQFB_APPL_LAST public final static int MQFB_NOT_A_REPOSITORY_MSG public final static int MQFB_PAN public final static int MQFB_NAN public final static String MQFMT_NONE public final static String MQFMT_ADMIN public final static String MQFMT_DEAD_LETTER_HEADER public final static String MQFMT_EVENT public final static String MQFMT_PCF public final static String MQFMT_STRING public final static String MQFMT_TRIGGER public final static String MQFMT_XMIT_Q_HEADER public final static String MQFMT_DIST_HEADER public final static String MQFMT_MD_EXTENSION public final static String MQFMT_REF_MSG_HEADER public final static byte MQGI_NONE public final static int MQGMO_ALL_MSGS_AVAILABLE public final static int MQGMO_ALL_SEGMENTS_AVAILABLE public final static int MQGMO_COMPLETE_MSG public final static int MQGMO_WAIT public final static int MQGMO_NO_WAIT public final static int MQGMO_SYNCPOINT public final static int MQGMO_SYNCPOINT_IF_PERSISTENT 268

291 6.MQC Java MQC Java public final static int MQGMO_NO_SYNCPOINT public final static int MQGMO_BROWSE_FIRST public final static int MQGMO_BROWSE_NEXT public final static int MQGMO_BROWSE_MSG_UNDER_CURSOR public final static int MQGMO_MSG_UNDER_CURSOR public final static int MQGMO_LOCK public final static int MQGMO_UNLOCK public final static int MQGMO_ACCEPT_TRUNCATED_MSG public final static int MQGMO_CURRENT_VERSION public final static int MQGMO_FAIL_IF_QUIESCING public final static int MQGMO_CONVERT public final static int MQGMO_NONE public final static int MQGMO_LOGICAL_ORDER public final static int MQGMO_VERSION_1 public final static int MQGMO_VERSION_2 public final static int MQGMO_VERSION_3 public final static char MQGS_NOT_IN_GROUP public final static char MQGS_MSG_IN_GROUP public final static char MQGS_LAST_MSG_IN_GROUP public final static int MQIA_FIRST public final static int MQIA_APPL_TYPE public final static int MQIA_CODED_CHAR_SET_ID public final static int MQIA_CURRENT_Q_DEPTH public final static int MQIA_DEF_INPUT_OPEN_OPTION public final static int MQIA_DEF_PERSISTENCE public final static int MQIA_DEF_PRIORITY public final static int MQIA_DEFINITION_TYPE public final static int MQIA_HARDEN_GET_BACKOUT public final static int MQIA_INHIBIT_GET 269

292 6.MQC Java MQC Java public final static int MQIA_INHIBIT_PUT public final static int MQIA_MAX_HANDLES public final static int MQIA_USAGE public final static int MQIA_MAX_MSG_LENGTH public final static int MQIA_MAX_PRIORITY public final static int MQIA_MAX_Q_DEPTH public final static int MQIA_MSG_DELIVERY_SEQUENCE public final static int MQIA_OPEN_INPUT_COUNT public final static int MQIA_OPEN_OUTPUT_COUNT public final static int MQIA_NAME_COUNT public final static int MQIA_Q_TYPE public final static int MQIA_RETENTION_INTERVAL public final static int MQIA_SHAREABILITY public final static int MQIA_TRIGGER_CONTROL public final static int MQIA_TRIGGER_INTERVAL public final static int MQIA_TRIGGER_MSG_PRIORITY public final static int MQIA_TRIGGER_TYPE public final static int MQIA_TRIGGER_DEPTH public final static int MQIA_SYNCPOINT public final static int MQIA_PLATFORM public final static int MQIA_MAX_UNCOMMITTED_MSGS public final static int MQIA_SCOPE public final static int MQIA_LAST_USED public final static int MQIA_LAST public final static int MQIA_DIST_LISTS public final static int MQIA_DEF_BIND public final static int MQIAV_NOT_APPLICABLE public final static int MQMD_VERSION_1 public final static int MQMD_VERSION_2 270

293 6.MQC Java MQC Java public final static int MQMD_CURRENT_VERSION public final static int MQMDS_PRIORITY public final static int MQMDS_FIFO public final static int MQMF_SEGMENTATION_INHIBITED public final static int MQMF_NONE public final static int MQMF_SEGMENTATION_ALLOWED public final static int MQMF_LAST_SEGMENT public final static int MQMF_SEGMENT public final static int MQMF_MSG_IN_GROUP public final static int MQMF_LAST_MSG_IN_GROUP public final static byte MQMI_NONE[] public final static int MQMO_NONE public final static int MQMO_MATCH_MSG_ID public final static int MQMO_MATCH_CORREL_ID public final static int MQMO_MATCH_GROUP_ID public final static int MQMO_MATCH_MSG_SEQ_NUMBER public final static int MQMO_MATCH_OFFSET public final static int MQMT_SYSTEM_FIRST public final static int MQMT_REQUEST public final static int MQMT_REPLY public final static int MQMT_DATAGRAM public final static int MQMT_REPORT public final static int MQMT_SYSTEM_LAST public final static int MQMT_APPL_FIRST public final static int MQMT_APPL_LAST public final static byte MQOII_NONE public final static int MQOL_UNDEFINED public final static int MQOO_INPUT_AS_Q_DEF public final static int MQOO_INPUT_SHARED 271

294 6.MQC Java MQC Java public final static int MQOO_INPUT_EXCLUSIVE public final static int MQOO_BROWSE public final static int MQOO_OUTPUT public final static int MQOO_SAVE_ALL_CONTEXT public final static int MQOO_ALTERNATE_USER_AUTHORITY public final static int MQOO_FAIL_IF_QUIESCING public final static int MQOO_PASS_IDENTITY_CONTEXT public final static int MQOO_PASS_ALL_CONTEXT public final static int MQOO_SET_IDENTITY_CONTEXT public final static int MQOO_SET_ALL_CONTEXT public final static int MQOO_INQUIRE public final static int MQOO_SET public final static int MQOO_BIND_AS_Q_DEF public final static int MQOO_BIND_ON_OPEN public final static int MQOO_BIND_NOT_FIXED public final static int MQOT_Q public final static int MQOT_PROCESS public final static int MQOT_Q_MGR public final static int MQPER_PERSISTENT public final static int MQPER_NOT_PERSISTENT public final static int MQPER_PERSISTENCE_AS_Q_DEF public final static int MQPL_MVS public final static int MQPL_OS2 public final static int MQPL_AIX public final static int MQPL_OS400 public final static int MQPL_OPEN_TP1 public final static int MQPL_XDM public final static int MQPL_TMS4V public final static int MQPMO_SYNCPOINT 272

295 6.MQC Java MQC Java public final static int MQPMO_NO_SYNCPOINT public final static int MQPMO_NO_CONTEXT public final static int MQPMO_DEFAULT_CONTEXT public final static int MQPMO_PASS_IDENTITY_CONTEXT public final static int MQPMO_PASS_ALL_CONTEXT public final static int MQPMO_SET_IDENTITY_CONTEXT public final static int MQPMO_SET_ALL_CONTEXT public final static int MQPMO_ALTERNATE_USER_AUTHORITY public final static int MQPMO_FAIL_IF_QUIESCING public final static int MQPMO_NONE public final static int MQPMO_NEW_MSG_ID public final static int MQPMO_NEW_CORREL_ID public final static int MQPMO_LOGICAL_ORDER public final static int MQPMO_VERSION_1 public final static int MQPMO_VERSION_2 public final static int MQPMO_CURRENT_VERSION public final static int MQPMRF_NONE public final static int MQPMRF_MSG_ID public final static int MQPMRF_CORREL_ID public final static int MQPMRF_GROUP_ID public final static int MQPMRF_FEEDBACK public final static int MQPMRF_ACCOUNTING_TOKEN public final static int MQPRI_PRIORITY_AS_Q_DEF public final static int MQQA_GET_INHIBITED public final static int MQQA_GET_ALLOWED public final static int MQQA_PUT_INHIBITED public final static int MQQA_PUT_ALLOWED public final static int MQQA_SHAREABLE public final static int MQQA_NOT_SHAREABLE 273

296 6.MQC Java MQC Java public final static int MQQA_BACKOUT_HARDENED public final static int MQQA_BACKOUT_NOT_HARDENED public final static int MQQDT_PREDEFINED public final static int MQQDT_PERMANENT_DYNAMIC public final static int MQQDT_TEMPORARY_DYNAMIC public final static int MQQT_LOCAL public final static int MQQT_MODEL public final static int MQQT_ALIAS public final static int MQQT_REMOTE public final static int MQQT_CLUSTER public final static int MQRO_EXCEPTION public final static int MQRO_EXCEPTION_WITH_DATA public final static int MQRO_EXCEPTION_WITH_FULL_DATA public final static int MQRO_EXPIRATION public final static int MQRO_EXPIRATION_WITH_DATA public final static int MQRO_EXPIRATION_WITH_FULL_DATA public final static int MQRO_COA public final static int MQRO_COA_WITH_DATA public final static int MQRO_COA_WITH_FULL_DATA public final static int MQRO_COD public final static int MQRO_COD_WITH_DATA public final static int MQRO_COD_WITH_FULL_DATA public final static int MQRO_COPY_MSG_ID_TO_CORREL_ID public final static int MQRO_PASS_CORREL_ID public final static int MQRO_NEW_MSG_ID public final static int MQRO_PASS_MSG_ID public final static int MQRO_DEAD_LETTER_Q public final static int MQRO_DISCARD_MSG public final static int MQRO_NONE 274

297 6.MQC Java MQC Java public final static int MQRO_REJECT_UNSUP_MASK public final static int MQRO_ACCEPT_UNSUP_MASK public final static int MQRO_ACCEPT_UNSUP_IF_XMIT_MASK public final static int MQRO_PAN public final static int MQRO_NAN public final static char MQSEG_INHIBITED public final static char MQSS_NOT_A_SEGMENT public final static int MQSP_AVAILABLE public final static int MQSP_NOT_AVAILABLE public final static char MQSS_LAST_SEGMENT public final static char MQSS_SEGMENT public final static int MQTC_OFF public final static int MQTC_ON public final static int MQTT_NONE public final static int MQTT_FIRST public final static int MQTT_EVERY public final static int MQTT_DEPTH public final static int MQUS_NORMAL public final static int MQUS_TRANSMISSION public final static int MQWI_UNLIMITED 275

298 6.MQC Java Java Java Java 6-2Java 276

299 6.MQC Java Java Java import JP.co.Hitachi.soft.MQ.Access.*; // import the MQAccess package public class MQAccessSample { private String QMgrName = " "; // queue manager name private MQQueueManager QMgr; // MQQueueManager object public MQAccessSample() { try { // connect to the queue manager QMgr = new MQQueueManager(QMgrName); // set the open options int openoptions = MQC.MQOO_OUTPUT MQC.MQOO_INPUT_AS_Q_DEF ; // open the queue MQQueue LocalQ = QMgr.accessQueue("dynq1", openoptions, null, null, null); // create a message object MQMessage PutMessage = new MQMessage(); // UTF format message data PutMessage.writeUTF("******** sample put data ********"); // set the put message options MQPutMessageOptions mqpmo= new MQPutMessageOptions(); mqpmo.options = MQC.MQPMO_SYNCPOINT; // begin local transaction QMgr.begin(); // put the message LocalQ.put(PutMessage, mqpmo); // commit local transaction QMgr.commit(); // create a message object MQMessage GetMessage = new MQMessage(); // set the get message id GetMessage.messageId = PutMessage.messageId; // set the get message options MQGetMessageOptions mqgmo= new MQGetMessageOptions(); mqgmo.options = MQC.MQGMO_SYNCPOINT MQC.MQGMO_NO_WAIT; // begin local transaction 277

300 6.MQC Java Java } } QMgr.begin(); // get the message LocalQ.get(GetMessage, mqgmo); // commit local transaction QMgr.commit(); // display the get message String msgtext = GetMessage.readUTF(); System.out.println("The message is: " + msgtext); // close the queue LocalQ.close(); // disconnect from the queue manager QMgr.disconnect(); } catch (MQException ex) { // MQ error System.out.println ("An MQ error occurred : Completion code " + ex.completioncode + " Reason code " + ex.reasoncode); } catch (java.io.ioexception ex) { // buffer error System.out.println ("An error occurred whilst writing to the buffer:" + ex); } public static void main(string args[]) { // execute this sample program MQAccessSample sample = new MQAccessSample(); } 278

301 7 MQC JMS MQC JMS JMS Java MQC JMS JMS JMS MQI JMS JMS JMS BytesMessage JMS ConnectionMetaData JMS DeliveryMode JMS Destination Queue JMS Message JMS MessageConsumer QueueReceiver JMS MessageProducer QueueSender JMS QueueBrowser JMS 279

302 7.MQC JMS QueueConnection JMS QueueConnectionFactory JMS QueueSession JMS TemporaryQueue JMS Enumeration J2SE MQC JMS JMS JMS 280

303 7.MQC JMS JMS Java JMS Java MQC JMS jp.co.hitachi.soft.mqadaptor Java JMS 281

304 7.MQC JMS MQC JMS MQC JMS MQC JMS Java JMS Sun Microsystems, Inc. JMS 1.0 MQC JMS BJMS MQC JMS 7-1JMS BytesMessage ConnectionMetaData DeliveryMode Destination Queue Message MessageConsumer QueueReceiver MessageProducer QueueSender QueueBrowser QueueConnection Connection QueueConnectionFactory ConnectionFactory QueueSession Session TemporaryQueue Connection JMS JMS JMS PTP JMS PTP QueueConnection QueueConnectionFactory QueueReceiverQueueSenderQueueBrowser TemporaryQueue QueueConnection Queue 7-2JMS MQC TP1/Message Queue JMS Java 282

305 7.MQC JMS MQC JMS 7-3JMS IllegalStateException InvalidClientIDException InvalidDestinationException InvalidSelectorException JMSException JMSSecurityException MessageEOFException MessageFormatException MessageNotReadableException MessageNotWriteableException ResourceAllocationException TransactionInProgressException TransactionRolledBackException ID JMS JMS StreamMessage BytesMessage JMS JMS JMS Session.commit 283

306 7.MQC JMS JMS JMS JMS 7-1JMS 284

307 7.MQC JMS JMS

308 7.MQC JMS JMS MQI JMS MQI JMS MQI 7-4 MQI Queue TemporaryQueue MQI QueueSession createsender createreceiver QueueSession createtemporary Queue MQOPEN QueueBrowser getenumeration QueueSender QueueReceiver QueueBrowser close QueueSession close MQCLOSE QueueSender send Queue QueueSender send Queue MQPUT QueueSender send Queue QueueSender send Queue MQPUT1 QueueReceiver receive receivenowait QueueReceiver receive receivenowait MQGET Enumeration hasmoreelements nextelement Enumeration hasmoreelements nextelement QueueBrowser getenumeration Enumeration Cosminexus Component Container MQCLOSEMQOPEN 286

309 7.MQC JMS JMS JMS JMS TP1/Message Queue MQC JMS JMS TP1/Message Queue 7-3JMS TP1/Message Queue JMS JMS TP1/Message Queue - Access 7-3 JMS MQMD MQMD TP1/Message Queue JMS MQMD JMS MQMD 287

310 7.MQC JMS JMS 7-5JMS MQMD MQMD JMSDestination Destination JMSMessageID String MsgId JMSTimestamp long PutDate PutTime JMSRedelivered boolean BackoutCount JMSCorrelationI D String 1 CorrelId Message JMSReplyTo Destination ReplyToQ ReplyToQMgr Message JMSType String Message TP1/Message Queue JMSDeliveryMod e int Persistence QueueSende r JMSExpiration long Expiry QueueSende r JMSPriority int Priority QueueSende r 7-6JMS MQMD MQMD JMSXAppID String PutApplName JMSXUserID String UserIdentifier JMSXDeliveryC ount JMSXGroupID 1 int BackoutCount String 2 GroupId Message JMSXGroupSeq int MsgSeqNumbe r Message JMS_HITACHI _PutApplType int PutApplType 288

311 7.MQC JMS JMS MQMD JMS_HITACHI _CodedCharSetI d int CodedCharSet Id Message JMS_HITACHI _Encoding JMS_HITACHI _Feedback JMS_HITACHI _MsgType JMS_HITACHI _Report JMS_HITACHI _Format JMS_HITACHI _MQMF_LAST_ MSG_IN_GRO UP 1 int Encoding Message int Feedback Message int MsgType Message int Report Message String 3 Format Message boolean MsgFlags Message 1 JMSXGroupID JMS_HITACHI_MQMF_LAST_MSG_IN_GROUP MQMD MsgFlags JMSXGroupID JMS_HITACHI_MQMF_LAST_MSG_IN_GROUP false true MQMF_NONE MQMF_MSG_IN_GROUP MQMF_LAST_MSG_IN_GROUP 2 String 24 byte TP1/Message Queue MQBYTE24 24 ID:UTF-8 ID: ID:ID: MQBYTE MQBYTE24 289

312 7.MQC JMS JMS MQMD MQCI_NONE MQGI_NONE 1. null 2. ID: 3. ID: ID: 16 3 String 8 char TP1/Message Queue MQCHAR8 UTF-8 7 ASCII 8 JMS JMS booleanbyteshortintlongfloatdouble String JMS 7-7JMS boolean byte short int long float double String boolea n byte short int long float double String String valueof 290

313 7.MQC JMS JMS 291

314 7.MQC JMS QueueSession.createReceiver createbrowser java.lang.string JMSMessageID JMSCorrelationID InvalidSelectorException = InvalidSelectorException InvalidSelectorException JMSMessageID JMSCorrelationID ' '' "literal's" 'literal''s' JMSMessageID MQMD MsgId JMSCorrelationID MQMD CorrelId ID:UTF-8 String 24 byte TP1/Message Queue MQBYTE

315 7.MQC JMS ID:ID: MQBYTE MQBYTE MQMD MQMI_NONE MQCI_NONE 1. null 2. ID: 3. ID: ID: 16 AND InvalidSelectorException JMSMessageID = 'aaa' JMSCorrelationID = 'bbb' JMSMessageID = 'aaa' AND JMSCorrelationID = 'bbb' JMSCorrelationID = 'aaa' AND JMSMessageID = 'bbb' 293

316 7.MQC JMS JMS JMS TP1/Message Queue - Access JMS QueueSession 1 1 EJB Resource Reference Unshareable Shareable QueueSession QueueSession QueueSession QueueSession QueueSession QueueSession close QueueSession transacted true QueueSession QueueSenderQueueReceiver send receive QueueSession commit rollback QueueSession QueueSenderQueueReceiver send receive send receive commit rollback QueueSession commit rollback QueueSession commit rollback QueueConnection createqueuesession QueueSession close QueueConnection createqueuesession QueueReceiver Shareability MQQA_NOT_SHAREABLEQueueReceiver 294

317 7.MQC JMS JMS QueueReceiver Shareability MQQA_SHAREABLEQueueReceiver QueueReceiver receive receivenowait QueueBrowser getenumeration Enumeration nextelement Message-Driven Bean Properties Pooled Instances Maximum Message-Driven Bean Maximum 0 1 Message-Driven Bean XATransaction XATransaction Message-Driven Bean 295

318 7.MQC JMS JMS JMS XATransaction Cosminexus Component Container "/opt/cosminexus/cc/server /usrconf/ejb/< >/usrconf.properties" ejbserver.distributedtx.xatransaction.enabled=true false MDB mqaqueatl -s shareblenotshareble JMS QueueSession Cosminexus Component Container MQC QueueSession Cosminexus Component Container Cosminexus Component Container MQC QueueSession QueueSession MQC QueueSession QueueSession Cosminexus Component Container MQC Cosminexus Component Container MQC Cosminexus Component Container MQC Cosminexus Component Container QueueSession Cosminexus Component 296

319 7.MQC JMS JMS Container MQC Cosminexus Component Container MDB Message-driven Bean:<Bean > caught an error from TP1 Message Queue. The error message is : KFCA31345-W MDB KFCA31346-E MDB MDB 8.2 DCMQCCLTPORT XATransaction MQC mqcenv -r (0)MQCONN MQRC_UNEXPECTED_ERROR2195MQC -r (0) MQC 297

320 7.MQC JMS BytesMessage JMS BytesMessage JMS BytesMessage public interface BytesMessage extends Message { public boolean readboolean() throws JMSException; public byte readbyte() throws JMSException; public int readunsignedbyte() throws JMSException; public short readshort() throws JMSException; public int readunsignedshort() throws JMSException; public char readchar() throws JMSException; public int readint() throws JMSException; public long readlong() throws JMSException; public float readfloat() throws JMSException; public double readdouble() throws JMSException; public java.lang.string readutf() throws JMSException; public int readbytes(byte[] value) throws JMSException; public int readbytes(byte[] value, int length) throws JMSException; public void writeboolean(boolean value) throws JMSException; public void writebyte(byte value) throws JMSException; public void writeshort(short value) throws JMSException; public void writechar(char value) throws JMSException; public void writeint(int value) throws JMSException; public void writelong(long value) throws JMSException; public void writefloat(float value) throws JMSException; public void writedouble(double value) throws JMSException; public void writeutf(java.lang.string value) throws JMSException; public void writebytes(byte[] value) throws JMSException; public void writebytes(byte[] value, int offset, int length) throws JMSException; public void writeobject(java.lang.object value) throws JMSException; public void reset() throws JMSException; } public boolean readboolean() throws JMSException boolean JMSException MessageNotReadableException MessageEOFException boolean 298

321 7.MQC JMS BytesMessage JMS public byte readbyte() throws JMSException 8 JMSException MessageNotReadableException MessageEOFException 1 8 public int readunsignedbyte() throws JMSException 8 JMSException MessageNotReadableException MessageEOFException 1 8 public short readshort() throws JMSException 16 JMSException MessageNotReadableException MessageEOFException 2 16 public int readunsignedshort() throws JMSException 16 JMSException MessageNotReadableException MessageEOFException 2 16 public char readchar() throws JMSException Unicode 299

322 7.MQC JMS BytesMessage JMS JMSException MessageNotReadableException MessageEOFException 2 Unicode public int readint() throws JMSException 32 JMSException MessageNotReadableException MessageEOFException 4 32 public long readlong() throws JMSException 64 JMSException MessageNotReadableException MessageEOFException 8 64 public float readfloat() throws JMSException float JMSException MessageNotReadableException MessageEOFException 4 float public double readdouble() throws JMSException double JMSException MessageNotReadableException MessageEOFException 300

323 7.MQC JMS BytesMessage JMS 8 double public java.lang.string readutf() throws JMSException UTF-8 JMSException MessageNotReadableException MessageEOFException Unicode public int readbytes(byte[] value) throws JMSException byte byte -1 value JMSException MessageNotReadableException -1 public int readbytes(byte[] value, int length) throws JMSException byte length length length length 301

324 7.MQC JMS BytesMessage JMS -1 length JMSException value length JMSException MessageNotReadableException -1 public void writeboolean(boolean value) throws JMSException 1 boolean true 1 false 0 value JMSException MessageNotWriteableException public void writebyte(byte value) throws JMSException 1 byte value JMSException MessageNotWriteableException 302

325 7.MQC JMS BytesMessage JMS public void writeshort(short value) throws JMSException 2 short high byte first value JMSException MessageNotWriteableException public void writechar(char value) throws JMSException 2 char high byte first value JMSException MessageNotWriteableException public void writeint(int value) throws JMSException 4 int high byte first value JMSException MessageNotWriteableException public void writelong(long value) throws JMSException 8 long high byte first value 303

326 7.MQC JMS BytesMessage JMS JMSException MessageNotWriteableException public void writefloat(float value) throws JMSException Float floattointbits float int 4 int high byte first value JMSException MessageNotWriteableException public void writedouble(double value) throws JMSException Double doubletolongbits double long 8 long high byte first value JMSException MessageNotWriteableException public void writeutf(java.lang.string value) throws JMSException UTF-8 value JMSException MessageNotWriteableException 304

327 7.MQC JMS BytesMessage JMS public void writebytes(byte[] value) throws JMSException byte value JMSException MessageNotWriteableException public void writebytes(byte[] value, int offset, int length) throws JMSException byte value offset byte length JMSException MessageNotWriteableException public void writeobject(java.lang.object value) throws JMSException Java ByteInteger String byte value Java null JMSException MessageNotWriteableException NullPointerException null MessageFormatException 305

328 7.MQC JMS BytesMessage JMS public void reset() throws JMSException JMSException MessageFormatException 306

329 7.MQC JMS ConnectionMetaData JMS ConnectionMetaData JMS ConnectionMetaData JMS QueueConnection getmetadata ConnectionMetaData JMS JMS JMS public interface ConnectionMetaData { public int getjmsmajorversion() throws JMSException; public int getjmsminorversion() throws JMSException; public java.lang.string getjmsprovidername() throws JMSException; public java.lang.string getjmsversion() throws JMSException; public java.util.enumeration getjmsxpropertynames() throws JMSException; public int getprovidermajorversion() throws JMSException; public int getproviderminorversion() throws JMSException; public java.lang.string getproviderversion() throws JMSException; } public int getjmsmajorversion() throws JMSException JMS JMSException JMS public int getjmsminorversion() throws JMSException JMS JMSException JMS public java.lang.string getjmsprovidername() throws JMSException 307

330 7.MQC JMS ConnectionMetaData JMS JMSException public java.lang.string getjmsversion() throws JMSException JMS JMSException JMS public java.util.enumeration getjmsxpropertynames() throws JMSException JMSX JMSException JMSX public int getprovidermajorversion() throws JMSException TP1/Message Queue - Access JMS JMSException TP1/Message Queue - Access JMS public int getproviderminorversion() throws JMSException TP1/Message Queue - Access JMS JMSException TP1/Message Queue - Access JMS public java.lang.string getproviderversion() throws JMSException TP1/Message Queue - Access JMS JMSException 308

331 7.MQC JMS ConnectionMetaData JMS TP1/Message Queue - Access JMS 309

332 7.MQC JMS DeliveryMode JMS DeliveryMode JMS DeliveryMode JMS TP1/Message Queue MQMD Persistence public interface DeliveryMode { public static final int NON_PERSISTENT; public static final int PERSISTENT; } public static final int NON_PERSISTENT TP1/Message Queue MQPER_NOT_PERSISTENT NON_PERSISTENT 1 2 public static final int PERSISTENT TP1/Message Queue MQPER_PERSISTENT send TP1/Message Queue PERSISTENT 310

333 7.MQC JMS Destination Queue JMS Destination Queue JMS Destination JMS Queue public interface Destination { } public interface Queue extends Destination { public java.lang.string getqueuename() throws JMSException; public java.lang.string tostring(); } public java.lang.string getqueuename() throws JMSException JMSException public java.lang.string tostring() java.lang.object tostring 311

334 7.MQC JMS Message JMS Message JMS Message JMS JMS public interface Message { public static final int DEFAULT_DELIVERY_MODE; public static final int DEFAULT_PRIORITY; public static final long DEFAULT_TIME_TO_LIVE; public java.lang.string getjmsmessageid() throws JMSException; public void setjmsmessageid(java.lang.string id) throws JMSException; public long getjmstimestamp() throws JMSException; public void setjmstimestamp(long timestamp) throws JMSException; public byte[] getjmscorrelationidasbytes() throws JMSException; public void setjmscorrelationidasbytes(byte[] correlationid) throws JMSException; public java.lang.string getjmscorrelationid() throws JMSException; public void setjmscorrelationid(java.lang.string correlationid) throws JMSException; public Destination getjmsreplyto() throws JMSException; public void setjmsreplyto(destination replyto) throws JMSException; public Destination getjmsdestination() throws JMSException; public void setjmsdestination(destination destination) throws JMSException; public int getjmsdeliverymode() throws JMSException; public void setjmsdeliverymode(int deliverymode) throws JMSException; public boolean getjmsredelivered() throws JMSException; public void setjmsredelivered(boolean redelivered) throws JMSException; public java.lang.string getjmstype() throws JMSException; public void setjmstype(java.lang.string type) throws JMSException; public long getjmsexpiration() throws JMSException; public void setjmsexpiration(long expiration) throws JMSException; public int getjmspriority() throws JMSException; public void setjmspriority(int priority) throws JMSException; public void clearproperties() throws JMSException; public boolean propertyexists(java.lang.string name) throws JMSException; public boolean getbooleanproperty(java.lang.string name) throws JMSException; public byte getbyteproperty(java.lang.string name) throws JMSException; public short getshortproperty(java.lang.string name) throws JMSException; public int getintproperty(java.lang.string name) throws 312

335 7.MQC JMS Message JMS JMSException; public long getlongproperty(java.lang.string name) throws JMSException; public float getfloatproperty(java.lang.string name) throws JMSException; public double getdoubleproperty(java.lang.string name) throws JMSException; public java.lang.string getstringproperty(java.lang.string name) throws JMSException; public java.lang.object getobjectproperty(java.lang.string name) throws JMSException; public java.util.enumeration getpropertynames() throws JMSException; public void setbooleanproperty(java.lang.string name, boolean value) throws JMSException; public void setbyteproperty(java.lang.string name, byte value) throws JMSException; public void setshortproperty(java.lang.string name, short value) throws JMSException; public void setintproperty(java.lang.string name, int value) throws JMSException; public void setlongproperty(java.lang.string name, long value) throws JMSException; public void setfloatproperty(java.lang.string name, float value) throws JMSException; public void setdoubleproperty(java.lang.string name, double value) throws JMSException; public void setstringproperty(java.lang.string name, java.lang.string value) throws JMSException; public void setobjectproperty(java.lang.string name, java.lang.object value) throws JMSException; public void acknowledge() throws JMSException; public void clearbody() throws JMSException; } public static final int DEFAULT_DELIVERY_MODE DeliveryMode.PERSISTENT public static final int DEFAULT_PRIORITY 4 public static final long DEFAULT_TIME_TO_LIVE 0 public java.lang.string getjmsmessageid() throws JMSException JMSMessageID 313

336 7.MQC JMS Message JMS JMSException public void setjmsmessageid(java.lang.string id) throws JMSException JMSMessageID JMSMessageID TP1/Message Queue JMSMessageID JMSMessageID ID: id JMSException public long getjmstimestamp() throws JMSException JMSTimestamp JMSException public void setjmstimestamp(long timestamp) throws JMSException JMSTimestamp TP1/Message Queue PutDatePutTime JMSTimestamp JMSTimestamp TP1/Message Queue JMSTimestamp timestamp

337 7.MQC JMS Message JMS JMSException public byte[] getjmscorrelationidasbytes() throws JMSException byte JMSException public void setjmscorrelationidasbytes(byte[] correlationid) throws JMSException byte 24 correlationid JMSException public java.lang.string getjmscorrelationid() throws JMSException String JMSException public void setjmscorrelationid(java.lang.string correlationid) throws JMSException String ID: byte TP1/Message Queue MQBYTE24 ID: String MQBYTE24 24 JMSCorrelationID ID:

338 7.MQC JMS Message JMS correlationid JMSException public Destination getjmsreplyto() throws JMSException JMSException public void setjmsreplyto(destination replyto) throws JMSException replyto JMSException public Destination getjmsdestination() throws JMSException JMSException public void setjmsdestination(destination destination) throws JMSException JMSDestination JMSDestination JMSDestination destination 316

339 7.MQC JMS Message JMS JMSException public int getjmsdeliverymode() throws JMSException JMSException DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT public void setjmsdeliverymode(int deliverymode) throws JMSException JMSDeliveryMode QueueSender deliverymode DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT JMSException public boolean getjmsredelivered() throws JMSException JMSException falsemqmd BackoutCount 0 truemqmd BackoutCount 1 public void setjmsredelivered(boolean redelivered) throws JMSException JMSRedelivered redelivered 317

340 7.MQC JMS Message JMS JMSException public java.lang.string getjmstype() throws JMSException TP1/Message Queue JMSType setjmstype JMSException JMSType public void setjmstype(java.lang.string type) throws JMSException JMSType TP1/Message Queue JMSException public long getjmsexpiration() throws JMSException JMSExpiration TimeToLive JMSExpiration 0 JMSException public void setjmsexpiration(long expiration) throws JMSException JMSExpiration TimeToLive QueueSender TimeToLive 0 JMSExpiration 0 expiration 0 318

341 7.MQC JMS Message JMS JMSException public int getjmspriority() throws JMSException JMSException public void setjmspriority(int priority) throws JMSException JMSPriority QueueSender priority JMSException public void clearproperties() throws JMSException JMSException public boolean propertyexists(java.lang.string name) throws JMSException name name JMSException true false public boolean getbooleanproperty(java.lang.string name) throws JMSException boolean name 319

342 7.MQC JMS Message JMS name JMSException MessageFormatException name public byte getbyteproperty(java.lang.string name) throws JMSException byte name name JMSException MessageFormatException name public short getshortproperty(java.lang.string name) throws JMSException short name name JMSException MessageFormatException name public int getintproperty(java.lang.string name) throws JMSException int name name JMSException 320

343 7.MQC JMS Message JMS MessageFormatException name public long getlongproperty(java.lang.string name) throws JMSException long name name JMSException MessageFormatException name public float getfloatproperty(java.lang.string name) throws JMSException float name name JMSException MessageFormatException name public double getdoubleproperty(java.lang.string name) throws JMSException double name name JMSException MessageFormatException name public java.lang.string getstringproperty(java.lang.string name) throws JMSException String name 321

344 7.MQC JMS Message JMS name JMSException MessageFormatException name public java.lang.object getobjectproperty(java.lang.string name) throws JMSException name name JMSException name public java.util.enumeration getpropertynames() throws JMSException JMSException public void setbooleanproperty(java.lang.string name, boolean value) throws JMSException boolean name name JMS 7-6 send TP1/ Message Queue name 322

345 7.MQC JMS Message JMS value JMSException MessageNotWriteableException public void setbyteproperty(java.lang.string name, byte value) throws JMSException byte name name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setshortproperty(java.lang.string name, short value) throws JMSException short name name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setintproperty(java.lang.string name, int value) throws JMSException int name 323

346 7.MQC JMS Message JMS name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setlongproperty(java.lang.string name, long value) throws JMSException long name name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setfloatproperty(java.lang.string name, float value) throws JMSException float name name JMS 7-6 send TP1/ Message Queue name value 324

347 7.MQC JMS Message JMS JMSException MessageNotWriteableException public void setdoubleproperty(java.lang.string name, double value) throws JMSException double name name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setstringproperty(java.lang.string name, java.lang.string value) throws JMSException String name name JMS 7-6 send TP1/ Message Queue name value JMSException MessageNotWriteableException public void setobjectproperty(java.lang.string name, java.lang.object value) throws JMSException name 325

348 7.MQC JMS Message JMS ByteInteger String name JMS 7-6 send TP1/ Message Queue name value JMSException MessageFormatException MessageNotWriteableException public void acknowledge() throws JMSException JMS acknowledge acknowledge JMSException IllegalStateException public void clearbody() throws JMSException JMSException 326

349 7.MQC JMS MessageConsumer QueueReceiver JMS MessageConsumer QueueReceiver JMS QueueReceiver public interface MessageConsumer { public void close() throws JMSException; public MessageListener getmessagelistener() throws JMSException; public java.lang.string getmessageselector() throws JMSException; public Message receive() throws JMSException; public Message receive(long timeout) throws JMSException; public Message receivenowait() throws JMSException; public void setmessagelistener(messagelistener listener) throws JMSException; } public interface QueueReceiver extends MessageConsumer { public Queue getqueue() throws JMSException; } public void close() throws JMSException TP1/Message Queue JMSException public MessageListener getmessagelistener() throws JMSException JMSException public java.lang.string getmessageselector() throws JMSException JMSException 327

350 7.MQC JMS MessageConsumer QueueReceiver JMS public Message receive() throws JMSException null KFCA31307-W JMSException null public Message receive(long timeout) throws JMSException timeout 0 null KFCA31307-W timeout JMSException JMSException null 328

351 7.MQC JMS MessageConsumer QueueReceiver JMS public Message receivenowait() throws JMSException null KFCA31307-W JMSException null public void setmessagelistener(messagelistener listener) throws JMSException QueueReceiver listener JMSException public Queue getqueue() throws JMSException JMSException Queue 329

352 7.MQC JMS MessageProducer QueueSender JMS MessageProducer QueueSender JMS QueueSender public interface MessageProducer { public void close() throws JMSException; public int getdeliverymode() throws JMSException; public boolean getdisablemessageid() throws JMSException; public boolean getdisablemessagetimestamp() throws JMSException; public int getpriority() throws JMSException; public long gettimetolive() throws JMSException; public void setdeliverymode(int deliverymode) throws JMSException; public void setdisablemessageid(boolean value) throws JMSException; public void setdisablemessagetimestamp(boolean value) throws JMSException; public void setpriority(int defaultpriority) throws JMSException; public void settimetolive(long timetolive) throws JMSException; } public interface QueueSender extends MessageProducer { public Queue getqueue() throws JMSException; public void send(message message) throws JMSException; public void send(message message, int deliverymode, int priority, long timetolive) throws JMSException; public void send(queue queue, Message message) throws JMSException; public void send(queue queue, Message message, int deliverymode, int priority, long timetolive) throws JMSException; } public void close() throws JMSException TP1/Message Queue JMSException public int getdeliverymode() throws JMSException 330

353 7.MQC JMS MessageProducer QueueSender JMS JMSException DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT public boolean getdisablemessageid() throws JMSException TP1/Message Queue JMSException true false public boolean getdisablemessagetimestamp() throws JMSException TP1/Message Queue JMSException true false public int getpriority() throws JMSException JMS TP1/Message Queue 0 MaxPriority MaxPriority JMSException public long gettimetolive() throws JMSException JMSException 331

354 7.MQC JMS MessageProducer QueueSender JMS public void setdeliverymode(int deliverymode) throws JMSException DeliveryMode.PERSISTENT deliverymode DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT JMSException JMSException public void setdisablemessageid(boolean value) throws JMSException TP1/Message Queue value true false JMSException public void setdisablemessagetimestamp(boolean value) throws JMSException TP1/Message Queue value true false 332

355 7.MQC JMS MessageProducer QueueSender JMS JMSException public void setpriority(int defaultpriority) throws JMSException JMS TP1/Message Queue 0 MaxPriority MaxPriority 4 defaultpriority 0 9 JMSException JMSException public void settimetolive(long timetolive) throws JMSException 0 timetolive MQMD Expiry TP1/Message Queue MQEI_UNLIMITED JMSException JMSException public Queue getqueue() throws JMSException JMSException 333

356 7.MQC JMS MessageProducer QueueSender JMS Queue public void send(message message) throws JMSException QueueSender QueueSender JMSException Message JMS 7-6 MQMD 7-6 MQMD MessageFormatException Message 7-6 MQMD message JMSException MessageFormatException InvalidDestinationException QueueSender public void send(message message, int deliverymode, int priority, long timetolive) throws JMSException QueueSender JMSException Message JMS 7-6 MQMD 7-6 MQMD MessageFormatException Message 7-6 MQMD 334

357 7.MQC JMS MessageProducer QueueSender JMS message deliverymode DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT JMSException priority 0 9 JMSException timetolive MQMD Expiry TP1/Message Queue MQEI_UNLIMITED JMSException JMSException MessageFormatException InvalidDestinationException QueueSender public void send(queue queue, Message message) throws JMSException QueueSender QueueSender null QueueSender QueueSender QueueSender JMSException Message JMS

358 7.MQC JMS MessageProducer QueueSender JMS MQMD 7-6 MQMD MessageFormatException Message 7-6 MQMD queue message JMSException MessageFormatException InvalidDestinationException public void send(queue queue, Message message, int deliverymode, int priority, long timetolive) throws JMSException QueueSender null QueueSender QueueSender QueueSender JMSException Message JMS 7-6 MQMD 7-6 MQMD MessageFormatException Message 7-6 MQMD queue message 336

359 7.MQC JMS MessageProducer QueueSender JMS deliverymode DeliveryMode.NON_PERSISTENT DeliveryMode.PERSISTENT JMSException priority 0 9 JMSException timetolive MQMD Expiry TP1/Message Queue MQEI_UNLIMITED JMSException JMSException MessageFormatException InvalidDestinationException 337

360 7.MQC JMS QueueBrowser JMS QueueBrowser JMS QueueBrowser public interface QueueBrowser { public Queue getqueue() throws JMSException; public java.lang.string getmessageselector() throws JMSException; public java.util.enumeration getenumeration() throws JMSException; public void close() throws JMSException; } public Queue getqueue() throws JMSException JMSException Queue public java.lang.string getmessageselector() throws JMSException JMSException public java.util.enumeration getenumeration() throws JMSException JMSException public void close() throws JMSException TP1/Message Queue 338

361 7.MQC JMS QueueBrowser JMS JMSException 339

362 7.MQC JMS QueueConnection JMS QueueConnection JMS QueueConnection TP1/Message Queue QueueConnectionFactory createqueueconnection QueueConnection QueueConnection QueueSession package:javax.jms public interface Connection { public void close() throws JMSException; public java.lang.string getclientid() throws JMSException; public ExceptionListener getexceptionlistener() throws JMSException; public ConnectionMetaData getmetadata() throws JMSException; public void setclientid(java.lang.string clientid) throws JMSException; public void setexceptionlistener(exceptionlistener listener) throws JMSException; public void start() throws JMSException; public void stop() throws JMSException; } public interface QueueConnection extends javax.jms.connection { public ConnectionConsumer createconnectionconsumer(queue queue, java.lang.string messageselector, ServerSessionPool sessionpool, int maxmessages) throws JMSException; public QueueSession createqueuesession(boolean transacted, int acknowledgemode) throws JMSException; } public void close() throws JMSException QueueConnection JMSException 340

363 7.MQC JMS QueueConnection JMS public java.lang.string getclientid() throws JMSException JMSException public ExceptionListener getexceptionlistener() throws JMSException JMSException public ConnectionMetaData getmetadata() throws JMSException ConnectionMetaData JMSExceptionQueueConnection ConnectionMetaData public void setclientid(java.lang.string clientid) throws JMSException clientid ID JMSException InvlidClientIDException IllegalStateException public void setexceptionlistener(exceptionlistener listener) throws JMSException listener ExceptionListener JMSException 341

364 7.MQC JMS QueueConnection JMS public void start() throws JMSException JMSException QueueConnection public void stop() throws JMSException QueueReciever QueueReciever receive JMSException QueueConnection public ConnectionConsumer createconnectionconsumer(queue queue, java.lang.string messageselector, ServerSessionPool sessionpool, int maxmessages) throws JMSException queue Queue messageselector null null sessionpool ServerSessionPool maxmessages ServerSession JMSException InvalidDestinationException InvalidSelectorException ConnectionConsumer 342

365 7.MQC JMS QueueConnection JMS public QueueSession createqueuesession(boolean transacted, int acknowledgemode) throws JMSException QueueSession acknowledgemode transacted OpenTP1 true false acknowledgemode QueueSession Session.AUTO_ACKNOWLEDGEAUTO_ACKNOWLEDGE Session.CLIENT_ACKNOWLEDGECLIENT_ACKNOWLEDGE Session.DUPS_OK_ACKNOWLEDGEDUPS_OK_ACKNOWLEDGE JMSExceptionQueueSession QueueConnection QueueSession 343

366 7.MQC JMS QueueConnectionFactory JMS QueueConnectionFactory JMS QueueConnectionFactory QueueConnection JNDI QueueConnectionFactory JNDI lookup QueueConnectionFactory QueueConnectionFactory QueueConnection package:javax.jms public interface QueueConnectionFactory extends ConnectionFactory, javax.resource.referenceable { public javax.jms.queueconnection createqueueconnection() throws JMSException; public javax.jms.queueconnection createqueueconnection(java.lang.string username, java.lang.string password) throws JMSException; } public javax.jms.queueconnection createqueueconnection() throws JMSException TP1/Message Queue QueueConnection JMSException JMSSecurityException QueueConnection public javax.jms.queueconnection createqueueconnection(java.lang.string username, java.lang.string password) throws JMSException TP1/Message Queue QueueConnection username 344

367 7.MQC JMS QueueConnectionFactory JMS password JMSException JMSSecurityException QueueConnection 345

368 7.MQC JMS QueueSession JMS QueueSession JMS QueueSession QueueConnection.createQueueSession transacted true QueueSession QueueConnection.createQueueSession acknowledge QueueSession BytesMessage Message QueueReceiver QueueBrowser QueueSender public interface Session extends java.lang.runnable { public static final int AUTO_ACKNOWLEDGE; public static final int CLIENT_ACKNOWLEDGE; public static final int DUPS_OK_ACKNOWLEDGE; public void close() throws JMSException; public void commit() throws JMSException; public BytesMessage createbytesmessage() throws JMSException; public MapMessage createmapmessage() throws JMSException; public Message createmessage() throws JMSException; public ObjectMessage createobjectmessage() throws JMSException; public ObjectMessage createobjectmessage (java.io.serializable object) throws JMSException; public StreamMessage createstreammessage() throws JMSException; public TextMessage createtextmessage() throws JMSException; public TextMessage createtextmessage(java.lang.string text) throws JMSException; public MessageListener getmessagelistener() throws JMSException; public boolean gettransacted() throws JMSException; public void recover() throws JMSException; public void rollback() throws JMSException; public void run(); public void setmessagelistener(messagelistener listener) throws JMSException; } public interface QueueSession extends Session { public QueueBrowser createbrowser(queue queue) throws JMSException; public QueueBrowser createbrowser(queue queue, java.lang.string messageselector) throws JMSException; 346

369 7.MQC JMS QueueSession JMS public Queue createqueue(java.lang.string queuename) throws JMSException; public QueueReceiver createreceiver(queue queue) throws JMSException; public QueueReceiver createreceiver(queue queue, java.lang.string messageselector) throws JMSException; public QueueSender createsender(queue queue) throws JMSException; public TemporaryQueue createtemporaryqueue() throws JMSException; } public static final int AUTO_ACKNOWLEDGE public static final int CLIENT_ACKNOWLEDGE public static final int DUPS_OK_ACKNOWLEDGE public void close() throws JMSException QueueSession JMSExceptionQueueSession public void commit() throws JMSException JMSException TransactionRolledBackException IllegalStateException QueueSession public BytesMessage createbytesmessage() throws JMSException BytesMessage JMSExceptionBytesMessage QueueSession BytesMessage 347

370 7.MQC JMS QueueSession JMS public MapMessage createmapmessage() throws JMSException JMSException public Message createmessage() throws JMSException Message JMSExceptionMessage QueueSession Message public ObjectMessage createobjectmessage() throws JMSException JMSException public ObjectMessage createobjectmessage(java.io.serializable object) throws JMSException JMSException public StreamMessage createstreammessage() throws JMSException JMSException public TextMessage createtextmessage() throws JMSException JMSException public TextMessage createtextmessage(java.lang.string text) throws JMSException JMSException 348

371 7.MQC JMS QueueSession JMS public MessageListener getmessagelistener() throws JMSException JMSException public boolean gettransacted() throws JMSException QueueSession JMSException QueueSession true false public void recover() throws JMSException JMSException IllegalStateException public void rollback() throws JMSException JMSException IllegalStateException QueueSession public void run() public void setmessagelistener(messagelistener listener) throws JMSException JMSException public QueueBrowser createbrowser(queue queue) throws JMSException 349

372 7.MQC JMS QueueSession JMS queue Queue TemporaryQueue QueueSession createtemporaryqueue TemporaryQueue JMSExceptionQueueSession InvalidDestinationException QueueBrowser public QueueBrowser createbrowser(queue queue, java.lang.string messageselector) throws JMSException queue Queue TemporaryQueue QueueSession createtemporaryqueue TemporaryQueue messageselector JMSExceptionQueueSession InvalidDestinationException InvalidSelectorException QueueBrowser public Queue createqueue(java.lang.string queuename) throws JMSException Queue JNDI queuename 350

373 7.MQC JMS QueueSession JMS JMSException public QueueReceiver createreceiver(queue queue) throws JMSException queue Queue TemporaryQueue QueueSession createtemporaryqueue TemporaryQueue JMSExceptionQueueSession InvalidDestinationException QueueReceiver public QueueReceiver createreceiver(queue queue, java.lang.string messageselector) throws JMSException queue Queue TemporaryQueue QueueSession createtemporaryqueue TemporaryQueue messageselector JMSExceptionQueueSession InvalidDestinationException InvalidSelectorException QueueReceiver public QueueSender createsender(queue queue) throws JMSException 351

374 7.MQC JMS QueueSession JMS queue Queue null TemporaryQueue QueueSession createtemporaryqueue TemporaryQueue JMSExceptionQueueSession InvalidDestinationException QueueSender public TemporaryQueue createtemporaryqueue() throws JMSException TemporaryQueue delete createtemporaryqueue QueueSession TemporaryQueue TP1/Message Queue - Access Properties ModelQueueName 2.2MQC TP1/Message Queue DefinitionType Cosminexus Component Container MQC createtemporaryqueue JMS* * JMSExceptionQueueSession 352

375 7.MQC JMS QueueSession JMS TemporaryQueue 353

376 7.MQC JMS TemporaryQueue JMS TemporaryQueue JMS TemporaryQueue QueueConnection Queue TemporaryQueue QueueConnection TemporaryQueue JMSReplyto TemporaryQueue getqueuename public interface TemporaryQueue extends Queue { public void delete() throws JMSException; } public void delete() throws JMSException JMSException JMSException 354

377 7.MQC JMS Enumeration J2SE Enumeration J2SE Enumeration public interface Enumeration { public boolean hasmoreelements(); public Object nextelement(); } public boolean hasmoreelements() nextelement QueueBrowser getenumeration Enumeration false KFCA31309-W false KFCA31307-W true false public Object nextelement() getenumeration nextelement NoSuchElementException QueueBrowser getenumeration Enumeration NoSuchElementException KFCA31310-W NoSuchElementException KFCA31307-W NoSuchElementException 355

378 7.MQC JMS MQC JMS MQC JMS TP1/Message Queue - Access JMS TP1/Message Queue MQC jp.co.hitachi.soft.mqadaptor jp.co.hitachi.soft.mqadaptor MQC import MQC classpath mqcadptdef.jar public final static int MQ_CLUSTER_NAME_LENGTH public final static int MQ_CORREL_ID_LENGTH public final static int MQ_CREATION_DATE_LENGTH public final static int MQ_CREATION_TIME_LENGTH public final static int MQ_FORMAT_LENGTH public final static int MQ_GROUP_ID_LENGTH public final static int MQ_MSG_ID_LENGTH public final static int MQ_PUT_TIME_LENGTH public final static int MQ_PUT_APPL_NAME_LENGTH public final static int MQ_PUT_DATE_LENGTH public final static int MQ_Q_MGR_NAME_LENGTH public final static int MQ_Q_NAME_LENGTH public final static int MQ_USER_ID_LENGTH public final static int MQAT_UNKNOWN public final static int MQAT_NO_CONTEXT public final static int MQAT_CICS 356

379 7.MQC JMS MQC JMS public final static int MQAT_MVS public final static int MQAT_IMS public final static int MQAT_OS2 public final static int MQAT_DOS public final static int MQAT_AIX public final static int MQAT_UNIX public final static int MQAT_QMGR public final static int MQAT_OS400 public final static int MQAT_WINDOWS public final static int MQAT_CICS_VSE public final static int MQAT_VMS public final static int MQAT_GUARDIAN public final static int MQAT_VOS public final static int MQAT_OPEN_TP1 public final static int MQAT_XDM public final static int MQAT_TMS_4V public final static int MQAT_DEFAULT public final static int MQAT_USER_FIRST public final static int MQAT_USER_LAST public final static int MQCCSI_EMBEDDED public final static int MQCCSI_DEFAULT public final static int MQCCSI_Q_MGR public final static int MQENC_NATIVE public final static int MQENC_INTEGER_MASK public final static int MQENC_DECIMAL_MASK public final static int MQENC_FLOAT_MASK public final static int MQENC_RESERVED_MASK public final static int MQENC_INTEGER_UNDEFINED 357

380 7.MQC JMS MQC JMS public final static int MQENC_INTEGER_NORMAL public final static int MQENC_INTEGER_REVERSED public final static int MQENC_DECIMAL_UNDEFINED public final static int MQENC_DECIMAL_NORMAL public final static int MQENC_DECIMAL_REVERSED public final static int MQENC_FLOAT_UNDEFINED public final static int MQENC_FLOAT_IEEE_NORMAL public final static int MQENC_FLOAT_IEEE_REVERSED public final static int MQENC_FLOAT_S390 public final static int MQFB_NONE public final static int MQFB_SYSTEM_FIRST public final static int MQFB_EXPIRATION public final static int MQFB_COA public final static int MQFB_COD public final static int MQFB_QUIT public final static int MQFB_APPL_CANNOT_BE_STARTED public final static int MQFB_TM_ERROR public final static int MQFB_APPL_TYPE_ERROR public final static int MQFB_STOPPED_BY_MSG_EXIT public final static int MQFB_XMIT_Q_MSG_ERROR public final static int MQFB_SYSTEM_LAST public final static int MQFB_APPL_FIRST public final static int MQFB_APPL_LAST public final static int MQFB_NOT_A_REPOSITORY_MSG public final static int MQFB_PAN public final static int MQFB_NAN public final static String MQFMT_NONE public final static String MQFMT_ADMIN public final static String MQFMT_DEAD_LETTER_HEADER 358

381 7.MQC JMS MQC JMS public final static String MQFMT_EVENT public final static String MQFMT_PCF public final static String MQFMT_STRING public final static String MQFMT_TRIGGER public final static String MQFMT_XMIT_Q_HEADER public final static String MQFMT_DIST_HEADER public final static String MQFMT_MD_EXTENSION public final static String MQFMT_REF_MSG_HEADER public final static byte[] MQGI_NONE public final static int MQMT_SYSTEM_FIRST public final static int MQMT_REQUEST public final static int MQMT_REPLY public final static int MQMT_DATAGRAM public final static int MQMT_REPORT public final static int MQMT_SYSTEM_LAST public final static int MQMT_APPL_FIRST public final static int MQMT_APPL_LAST public final static int MQRO_EXCEPTION public final static int MQRO_EXCEPTION_WITH_DATA public final static int MQRO_EXCEPTION_WITH_FULL_DATA public final static int MQRO_EXPIRATION public final static int MQRO_EXPIRATION_WITH_DATA public final static int MQRO_EXPIRATION_WITH_FULL_DATA public final static int MQRO_COA public final static int MQRO_COA_WITH_DATA public final static int MQRO_COA_WITH_FULL_DATA public final static int MQRO_COD public final static int MQRO_COD_WITH_DATA public final static int MQRO_COD_WITH_FULL_DATA 359

382 7.MQC JMS MQC JMS public final static int MQRO_COPY_MSG_ID_TO_CORREL_ID public final static int MQRO_PASS_CORREL_ID public final static int MQRO_NEW_MSG_ID public final static int MQRO_PASS_MSG_ID public final static int MQRO_DEAD_LETTER_Q public final static int MQRO_DISCARD_MSG public final static int MQRO_NONE public final static int MQRO_REJECT_UNSUP_MASK public final static int MQRO_ACCEPT_UNSUP_MASK public final static int MQRO_ACCEPT_UNSUP_IF_XMIT_MASK public final static int MQRO_PAN public final static int MQRO_NAN 360

383 7.MQC JMS JMS JMS JMS Cosminexus Component Container JMS TP1/Message Queue - Access examples jms SessionBean1 SessionBean2 2 SessionBean1 JMS SessionBean2 SessionBean1 JMS MQC JMS 361

384 7.MQC JMS JMS 7-4JMS Cosminexus Component Container J2EE MyServerJ2EE Display name 362