Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- QueueBrowser browser = session.createBrowser(queue1);
- queue1
- public static void main(String[] args) throws Exception {
- Logger logger = LoggerFactory.getLogger(Connection.class);
- String hostname = "xxxxxx";
- int port = 1442;
- String queueManager = "xxxxxxxx";
- String channel = "xxxxxxxxxx";
- String queueName = "xxxxxxxxxx";
- String keystore = "xxxxxxxxx/xxxxxxx/ssclient_test.ks";
- String truststore = "cxxxxxx/xxxxxxxx/client_test.ts";
- String suiteName = "xxx_xxx_xxxx_xxx_xxx_xxx";
- String keyStorePassKey = "xxx_KEYSTORE";
- SSLSocketFactory sslSocketFactory = createSslSocketFactory(new File(keystore), new File(truststore),
- keyStorePassKey);
- MQXAQueueConnectionFactory mqConnFactory = new MQXAQueueConnectionFactory();
- mqConnFactory.setHostName(hostname);
- mqConnFactory.setPort(port);
- mqConnFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
- mqConnFactory.setQueueManager(queueManager);
- mqConnFactory.setChannel(channel);
- mqConnFactory.setUseConnectionPooling(true);
- mqConnFactory.setSSLSocketFactory(sslSocketFactory);
- mqConnFactory.setSSLCipherSuite(suiteName);
- QueueConnection queueConnection = mqConnFactory.createQueueConnection();
- QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
- queueSession.close();
- queueConnection.close();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement