[mule-user] failed to create a temporary queue from SYSTEM.DEFAULT.MODEL.QUEUE
Ryan J. R
hi experts,
i get the following exception when i try to write data into the queue
when using mule. But if i run from the java application it works fine. I am
trying to connect MQ Over an SSL.
Please help me out with this.
2009-11-02 07:21:41,383 [jmsConnector.dispatcher.1] ERROR
[org.mule.DefaultExceptionStrategy] - Caught exception in Exception
Strategy: MQJMS3000: failed to create a temporary queue from
SYSTEM.DEFAULT.MODEL.QUEUE
javax.jms.JMSException: MQJMS3000: failed to create a temporary queue from
SYSTEM.DEFAULT.MODEL.QUEUE
at
com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:586)
at
com.ibm.mq.jms.MQConnection.createTemporaryQueue(MQConnection.java:2509)
at
com.ibm.mq.jms.MQSession.createTemporaryQueue(MQSession.java:4592)
at
com.ibm.mq.jms.MQQueueSession.createTemporaryQueue(MQQueueSession.java:290)
at
org.mule.transport.jms.Jms11Support.createTemporaryDestination(Jms11Support.java:247)
at
org.mule.transport.jms.JmsMessageDispatcher.getReplyToDestination(JmsMessageDispatcher.java:483)
at
org.mule.transport.jms.JmsMessageDispatcher.dispatchMessage(JmsMessageDispatcher.java:171)
at
org.mule.transport.jms.JmsMessageDispatcher.doDispatch(JmsMessageDispatcher.java:73)
at
org.mule.transport.AbstractMessageDispatcher$Worker.run(AbstractMessageDispatcher.java:262)
at org.mule.work.WorkerContext.run(WorkerContext.java:310)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1061)
at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:575)
at java.lang.Thread.run(Thread.java:619)
--
View this message in context: http://old.nabble.com/failed-to-create-a-temporary-queue-from-SYSTEM.DEFAULT.MODEL.QUEUE-tp26156698p26156698.html
Sent from the Mule - User mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe from this list, please visit:
http://xircles.codehaus.org/manage_email
Richard Swart
I assume you are now accessing MQ using a different user than without SSL. Correct?
P.S. If you have the complete SSL setup working please post the config to share with the community ....
Ryan Rodrigues
It was really helpful. thanks alot
I set the Authentication to the user using the setmauth command and then tried it worked.
and as you wanted am providing the mule configuration :
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesource.org/schema/mule/core/2.2"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.mulesource.org/schema/mule/jms/2.2"
xmlns:file="http://www.mulesource.org/schema/mule/file/2.2"
xmlns:spring="http://www.springframework.org/schema/beans"
xsi:schemaLocation="
http://www.mulesource.org/schema/mule/core/2.2 http://www.mulesource.org/schema/mule/core/2.2/mule.xsd
http://www.mulesource.org/schema/mule/jms/2.2 http://www.mulesource.org/schema/mule/jms/2.2/mule-jms.xsd
http://www.mulesource.org/schema/mule/file/2.2 http://www.mulesource.org/schema/mule/file/2.2/mule-file.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
<!-- Direct MQ Configuration -->
<spring:bean id="mqconnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
<spring:property name="hostName" value="<ip addr of server>" />
<spring:property name="port" value="1415" />
<spring:property name="channel" value="<channel-name>" />
<spring:property name="queueManager" value="<queueManager>" />
<spring:property name="transportType" value="1" />
<spring:property name="SSLCipherSuite" value="SSL_RSA_WITH_NULL_MD5" />
<spring:property name="SSLSocketFactory" ref="SSLSocketFactoryClass"></spring:property>
</spring:bean>
<spring:bean name="SSLSocketFactoryClass" class="aero.sita.bagmanager.bsmtomq.sender.DummyMQSSLSocketfactory" >
<spring:constructor-arg value="/var/mqm/clients/ssl/KeyringClient.jks"> </spring:constructor-arg>
</spring:bean>
<jms:websphere-connector name="jmsConnector"
acknowledgementMode="AUTO_ACKNOWLEDGE" persistentDelivery="true"
specification="1.1" connectionFactory-ref="mqconnectionFactory" >
</jms:websphere-connector>
<jms:endpoint name="bsmInputQueue" queue="V"
connector-ref="jmsConnector" >
</jms:endpoint>
<file:connector name="fileConnector"
pollingFrequency="10000" streaming="false" moveToPattern="${SYSTIME}.txt">
</file:connector>
<model name="bsm-mqsender-model">
<service name="bsmMQSenderBean">
<inbound>
<file:inbound-endpoint path="/tmp/input/mq/bsm"
connector-ref="fileConnector" synchronous="true">
<file:file-to-string-transformer />
</file:inbound-endpoint>
</inbound>
<outbound>
<pass-through-router>
<jms:outbound-endpoint ref="bsmInputQueue">
<jms:object-to-jmsmessage-transformer />
</jms:outbound-endpoint>
</pass-through-router>
</outbound>
</service>
</model>
</mule>
i am using a dummy SSLSocketFactory in the configuration. The following code is the dummy socketfactory.
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.security.KeyManagementException;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.UnrecoverableKeyException;
import java.security.cert.CertificateException;
import javax.net.SocketFactory;
import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManagerFactory;
public class DummyMQSSLSocketfactory extends SSLSocketFactory
{
private SSLSocketFactory sslSocketFactory = null;
public DummyMQSSLSocketfactory() {
super();
}
public DummyMQSSLSocketfactory ( String fileLocation)
{
KeyStore keyStore;
KeyStore trustStore;
try
{
Class.forName("com.sun.net.ssl.internal.ssl.Provider");
System.out.println("JSSE is installed correctly!");
String pass = "password";
char[ ] password = pass.toCharArray ( );
keyStore = KeyStore.getInstance ( "JKS" );
java.io.FileInputStream fis = new java.io.FileInputStream ( fileLocation );
keyStore.load ( fis, password );
System.out.println("Number of keys on JKS: "
+ Integer.toString(keyStore.size()));
java.io.FileInputStream fis1 = new java.io.FileInputStream ( fileLocation );
trustStore = KeyStore.getInstance ( "JKS" );
trustStore.load ( fis1,null );
// Create a default trust and key manager
TrustManagerFactory trustManagerFactory =
TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
KeyManagerFactory keyManagerFactory =
KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
// Initialise the managers
trustManagerFactory.init(trustStore);
keyManagerFactory.init(keyStore,password);
// Get an SSL context.
// Note: not all providers support all CipherSuites. But the
// "SSL_RSA_WITH_3DES_EDE_CBC_SHA" CipherSuite is supported on both SunJSSE
// and IBMJSSE2 providers
// Accessing available algorithm/protocol in the SunJSSE provider
// see http://java.sun.com/javase/6/docs/technotes/guides/security/SunProviders.html
SSLContext sslContext = SSLContext.getInstance("SSLv3");
System.out.println("SSLContext provider: " +
sslContext.getProvider().toString());
// Initialise our SSL context from the key/trust managers
sslContext.init(keyManagerFactory.getKeyManagers(),
trustManagerFactory.getTrustManagers(), null);
// Get an SSLSocketFactory to pass to WMQ
sslSocketFactory = sslContext.getSocketFactory();
fis.close ( );
fis1.close ( );
}
catch ( KeyStoreException e )
{
// TODO Auto-generated catch block
e.printStackTrace ( );
}
catch ( FileNotFoundException e )
{
// TODO Auto-generated catch block
e.printStackTrace ( );
}
catch ( NoSuchAlgorithmException e )
{
// TODO Auto-generated catch block
e.printStackTrace ( );
}
catch ( CertificateException e )
{
// TODO Auto-generated catch block
e.printStackTrace ( );
}
catch ( IOException e )
{
// TODO Auto-generated catch block
e.printStackTrace ( );
}
catch ( ClassNotFoundException e )
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch ( UnrecoverableKeyException e )
{
// TODO Auto-generated catch block
e.printStackTrace();
}
catch ( KeyManagementException e )
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static SocketFactory getDefault ( )
{
return new DummyMQSSLSocketfactory ( );
}
public SSLSocketFactory getSslSocketFactory ( )
{
return sslSocketFactory;
}
public void setSslSocketFactory ( SSLSocketFactory sslSocketFactory )
{
this.sslSocketFactory = sslSocketFactory;
}
@Override
public Socket createSocket ( ) throws IOException
{
Socket socket;
try
{
if ( sslSocketFactory == null )
{
getDefault ( );
}
socket = sslSocketFactory.createSocket ( );
}
catch ( SocketException soc )
{
socket = new Socket ( );
}
return socket;
}
@Override
public Socket createSocket ( Socket s, String host, int port, boolean autoClose ) throws IOException
{
return sslSocketFactory.createSocket ( s, host, port, autoClose );
}
@Override
public String[ ] getDefaultCipherSuites ( )
{
return sslSocketFactory.getDefaultCipherSuites ( );
}
@Override
public String[ ] getSupportedCipherSuites ( )
{
return sslSocketFactory.getSupportedCipherSuites ( );
}
@Override
public Socket createSocket ( String arg0, int arg1 ) throws IOException, UnknownHostException
{
// TODO Auto-generated method stub
return sslSocketFactory.createSocket ( arg0, arg1 );
}
@Override
public Socket createSocket ( InetAddress arg0, int arg1 ) throws IOException
{
// TODO Auto-generated method stub
return sslSocketFactory.createSocket ( arg0, arg1 );
}
@Override
public Socket createSocket ( String arg0, int arg1, InetAddress arg2, int arg3 ) throws IOException,
UnknownHostException
{
// TODO Auto-generated method stub
return sslSocketFactory.createSocket ( arg0, arg1, arg2, arg3 );
}
@Override
public Socket createSocket ( InetAddress arg0, int arg1, InetAddress arg2, int arg3 ) throws IOException
{
// TODO Auto-generated method stub
return sslSocketFactory.createSocket ( arg0, arg1, arg2, arg3 );
}
}
Hope this would help you. once again thank you for the reply.