001: /*
002: * The Apache Software License, Version 1.1
003: *
004: *
005: * Copyright (c) 2002 The Apache Software Foundation. All rights
006: * reserved.
007: *
008: * Redistribution and use in source and binary forms, with or without
009: * modification, are permitted provided that the following conditions
010: * are met:
011: *
012: * 1. Redistributions of source code must retain the above copyright
013: * notice, this list of conditions and the following disclaimer.
014: *
015: * 2. Redistributions in binary form must reproduce the above copyright
016: * notice, this list of conditions and the following disclaimer in
017: * the documentation and/or other materials provided with the
018: * distribution.
019: *
020: * 3. The end-user documentation included with the redistribution,
021: * if any, must include the following acknowledgment:
022: * "This product includes software developed by the
023: * Apache Software Foundation (http://www.apache.org/)."
024: * Alternately, this acknowledgment may appear in the software itself,
025: * if and wherever such third-party acknowledgments normally appear.
026: *
027: * 4. The names "WSIF" and "Apache Software Foundation" must
028: * not be used to endorse or promote products derived from this
029: * software without prior written permission. For written
030: * permission, please contact apache@apache.org.
031: *
032: * 5. Products derived from this software may not be called "Apache",
033: * nor may "Apache" appear in their name, without prior written
034: * permission of the Apache Software Foundation.
035: *
036: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
037: * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
038: * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
039: * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
040: * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
041: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
042: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
043: * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
044: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
045: * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
046: * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
047: * SUCH DAMAGE.
048: * ====================================================================
049: *
050: * This software consists of voluntary contributions made by many
051: * individuals on behalf of the Apache Software Foundation and was
052: * originally based on software copyright (c) 2001, 2002, International
053: * Business Machines, Inc., http://www.apache.org. For more
054: * information on the Apache Software Foundation, please see
055: * <http://www.apache.org/>.
056: */
057:
058: package org.apache.wsif.util.jms;
059:
060: import javax.jms.Destination;
061: import javax.jms.Queue;
062: import javax.jms.QueueConnectionFactory;
063: import org.apache.wsif.WSIFException;
064:
065: /**
066: * Finds JMS objects by going directly to MQSeries.
067: * @author Mark Whitlock <whitlock@apache.org>
068: */
069: class WSIFJMSFinderForMq extends WSIFJMSFinder {
070:
071: private QueueConnectionFactory factory;
072: private Destination initialDestination;
073: private String style;
074:
075: WSIFJMSFinderForMq(String jmsVendorURL, String implSpecURL)
076: throws WSIFException {
077: throw new WSIFException("not yet implemented");
078:
079: /* try {
080: factory = new MQQueueConnectionFactory();
081: factory.setQueueManager("");
082:
083: connection = factory.createQueueConnection();
084: session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
085:
086: readQ = session.createQueue(readQName );
087: writeQ = session.createQueue(writeQName);
088: connection.start();
089:
090: if (startType==COLDSTART) {
091: System.out.println("Wiping messages off the queues");
092: Message msg=null;
093: try {
094: if (receiver==null) receiver=session.createReceiver(readQ);
095: for (;;) {
096: msg=receiver.receive(100);
097: if (msg!=null) System.out.println("Removing an input message");
098: else break;
099: }
100: } catch (Exception e) {}
101:
102: try {
103: QueueReceiver tmpRec = session.createReceiver(writeQ);
104: for (;;) {
105: msg=tmpRec.receive(100);
106: if (msg!=null) System.out.println("Removing an output message");
107: else break;
108: }
109: } catch (Exception e) {}
110: }
111:
112: } catch( JMSException je ) {
113: System.out.println("caught JMSException: " + je);
114: Exception le = je.getLinkedException();
115: if (le != null) System.out.println("linked exception: "+le);
116:
117: } catch( Exception e ) {
118: System.out.println("Caught exception: " + e );
119: } */
120:
121: }
122:
123: public QueueConnectionFactory getFactory() {
124: return factory;
125: }
126:
127: public Destination getInitialDestination() {
128: return initialDestination;
129: }
130:
131: String getStyle() {
132: return style;
133: }
134:
135: Queue findQueue(String name) throws WSIFException {
136: return null;
137: }
138: }
|