Apache Camel MQXAQueueConnectionFactory

Question

So gut, ich versuche, eine MQXAQueueConnectionFactory zu arbeiten, habe ich eine erweiterte Klasse von der JmsComponent erstellt, um Benutzernamen und Passwort beim Senden von Daten in die Warteschlange zu behandeln. Es geht/Put-Nachrichten in der Warteschlange, aber in meinem Fall habe ich einen Router testen Sie die XA wie

from("wmq:queue:incomingQueue") 
    .process(new Processor(){ 
    ... Thread.sleep(20000) 
    }) 
    .to("wmq:queue:outgoingQueue") 

während im Schlaf wird erstellt, ich habe die Queuemanager heruntergefahren. Aber beim Versuch, nicht committed Nachrichten aus der Warteschlange DISPLAY QSTATUS ('qChainQueue') bekomme ich CURDEPTH (0), während es sollte 1 sein, wie ich den XA-Teil verstehe.

• Mache ich das total falsch?
• Wie kann es getestet werden?

HelpClass WMQ zu handhaben:

public class WMQComponent extends JmsComponent { 
    private final String username; 
    private final String password; 

    public WMQComponent(String hostname, int port, String username, String password, 
         String queueManager, String channel) throws JMSException { 
     super(); 
     this.username = username; 
     this.password = password; 

     MQXAQueueConnectionFactory connectionFactory = new MQXAQueueConnectionFactory(); 
     connectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP); 
     connectionFactory.setFailIfQuiesce(1); 

     connectionFactory.setHostName(hostname); 
     connectionFactory.setPort(port); 
     connectionFactory.setQueueManager(queueManager); 
     connectionFactory.setChannel(channel); 

     setConnectionFactory(connectionFactory); 
    } 

    @Override 
    public Endpoint createEndpoint(String uri) throws Exception { 
     if (uri.contains("username") || uri.contains("password")) { 
      throw new IllegalStateException("Username and password is set by the component"); 
     } 
     if (uri.contains("?")) { 
      return super.createEndpoint(uri + "&username=" + username + "&password=" + password); 
     } else { 
      return super.createEndpoint(uri + "?username=" + username + "&password=" + password); 
     } 
    } 

} 

Mit den folgenden Fehlern:

2015-03-25 14:01:12,077 [ #2 - Multicast] INFO dest_chain_ldap    - org.springframework.jms.IllegalStateException: JMSWMQ0018: Failed to connect to queue manager 'QMBATCHESB' with connection mode 'Client' and host name 'hostname.com'.; nested exception is com.ibm.msg.client.jms.DetailedIllegalStateException: JMSWMQ0018: Failed to connect to queue manager 'QMBATCHESB' with connection mode 'Client' and host name 'hostname.com'. Check the queue manager is started and if running in client mode, check there is a listener running. Please see the linked exception for more information.; nested exception is com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with compcode '2' ('MQCC_FAILED') reason '2059' ('MQRC_Q_MGR_NOT_AVAILABLE'). 
    at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:279) 
    at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469) 
    at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:228) 
    at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:431) 
    at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:385) 
    at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:153) 
    at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:120) 
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) 
    at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163) 
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:416) 
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) 
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) 
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) 
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) 
    at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51) 
    at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:120) 
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) 
    at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163) 
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) 
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:416) 
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) 
    at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105) 
    at org.apache.camel.processor.MulticastProcessor.doProcessParallel(MulticastProcessor.java:732) 
    at org.apache.camel.processor.MulticastProcessor.access$200(MulticastProcessor.java:82) 
    at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:303) 
    at org.apache.camel.processor.MulticastProcessor$1.call(MulticastProcessor.java:288) 
    at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) 
    at java.util.concurrent.FutureTask.run(FutureTask.java:166) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) 
    at java.lang.Thread.run(Thread.java:722) 
Caused by: com.ibm.msg.client.jms.DetailedIllegalStateException: JMSWMQ0018: Failed to connect to queue manager 'QMBATCHESB' with connection mode 'Client' and host name 'hostname.com'. Check the queue manager is started and if running in client mode, check there is a listener running. Please see the linked exception for more information. 
    at com.ibm.msg.client.wmq.common.internal.Reason.reasonToException(Reason.java:496) 
    at com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:236) 
    at com.ibm.msg.client.wmq.internal.WMQConnection.<init>(WMQConnection.java:430) 
    at com.ibm.msg.client.wmq.internal.WMQXAConnection.<init>(WMQXAConnection.java:70) 
    at com.ibm.msg.client.wmq.factories.WMQXAConnectionFactory.createV7ProviderConnection(WMQXAConnectionFactory.java:190) 
    at com.ibm.msg.client.wmq.factories.WMQConnectionFactory.createProviderConnection(WMQConnectionFactory.java:6210) 
    at com.ibm.msg.client.jms.admin.JmsConnectionFactoryImpl.createConnection(JmsConnectionFactoryImpl.java:278) 
    at com.ibm.mq.jms.MQConnectionFactory.createCommonConnection(MQConnectionFactory.java:6155) 
    at com.ibm.mq.jms.MQQueueConnectionFactory.createQueueConnection(MQQueueConnectionFactory.java:144) 
    at com.ibm.mq.jms.MQQueueConnectionFactory.createConnection(MQQueueConnectionFactory.java:223) 
    at org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.doCreateConnection(UserCredentialsConnectionFactoryAdapter.java:175) 
    at org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter.createConnection(UserCredentialsConnectionFactoryAdapter.java:150) 
    at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:184) 
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:456) 
    ... 29 more 
Caused by: com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with compcode '2' ('MQCC_FAILED') reason '2059' ('MQRC_Q_MGR_NOT_AVAILABLE'). 
    at com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:223) 
    ... 41 more 
Caused by: com.ibm.mq.jmqi.JmqiException: CC=2;RC=2059;AMQ9204: Connection to host 'hostname.com(1514)' rejected. [1=com.ibm.mq.jmqi.JmqiException[CC=2;RC=2059;AMQ9213: A communications error for occurred. [1=java.net.ConnectException[Connection refused: connect],3=hostname.com]],3=hostname.com(1514),5=RemoteTCPConnection.connnectUsingLocalAddress] 
    at com.ibm.mq.jmqi.remote.internal.RemoteFAP.jmqiConnect(RemoteFAP.java:1831) 
    at com.ibm.msg.client.wmq.internal.WMQConnection.<init>(WMQConnection.java:345) 
    ... 40 more 
Caused by: com.ibm.mq.jmqi.JmqiException: CC=2;RC=2059;AMQ9213: A communications error for occurred. [1=java.net.ConnectException[Connection refused: connect],3=hostname.com] 
    at com.ibm.mq.jmqi.remote.internal.RemoteTCPConnection.connnectUsingLocalAddress(RemoteTCPConnection.java:612) 
    at com.ibm.mq.jmqi.remote.internal.RemoteTCPConnection.protocolConnect(RemoteTCPConnection.java:940) 
    at com.ibm.mq.jmqi.remote.internal.system.RemoteConnection.connect(RemoteConnection.java:1097) 
    at com.ibm.mq.jmqi.remote.internal.system.RemoteConnectionPool.getConnection(RemoteConnectionPool.java:348) 
    at com.ibm.mq.jmqi.remote.internal.RemoteFAP.jmqiConnect(RemoteFAP.java:1503) 
    ... 41 more 
Caused by: java.net.ConnectException: Connection refused: connect 
    at java.net.DualStackPlainSocketImpl.connect0(Native Method) 
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:69) 
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339) 
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200) 
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182) 
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:157) 
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391) 
    at java.net.Socket.connect(Socket.java:579) 
    at java.net.Socket.connect(Socket.java:528) 
    at com.ibm.mq.jmqi.remote.internal.RemoteTCPConnection$2.run(RemoteTCPConnection.java:597) 
    at java.security.AccessController.doPrivileged(Native Method) 
    at com.ibm.mq.jmqi.remote.internal.RemoteTCPConnection.connnectUsingLocalAddress(RemoteTCPConnection.java:588) 
    ... 45 more 

Answer 1

Also ich hatte dies ein bisschen falsch gemacht, es war nicht genug, die MQXAConnectionFactory zu verwenden, aber ich musste die JmsComponent als transacted erstellen.

Ich habe versucht, den Warteschlangenmanager während der Ausführung der Anwendung zu stoppen und die Anwendung während der Verarbeitung einer Nachricht zu stoppen, und es scheint den Rollback wie erwartet auszuführen.

mit

public static JmsComponent mqXAComponentTransacted(String hostname, int port, String username, String password, 
          String queueManager, String channel) throws JMSException { 
    MQXAQueueConnectionFactory connectionFactory = new MQXAQueueConnectionFactory(); 
    connectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP); 
    connectionFactory.setFailIfQuiesce(1); 
    connectionFactory.setHostName(hostname); 
    connectionFactory.setPort(port); 
    connectionFactory.setQueueManager(queueManager); 
    connectionFactory.setChannel(channel); 

    UserCredentialsConnectionFactoryAdapter connectionFactoryAdapter=new UserCredentialsConnectionFactoryAdapter(); 
    connectionFactoryAdapter.setTargetConnectionFactory(connectionFactory); 
    connectionFactoryAdapter.setUsername(username); 
    connectionFactoryAdapter.setPassword(password); 

    return JmsComponent.jmsComponentTransacted(connectionFactoryAdapter); 
} 

Auch mit dem UserCredentialsConnectionFactoryAdapter Ended up, wollte ich nicht Frühling Komponenten verwenden, aber da das Jms Paket bereits abhängig ist, war es einfacher, es als meine bisherige Lösung zu verwenden, um Handle Anmeldedaten.

Answer 2

Der Grund Code 2059 und unter Angabe verschiedene Fehler, dass die Verbindung vorschlägt entweder verweigert wurde ein mechanisches Problem (dh kein Listener läuft) oder ein auths-Problem.

Wenn ich versuchte, dies zu debuggen, würde ich als Erstes Autorisierungsereignisse, Channel-Ereignisse und alle anderen aktivieren, die Sie normalerweise aktivieren würden. Wenn Sie MQ Explorer verwenden, installieren Sie auch MS0P Plugin, mit dem Sie die Ereignisnachrichten in lesbarem Text anzeigen können.

Als nächstes würde ich die MQ-Beispielprogramme zum Testen verwenden. Da ich immer den vollen Client installiere, anstatt die JAR-Dateien zu greifen, habe ich amqsputc zur Verfügung. Die Java-Klassen verfügen jedoch über IVT-Programme (Initial Verification Test). Diese stellen sicher, dass der Listener läuft, der Kanal konfiguriert und verfügbar ist usw. Ab Version 7.1 stellt dies auch sicher, dass die CHLAUTH Regeln den Zugriff erlauben. Ab Version 8.0 oder wenn Sie den Capitalware-Exit installiert hatten, können Sie auch die Benutzer-ID und die Passwort-Authentifizierung testen.

Das Fehlerprotokoll des Warteschlangenmanagers und die Ereignismeldungen sollten eine gute Diagnose bieten, vorausgesetzt, die Verbindungsanforderung führt zu MQ. Stellen Sie sicher, dass Sie sowohl in den QMgr-spezifischen Fehlerprotokollen als auch in den Installations-globalen Fehlerprotokollen nachsehen.

Sobald ich bestätigt hatte, dass grundlegende Konnektivität vorhanden ist, würde ich meine clientseitige Konfigurationsparameter für Host, Port, Kanal und wenn es angegeben wird [schaudern!] Den QMgr-Namen. Unter der Annahme, dass diese korrekt sind und die grundlegenden Konnektivitätsfunktionen funktionieren, ist es nun möglich, die App mit einiger Sicherheit zu testen.

Die gleiche Methode gilt. Stellen Sie zuerst sicher, dass die Verbindungsanfrage der App zum QMgr führt. Wenn dies der Fall ist und verweigert wird, werden die Ereignismeldungen und Fehlerprotokolle dies und warum notieren. Wenn an diesen Stellen kein Hinweis auf einen Fehler angezeigt wird, gelangt die App nicht zum QMgr. Der 2059 kann anzeigen, dass der Socket abgelehnt wurde, dass der Listener hochgefahren ist, aber der QMgr nicht, dass die Kanalinstanzen ausgereizt sind oder dass nach dem vorläufigen Start des Channels der QMgr geschlossen wurde, oft aufgrund einer CHLAUTH Regel. In jedem Fall werden die Ereignismeldungen und Fehlerprotokolle ausführlich erläutert.