| Author |
Message
|
| legux |
 Posted: Mon Dec 05, 2005 6:13 am Post subject: Problems accessing a Cluster using jms |
 |
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
Hi!
I set up a cluster on a Windows XP System.
I have got two full repositories: CLUSTER1 and CLUSTER2.
CLUSTER1 defines a local queue CLUSTERQ1, and CLUSTER2 defines a local queue CLUSTERQ2.
Both queues set to Binding mode NOT FIXED.
Then I have on every queue manager a sender and receiver channel. this was installed by mq-explorer.
Now i want to fill the queues with messages.
On the same system runs jboss 4.0.3.
To connect the cluster i think i have to create a serverconnection. So i created in QM CLUSTER1 a svrconn-channel CHL.CLUSTER1.
When jboss is starting, it should initialize the connections.
I initialize a qcf, where i transmit the port, queueManager, and serverconnection-channel. In this case i don't left the queueManagerName blank.
and then i initialize the mqdestination. in this case the queueManagerName is left blank (((MQQueue) destination).setBaseQueueManagerName("")).
when trying to initialize the queue jboss throws the following exception:
javax.jms.JMSException: MQJMS2008: Fehler beim Öffnen der MQ-Warteschlang CLUSTERQ2
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:586)
at com.ibm.mq.jms.MQQueueAgent.resolveQueue(MQQueueAgent.java:502)
at com.ibm.mq.jms.MQQueueAgent.getQueueAgent(MQQueueAgent.java:302)
at com.ibm.mq.jms.MQConnectionBrowser.MQConnectionBrowserInit(MQConnectionBrowser.java:325)
Can you help me with my problem. Can you find any errors in my code?
regards,
steffen
The following code initializes the queueConnectionFactory
MQConnectionFactory connectionFactory = null;
connectionFactory = new MQTopicConnectionFactory();
connectionFactory = new MQQueueConnectionFactory();
connectionFactory.setHostName(hostName);
connectionFactory.setPort(port);
connectionFactory.setChannel(channel);
connectionFactory.setQueueManager(queueManagerName);
connectionFactory.setTransportType(transportType);
connectionFactory.setFailIfQuiesce(failIfQuiesce);
connectionFactory.setUseConnectionPooling(true);
The following xml-code represents the parameter for qcf:
<mbean code="jms.wsmq.WsMqConnectionFactory" name="jms.test.app:service=TestQueueConnectionFactory">
<depends>jboss:service=Naming</depends>
<attribute name="JndiName">java:/jms/test/app/TestQueueConnectionFactory</attribute>
<attribute name="JmsStyle">Queue</attribute>
<attribute name="Transactional">false</attribute>
<attribute name="CcsidId">UTF8</attribute>
<attribute name="Channel">TO.CLUSTER1</attribute>
<attribute name="FailIfQuiesceId">MQJMS_FIQ_YES</attribute>
<attribute name="HostName">localhost</attribute>
<attribute name="Port">1460</attribute>
<attribute name="QueueManagerName">CLUSTER1</attribute>
<attribute name="TransportTypeId">MQJMS_TP_CLIENT_MQ_TCPIP</attribute>
</mbean>
The following code initializes the MQDestination:
MQDestination destination = null;
destination = new MQQueue();
if (queueManagerName == null){
((MQQueue) destination).setBaseQueueManagerName("");
} else{
((MQQueue) destination).setBaseQueueManagerName(queueManagerName);
}
((MQQueue) destination).setBaseQueueName(destinationName);
destination.setCCSID(ccsid);
destination.setDescription(description);
destination.setEncoding(encoding);
destination.setExpiry(expiry);
destination.setFailIfQuiesce(failIfQuiesce);
destination.setPersistence(persistence);
destination.setPriority(priority);
destination.setTargetClient(targetClient);
The following xml-code represents the parameter for queue:
<mbean code="jms.wsmq.WsMqDestination" name="jms.test.app:service=TestQueue">
<depends>jboss:service=Naming</depends>
<attribute name="JndiName">java:/jms/test/app/TestQueue</attribute>
<attribute name="JmsStyle">Queue</attribute>
<attribute name="Transactional">false</attribute>
<attribute name="CcsidId">UTF8</attribute>
<attribute name="Description">Test-Warteschlange</attribute>
<attribute name="DestinationName">CLUSTERQ2</attribute>
<attribute name="EncodingId">MQJMS_ENCODING_NATIVE</attribute>
<attribute name="ExpiryId">MQJMS_EXP_APP</attribute>
<attribute name="PersistenceId">MQJMS_PER_PER</attribute>
<attribute name="PriorityId">MQJMS_PRI_APP</attribute>
<attribute name="QueueManagerName"></attribute> <!-- left blank -->
<attribute name="TargetClientId">MQJMS_CLIENT_JMS_COMPLIANT</attribute>
<attribute name="FailIfQuiesceId">MQJMS_FIQ_YES</attribute>
</mbean> |
|
| Back to top |
|
 |
| Mr Butcher |
| Posted: Mon Dec 05, 2005 7:23 am Post subject: |
|
|
Padawan
Joined: 23 May 2005
Posts: 1716
|
| Quote: |
I have got two full repositories: CLUSTER1 and CLUSTER2.
CLUSTER1 defines a local queue CLUSTERQ1, and CLUSTER2 defines a local queue CLUSTERQ2.
Both queues set to Binding mode NOT FIXED.
Then I have on every queue manager a sender and receiver channel. this was installed by mq-explorer. |
are you sure your cluster is set up properly? did you set up sender and receiver channels or did you set up cluster sender and cluster receiver channels?
please use runmqsc on CLUSTER1 and show a
DIS QMGR ALL
DIS CLUSQMGR(*) ALL
DIS CHANNEL(*) ALL
DIS QCLUSTER(*) ALL
_________________
Regards, Butcher |
|
| Back to top |
|
|
| legux |
| Posted: Mon Dec 05, 2005 7:37 am Post subject: |
|
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
Hi.
I'm not sure, but i have done this with mq-explorer. so i thought it was right.
I set up cluster sender and cluster receiver channels.
here are my results, hope it will help.
:
dis qcluster(*) all
4 : dis qcluster(*) all
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ1) TYPE(QCLUSTER)
ALTDATE(2005-12-05) ALTTIME(16.33.36)
CLUSDATE(2005-11-25) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER1) CLUSQT(QLOCAL)
CLUSTIME(09.47.45) CLWLPRTY(0)
CLWLRANK(0) DEFBIND(NOTFIXED)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER1_2005-11-25_09.22.47)
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ2) TYPE(QCLUSTER)
ALTDATE(2005-11-2 ALTTIME(16.05.40)
CLUSDATE(2005-12-05) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER2) CLUSQT(QLOCAL)
CLUSTIME(10.37.4 CLWLPRTY(0)
CLWLRANK(0) DEFBIND(NOTFIXED)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER2_2005-11-25_09.25.5
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ3) TYPE(QCLUSTER)
ALTDATE(2005-11-25) ALTTIME(13.59.54)
CLUSDATE(2005-12-05) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER3) CLUSQT(QLOCAL)
CLUSTIME(10.37.54) CLWLPRTY(0)
CLWLRANK(0) DEFBIND(OPEN)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER3_2005-11-25_12.32.36)
thanks,
steffen |
|
| Back to top |
|
|
| legux |
| Posted: Mon Dec 05, 2005 10:44 pm Post subject: |
|
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
sorry, here are the whole results:
DIS QMGR all
1 : DIS QMGR all
AMQ8408: Details zu DISPLAY QMGR werden angezeigt.
QMNAME(CLUSTER1) ACCTCONO(DISABLED)
ACCTINT(1800) ACCTMQI(OFF)
ACCTQ(OFF) ACTIVREC(MSG)
ALTDATE(2005-11-28) ALTTIME(10.20.32)
AUTHOREV(DISABLED) CCSID(850)
CHAD(DISABLED) CHADEV(DISABLED)
CHADEXIT( ) CHLEV(DISABLED)
CLWLDATA( ) CLWLEXIT( )
CLWLLEN(100) CLWLMRUC(999999999)
CLWLUSEQ(LOCAL) CMDLEVEL(600)
COMMANDQ(SYSTEM.ADMIN.COMMAND.QUEUE) CRDATE(2005-11-25)
CRTIME(09.22.47) DEADQ( )
DEFXMITQ( ) DESCR( )
DISTL(YES) INHIBTEV(DISABLED)
IPADDRV(IPV4) LOCALEV(DISABLED)
LOGGEREV(DISABLED) MAXHANDS(256)
MAXMSGL(25194304) MAXPRTY(9)
MAXUMSGS(10000) MONACLS(QMGR)
MONCHL(OFF) MONQ(OFF)
PERFMEV(DISABLED) PLATFORM(WINDOWSNT)
QMID(CLUSTER1_2005-11-25_09.22.47) REMOTEEV(DISABLED)
REPOS(MDATA.CLUSTER.TEST) REPOSNL( )
ROUTEREC(MSG) SCHINIT(QMGR)
SCMDSERV(QMGR) SSLCRLNL( )
SSLCRYP( ) SSLEV(DISABLED)
SSLFIPS(NO)
SSLKEYR(c:\Programme\IBM\WebSphere MQ\qmgrs\CLUSTER1\ssl\key)
SSLRKEYC(0) STATACLS(QMGR)
STATCHL(OFF) STATINT(1800)
STATMQI(OFF) STATQ(OFF)
STRSTPEV(ENABLED) SYNCPT
TRIGINT(999999999)
dis clusqmgr(*) all
2 : dis clusqmgr(*) all
AMQ8441: Einzelheiten zu Cluster-WS-Manager anzeigen.
CLUSQMGR(CLUSTER1) ALTDATE( )
ALTTIME( ) BATCHHB(0)
BATCHINT(0) BATCHSZ(50)
CHANNEL(TO.CLUSTER1) CLUSDATE(2005-11-25)
CLUSTER(MDATA.CLUSTER.TEST) CLUSTIME(09.43.44)
CLWLPRTY(0) CLWLRANK(0)
CLWLWGHT(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME(localhost(1460))
CONVERT(NO) DEFTYPE(CLUSRCVR)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(25194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MRDATA( ) MREXIT( )
MRRTY(10) MRTMR(1000)
MSGDATA( )
MSGEXIT( ) NETPRTY(0)
NPMSPEED(FAST) PASSWORD( )
PUTAUT(DEF) QMID(CLUSTER1_2005-11-25_09.22.47)
QMTYPE(REPOS)
RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( )
SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SHORTRTY(10) SHORTTMR(60)
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) STATUS(INACTIVE)
SUSPEND(NO) TPNAME( )
TRPTYPE(TCP) USERID( )
AMQ8441: Einzelheiten zu Cluster-WS-Manager anzeigen.
CLUSQMGR(CLUSTER2) ALTDATE( )
ALTTIME( ) BATCHHB(0)
BATCHINT(0) BATCHSZ(50)
CHANNEL(TO.CLUSTER2) CLUSDATE(2005-12-05)
CLUSTER(MDATA.CLUSTER.TEST) CLUSTIME(10.37.47)
CLWLPRTY(0) CLWLRANK(0)
CLWLWGHT(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME(localhost(1461))
CONVERT(NO) DEFTYPE(CLUSSDRB)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(25194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MRDATA( ) MREXIT( )
MRRTY(10) MRTMR(1000)
MSGDATA( ) MSGEXIT( )
NETPRTY(0) NPMSPEED(FAST)
PASSWORD( ) PUTAUT(DEF)
QMID(CLUSTER2_2005-11-25_09.25.58) QMTYPE(REPOS)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCAUTH(REQUIRED)
SSLCIPH( ) SSLPEER( )
STATUS(RUNNING) SUSPEND(NO)
TPNAME( ) TRPTYPE(TCP)
USERID( )
AMQ8441: Einzelheiten zu Cluster-WS-Manager anzeigen.
CLUSQMGR(CLUSTER3) ALTDATE( )
ALTTIME( ) BATCHHB(0)
BATCHINT(0) BATCHSZ(50)
CHANNEL(TO.CLUSTER3) CLUSDATE(2005-12-05)
CLUSTER(MDATA.CLUSTER.TEST) CLUSTIME(10.37.54)
CLWLPRTY(0) CLWLRANK(0)
CLWLWGHT(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME(localhost(1462))
CONVERT(NO) DEFTYPE(CLUSSDRA)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(4194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MRDATA( ) MREXIT( )
MRRTY(10) MRTMR(1000)
MSGDATA( ) MSGEXIT( )
NETPRTY(0) NPMSPEED(FAST)
PASSWORD( ) PUTAUT(DEF)
QMID(CLUSTER3_2005-11-25_12.32.36) QMTYPE(NORMAL)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCAUTH(REQUIRED)
SSLCIPH( ) SSLPEER( )
STATUS(INACTIVE) SUSPEND(NO)
TPNAME( ) TRPTYPE(TCP)
USERID( )
dis channel(*) all
3 : dis channel(*) all
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(CHL.CLUSTER1) CHLTYPE(SVRCONN)
ALTDATE(2005-11-28) ALTTIME(10.18.15)
COMPHDR(NONE) COMPMSG(NONE)
DESCR( ) HBINT(300)
KAINT(AUTO) MAXMSGL(25194304)
MCAUSER( ) MONCHL(QMGR)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.ADMIN.SVRCONN) CHLTYPE(SVRCONN)
ALTDATE(2005-11-25) ALTTIME(09.23.14)
COMPHDR(NONE) COMPMSG(NONE)
DESCR( ) HBINT(300)
KAINT(AUTO) MAXMSGL(4194304)
MCAUSER( ) MONCHL(QMGR)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.AUTO.RECEIVER) CHLTYPE(RCVR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHSZ(50) COMPHDR(NONE)
COMPMSG(NONE) DESCR(Auto-defined by)
HBINT(300) KAINT(AUTO)
MAXMSGL(4194304) MCAUSER( )
MONCHL(QMGR) MRDATA( )
MREXIT( ) MRRTY(10)
MRTMR(1000) MSGDATA( )
MSGEXIT( ) NPMSPEED(FAST)
PUTAUT(DEF) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) STATCHL(QMGR)
TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.AUTO.SVRCONN) CHLTYPE(SVRCONN)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
COMPHDR(NONE) COMPMSG(NONE)
DESCR(Auto-defined by) HBINT(300)
KAINT(AUTO) MAXMSGL(4194304)
MCAUSER( ) MONCHL(QMGR)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.CLUSRCVR) CHLTYPE(CLUSRCVR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) CLUSNL( )
CLUSTER( ) CLWLPRTY(0)
CLWLRANK(0) CLWLWGHT(50)
COMPHDR(NONE) COMPMSG(NONE)
CONNAME( ) CONVERT(NO)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(4194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MONCHL(QMGR) MRDATA( )
MREXIT( ) MRRTY(10)
MRTMR(1000) MSGDATA( )
MSGEXIT( ) NETPRTY(0)
NPMSPEED(FAST) PUTAUT(DEF)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCAUTH(REQUIRED)
SSLCIPH( ) SSLPEER( )
STATCHL(QMGR) TPNAME( )
TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.CLUSSDR) CHLTYPE(CLUSSDR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) CLUSNL( )
CLUSTER( ) CLWLPRTY(0)
CLWLRANK(0) CLWLWGHT(50)
COMPHDR(NONE) COMPMSG(NONE)
CONNAME( ) CONVERT(NO)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(4194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MONCHL(QMGR) MSGDATA( )
MSGEXIT( ) NPMSPEED(FAST)
PASSWORD( ) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SHORTRTY(10) SHORTTMR(60)
SSLCIPH( ) SSLPEER( )
STATCHL(QMGR) TPNAME( )
TRPTYPE(TCP) USERID( )
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.RECEIVER) CHLTYPE(RCVR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHSZ(50) COMPHDR(NONE)
COMPMSG(NONE) DESCR( )
HBINT(300) KAINT(AUTO)
MAXMSGL(4194304) MCAUSER( )
MONCHL(QMGR) MRDATA( )
MREXIT( ) MRRTY(10)
MRTMR(1000) MSGDATA( )
MSGEXIT( ) NPMSPEED(FAST)
PUTAUT(DEF) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) STATCHL(QMGR)
TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.REQUESTER) CHLTYPE(RQSTR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHSZ(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME( )
DESCR( ) HBINT(300)
KAINT(AUTO) LOCLADDR( )
MAXMSGL(4194304) MCANAME( )
MCATYPE(PROCESS) MCAUSER( )
MODENAME( ) MONCHL(QMGR)
MRDATA( ) MREXIT( )
MRRTY(10) MRTMR(1000)
MSGDATA( ) MSGEXIT( )
NPMSPEED(FAST) PASSWORD( )
PUTAUT(DEF) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) STATCHL(QMGR)
TPNAME( ) TRPTYPE(TCP)
USERID( )
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.SENDER) CHLTYPE(SDR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME( )
CONVERT(NO) DESCR( )
DISCINT(6000) HBINT(300)
KAINT(AUTO) LOCLADDR( )
LONGRTY(999999999) LONGTMR(1200)
MAXMSGL(4194304) MCANAME( )
MCATYPE(PROCESS) MCAUSER( )
MODENAME( ) MONCHL(QMGR)
MSGDATA( ) MSGEXIT( )
NPMSPEED(FAST) PASSWORD( )
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCIPH( )
SSLPEER( ) STATCHL(QMGR)
TPNAME( ) TRPTYPE(TCP)
USERID( ) XMITQ( )
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.SERVER) CHLTYPE(SVR)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) COMPHDR(NONE)
COMPMSG(NONE) CONNAME( )
CONVERT(NO) DESCR( )
DISCINT(6000) HBINT(300)
KAINT(AUTO) LOCLADDR( )
LONGRTY(999999999) LONGTMR(1200)
MAXMSGL(4194304) MCANAME( )
MCATYPE(PROCESS) MCAUSER( )
MODENAME( ) MONCHL(QMGR)
MSGDATA( ) MSGEXIT( )
NPMSPEED(FAST) PASSWORD( )
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCAUTH(REQUIRED)
SSLCIPH( ) SSLPEER( )
STATCHL(QMGR) TPNAME( )
TRPTYPE(TCP) USERID( )
XMITQ( )
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.SVRCONN) CHLTYPE(SVRCONN)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
COMPHDR(NONE) COMPMSG(NONE)
DESCR( ) HBINT(300)
KAINT(AUTO) MAXMSGL(4194304)
MCAUSER( ) MONCHL(QMGR)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SSLCAUTH(REQUIRED) SSLCIPH( )
SSLPEER( ) TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(TO.CLUSTER1) CHLTYPE(CLUSRCVR)
ALTDATE(2005-11-28) ALTTIME(10.18.27)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) CLUSNL( )
CLUSTER(MDATA.CLUSTER.TEST) CLWLPRTY(0)
CLWLRANK(0) CLWLWGHT(50)
COMPHDR(NONE) COMPMSG(NONE)
CONNAME(localhost(1460)) CONVERT(NO)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(25194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MONCHL(QMGR) MRDATA( )
MREXIT( ) MRRTY(10)
MRTMR(1000) MSGDATA( )
MSGEXIT( ) NETPRTY(0)
NPMSPEED(FAST) PUTAUT(DEF)
RCVDATA( ) RCVEXIT( )
SCYDATA( ) SCYEXIT( )
SENDDATA( ) SENDEXIT( )
SEQWRAP(999999999) SHORTRTY(10)
SHORTTMR(60) SSLCAUTH(REQUIRED)
SSLCIPH( ) SSLPEER( )
STATCHL(QMGR) TPNAME( )
TRPTYPE(TCP)
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(TO.CLUSTER2) CHLTYPE(CLUSSDR)
ALTDATE(2005-11-28) ALTTIME(10.18.39)
BATCHHB(0) BATCHINT(0)
BATCHSZ(50) CLUSNL( )
CLUSTER(MDATA.CLUSTER.TEST) CLWLPRTY(0)
CLWLRANK(0) CLWLWGHT(50)
COMPHDR(NONE) COMPMSG(NONE)
CONNAME(localhost(1461)) CONVERT(NO)
DESCR( ) DISCINT(6000)
HBINT(300) KAINT(AUTO)
LOCLADDR( ) LONGRTY(999999999)
LONGTMR(1200) MAXMSGL(25194304)
MCANAME( ) MCATYPE(THREAD)
MCAUSER( ) MODENAME( )
MONCHL(QMGR) MSGDATA( )
MSGEXIT( ) NPMSPEED(FAST)
PASSWORD( ) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SEQWRAP(999999999)
SHORTRTY(10) SHORTTMR(60)
SSLCIPH( ) SSLPEER( )
STATCHL(QMGR) TPNAME( )
TRPTYPE(TCP) USERID( )
AMQ8414: Details zu DISPLAY CHL werden angezeigt.
CHANNEL(SYSTEM.DEF.CLNTCONN) CHLTYPE(CLNTCONN)
ALTDATE(2005-11-25) ALTTIME(09.22.55)
COMPHDR(NONE) COMPMSG(NONE)
CONNAME( ) DESCR( )
HBINT(300) KAINT(AUTO)
LOCLADDR( ) MAXMSGL(4194304)
MODENAME( ) PASSWORD( )
QMNAME( ) RCVDATA( )
RCVEXIT( ) SCYDATA( )
SCYEXIT( ) SENDDATA( )
SENDEXIT( ) SSLCIPH( )
SSLPEER( ) TPNAME( )
TRPTYPE(TCP) USERID( )
:
dis qcluster(*) all
4 : dis qcluster(*) all
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ1) TYPE(QCLUSTER)
ALTDATE(2005-12-05) ALTTIME(16.33.36)
CLUSDATE(2005-11-25) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER1) CLUSQT(QLOCAL)
CLUSTIME(09.47.45) CLWLPRTY(0)
CLWLRANK(0) DEFBIND(NOTFIXED)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER1_2005-11-25_09.22.47)
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ2) TYPE(QCLUSTER)
ALTDATE(2005-11-28) ALTTIME(16.05.40)
CLUSDATE(2005-12-05) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER2) CLUSQT(QLOCAL)
CLUSTIME(10.37.48) CLWLPRTY(0)
CLWLRANK(0) DEFBIND(NOTFIXED)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER2_2005-11-25_09.25.58)
AMQ8409: Warteschlangendetails werden angezeigt.
QUEUE(CLUSTERQ3) TYPE(QCLUSTER)
ALTDATE(2005-11-25) ALTTIME(13.59.54)
CLUSDATE(2005-12-05) CLUSTER(MDATA.CLUSTER.TEST)
CLUSQMGR(CLUSTER3) CLUSQT(QLOCAL)
CLUSTIME(10.37.54) CLWLPRTY(0)
CLWLRANK(0) DEFBIND(OPEN)
DEFPRTY(0) DEFPSIST(NO)
DESCR( ) PUT(ENABLED)
QMID(CLUSTER3_2005-11-25_12.32.36)
Last edited by legux on Tue Dec 06, 2005 12:26 am; edited 1 time in total |
|
| Back to top |
|
|
| Mr Butcher |
| Posted: Mon Dec 05, 2005 11:37 pm Post subject: |
|
|
Padawan
Joined: 23 May 2005
Posts: 1716
|
well, the cluster looks fine. you may verify it using the amqsput or amqsputc programs that come with mqseries to make sure it is working properly.
I do not know much about java programming so i can not verify your code. is there any 2xxx returncode you get when you try to run your program?
_________________
Regards, Butcher |
|
| Back to top |
|
|
| legux |
| Posted: Mon Dec 05, 2005 11:49 pm Post subject: |
|
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
In my java-programm i get a return code mqjms2008, which means failed to opened queue CLUSTERQ2.
When i call amqsput CLUSTERQ2, which is a queue name inside the cluster i get the return code 2059.
When i call amqsputc CLUSTERQ2 i get the return code 2058.
In both cases, i am not able to send data to the queue.
regards,
steffen |
|
| Back to top |
|
|
| Mr Butcher |
| Posted: Tue Dec 06, 2005 12:18 am Post subject: |
|
|
Padawan
Joined: 23 May 2005
Posts: 1716
|
if you are local on the machine and you want to connect to queuemanager CLUSTER1 and want to put to queue CLUSTERQ2 then specify queuename and queuemanagername like
amqsput CLUSTERQ2 CLUSTER1
for amqsputc, you have to specify the mqserver variable, e.g.
set MQSERVER=CHL.CLUSTER1/tcp/localhost(1460)
amqsputc CLUSTERQ2 CLUSTER1
i know see that you specified channel TO.CLUSTER1 in the attributes of the connection factory,this will not work because this is a cluster receiver channel and not a SVRCONN channel, so maybe you should change this to the SVRCONN channel CHL.CLUSTER1 that you created and try again.
_________________
Regards, Butcher |
|
| Back to top |
|
|
| legux |
| Posted: Tue Dec 06, 2005 12:36 am Post subject: |
|
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
this was my fault.
i tried it also with chl.cluster1 but it has the same effect.
the command amqsput CLUSTERQ2 CLUSTER1 works.
so i think the error must be in the java part.
Can anyone help me?
thanks,
steffen |
|
| Back to top |
|
|
| fjb_saper |
| Posted: Tue Dec 06, 2005 8:55 pm Post subject: |
|
|
Grand High Poobah
Joined: 18 Nov 2003
Posts: 20756
Location: LI,NY
|
Read the communications manual part about qmgr aliases.
Specifically in JMS you may have to use a qmgr alias that resolves to the cluster.
Enjoy |
|
| Back to top |
|
|
| legux |
| Posted: Thu Dec 08, 2005 12:44 pm Post subject: Solved Problem |
|
|
Novice
Joined: 14 Nov 2005
Posts: 18
|
Hi.
Thanks for all your help.
There was no mistake, the error only appears, when the mdb tries to receive the queue CLUSTERQ2 when connected to CLUSTER1. => This is not local, so it fails.
thanks,
steffen |
|
| Back to top |
|
|
| jefflowrey |
| Posted: Thu Dec 08, 2005 1:37 pm Post subject: Re: Solved Problem |
|
|
Grand Poobah
Joined: 16 Oct 2002
Posts: 19981
|
| legux wrote: |
| There was no mistake, the error only appears, when the mdb tries to receive the queue CLUSTERQ2 when connected to CLUSTER1. => This is not local, so it fails. |
I hope you know why, that the MDB is attempting to execute an MQGET against a remote queue, and that this is not at all possible in MQ.
_________________
I am *not* the model of the modern major general. |
|
| Back to top |
|
|
|
|
