001: /*
002: * <copyright>
003: *
004: * Copyright 2002-2004 BBNT Solutions, LLC
005: * under sponsorship of the Defense Advanced Research Projects
006: * Agency (DARPA).
007: *
008: * You can redistribute this software and/or modify it under the
009: * terms of the Cougaar Open Source License as published on the
010: * Cougaar Open Source Website (www.cougaar.org).
011: *
012: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
013: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
014: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
015: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
016: * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
017: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
018: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
019: * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
020: * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
021: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
022: * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
023: *
024: * </copyright>
025: */
026:
027: package org.cougaar.yp;
028:
029: import java.net.URL;
030: import java.util.List;
031:
032: import org.cougaar.core.agent.service.MessageSwitchService;
033: import org.cougaar.core.component.ComponentLoadFailure;
034: import org.cougaar.core.component.ComponentSupport;
035: import org.cougaar.core.component.ServiceBroker;
036: import org.cougaar.core.mts.Message;
037: import org.cougaar.core.mts.MessageAddress;
038: import org.cougaar.core.mts.MessageHandler;
039: import org.w3c.dom.Element;
040:
041: /**
042: * This is a trivial YP gateway which translates
043: * in-band Cougaar YP queries into SOAP comms using the
044: * apache backend from uddi4j
045: * The component requires a parameter which specifies the URL to which
046: * queries should be sent.
047: * @note This gateway only supports queries, not updates.
048: **/
049:
050: public class YPSoapGateway extends ComponentSupport {
051:
052: private MessageSwitchService mss = null;
053: private MessageAddress originMA;
054: // private ApacheSOAPTransport transport = null;
055: private URL iURL = null;
056: private URL pURL = null;
057:
058: public void setParameter(Object o) {
059: if (o instanceof List) {
060: List l = (List) o;
061: if (l.size() > 1) {
062: Object o1 = l.get(0);
063: if (o1 instanceof URL) {
064: iURL = (URL) o1;
065: } else if (o1 instanceof String) {
066: try {
067: iURL = new URL((String) o1);
068: } catch (Exception e) {
069: throw new ComponentLoadFailure(
070: "Bad inquiry URL parameter specified "
071: + o1, this , e);
072: }
073: }
074:
075: Object o2 = l.get(1);
076: if (o2 instanceof URL) {
077: pURL = (URL) o2;
078: } else if (o2 instanceof String) {
079: try {
080: pURL = new URL((String) o2);
081: } catch (Exception e) {
082: throw new ComponentLoadFailure(
083: "Bad post URL parameter specified "
084: + o2, this , e);
085: }
086: }
087: }
088: }
089: if (iURL == null || pURL == null) {
090: throw new ComponentLoadFailure(
091: "Not enough URL parameters specified", this );
092: }
093: }
094:
095: public void load() {
096: super .load();
097:
098: // need to hook into the Agent MessageHandler protocol
099: MessageHandler mh = new MessageHandler() {
100: public boolean handleMessage(Message message) {
101: if (message instanceof YPQueryMessage) {
102: dispatchQuery((YPQueryMessage) message);
103: return true;
104: }
105: return false;
106: }
107: };
108: ServiceBroker sb = getServiceBroker();
109: mss = (MessageSwitchService) sb.getService(this ,
110: MessageSwitchService.class, null);
111: mss.addMessageHandler(mh);
112: originMA = mss.getMessageAddress();
113:
114: // transport = new ApacheSOAPTransport();
115: }
116:
117: /** forward to apache soap **/
118: private void dispatchQuery(YPQueryMessage r) {
119: Object key = r.getKey();
120: // Element qel = r.getElement();
121: Element rel = null;
122: // boolean isInquiry = r.isInquiry();
123: // try {
124: // rel = transport.send(qel, isInquiry?iURL:pURL);
125: // } catch (TransportException te) {
126: // // probably should bundle up the exception in a response element
127: // }
128: YPResponseMessage m = new YPResponseMessage(originMA, r
129: .getOriginator(), rel, key);
130: sendMessage(m);
131: }
132:
133: protected void sendMessage(Message m) {
134: mss.sendMessage(m);
135: }
136: }
|