Merge "Omaha #3280 Sister ticket to 3141 for DD repo. Setup SOAP metadata transfers for DPA" into omaha_14.4.1
Former-commit-id: 5dab0d8232781688132d7df0710a86ea98f93810
This commit is contained in:
commit
b630aa2971
3 changed files with 219 additions and 1 deletions
|
@ -76,6 +76,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
|
||||||
* Dec 10, 2013 2616 mpduff Added stationId to the unique constraint
|
* Dec 10, 2013 2616 mpduff Added stationId to the unique constraint
|
||||||
* jan 22, 2014 2713 dhladky Calendar conversion.
|
* jan 22, 2014 2713 dhladky Calendar conversion.
|
||||||
* Mar 21, 2014 2939 dhladky Fixed mismatches in HDF5, DB records.
|
* Mar 21, 2014 2939 dhladky Fixed mismatches in HDF5, DB records.
|
||||||
|
* Jan 08, 2014 3141 dhladky Bad index for WFS requests.
|
||||||
*
|
*
|
||||||
* </pre>
|
* </pre>
|
||||||
*
|
*
|
||||||
|
@ -88,7 +89,7 @@ import com.raytheon.uf.common.serialization.annotations.DynamicSerializeElement;
|
||||||
@Table(name = "madis", uniqueConstraints = { @UniqueConstraint(columnNames = {
|
@Table(name = "madis", uniqueConstraints = { @UniqueConstraint(columnNames = {
|
||||||
"latitude", "longitude", "stationId", "refTime", "provider", "subProvider", "restriction" }) })
|
"latitude", "longitude", "stationId", "refTime", "provider", "subProvider", "restriction" }) })
|
||||||
@org.hibernate.annotations.Table(appliesTo = "madis", indexes = { @Index(name = "madis_wfsQueryIndex", columnNames = {
|
@org.hibernate.annotations.Table(appliesTo = "madis", indexes = { @Index(name = "madis_wfsQueryIndex", columnNames = {
|
||||||
"refTime", "location" }), })
|
"insertTime", "location" }), })
|
||||||
@DynamicSerialize
|
@DynamicSerialize
|
||||||
public class MadisRecord extends PersistablePluginDataObject implements
|
public class MadisRecord extends PersistablePluginDataObject implements
|
||||||
ISpatialEnabled, IPointData {
|
ISpatialEnabled, IPointData {
|
||||||
|
|
|
@ -0,0 +1,104 @@
|
||||||
|
/**
|
||||||
|
* This software was developed and / or modified by Raytheon Company,
|
||||||
|
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
||||||
|
*
|
||||||
|
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
||||||
|
* This software product contains export-restricted data whose
|
||||||
|
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
||||||
|
* to non-U.S. persons whether in the United States or abroad requires
|
||||||
|
* an export license or other authorization.
|
||||||
|
*
|
||||||
|
* Contractor Name: Raytheon Company
|
||||||
|
* Contractor Address: 6825 Pine Street, Suite 340
|
||||||
|
* Mail Stop B8
|
||||||
|
* Omaha, NE 68106
|
||||||
|
* 402.291.0100
|
||||||
|
*
|
||||||
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
||||||
|
* further licensing information.
|
||||||
|
**/
|
||||||
|
package com.raytheon.uf.common.registry.ebxml;
|
||||||
|
|
||||||
|
import com.raytheon.uf.common.registry.services.RegistrySOAPServices;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Remote version of the {@link SOAPRegistryManager}.
|
||||||
|
*
|
||||||
|
* <pre>
|
||||||
|
*
|
||||||
|
* SOFTWARE HISTORY
|
||||||
|
*
|
||||||
|
* Date Ticket# Engineer Description
|
||||||
|
* ------------ ---------- ----------- --------------------------
|
||||||
|
* Jun 06, 2014 #3141 dhladky initial creation
|
||||||
|
* </pre>
|
||||||
|
*
|
||||||
|
* @author dhladky
|
||||||
|
* @version 1.0
|
||||||
|
*/
|
||||||
|
public class RemoteSOAPRegistryHandler extends RemoteSOAPRegistryManager {
|
||||||
|
|
||||||
|
/** remote registry host **/
|
||||||
|
private String host;
|
||||||
|
|
||||||
|
/** remote registry port **/
|
||||||
|
private String port;
|
||||||
|
|
||||||
|
/** remote registry protocol **/
|
||||||
|
private String protocol;
|
||||||
|
|
||||||
|
/** remote host complete precursor URL */
|
||||||
|
public String remoteHostUrl = null;
|
||||||
|
|
||||||
|
/** default constructor **/
|
||||||
|
public RemoteSOAPRegistryHandler() {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Bean constructor **/
|
||||||
|
public RemoteSOAPRegistryHandler(RegistrySOAPServices rss) {
|
||||||
|
super(rss);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected String getRemoteHost() {
|
||||||
|
|
||||||
|
if (remoteHostUrl == null) {
|
||||||
|
StringBuffer buf = new StringBuffer();
|
||||||
|
buf.append(protocol);
|
||||||
|
buf.append("://");
|
||||||
|
buf.append(host);
|
||||||
|
buf.append(":");
|
||||||
|
buf.append(port);
|
||||||
|
|
||||||
|
remoteHostUrl = buf.toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
return remoteHostUrl;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getHost() {
|
||||||
|
return host;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setHost(String host) {
|
||||||
|
this.host = host;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getPort() {
|
||||||
|
return port;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPort(String port) {
|
||||||
|
this.port = port;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getProtocol() {
|
||||||
|
return protocol;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setProtocol(String protocol) {
|
||||||
|
this.protocol = protocol;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,113 @@
|
||||||
|
package com.raytheon.uf.common.registry.ebxml;
|
||||||
|
|
||||||
|
import oasis.names.tc.ebxml.regrep.wsdl.registry.services.v4.LifecycleManager;
|
||||||
|
import oasis.names.tc.ebxml.regrep.wsdl.registry.services.v4.QueryManager;
|
||||||
|
|
||||||
|
import com.raytheon.uf.common.registry.services.RegistrySOAPServices;
|
||||||
|
import com.raytheon.uf.common.status.IUFStatusHandler;
|
||||||
|
import com.raytheon.uf.common.status.UFStatus;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* A SOAP client implementation for use with the RegistryManager Class.
|
||||||
|
*
|
||||||
|
* <pre>
|
||||||
|
*
|
||||||
|
* SOFTWARE HISTORY
|
||||||
|
*
|
||||||
|
* Date Ticket# Engineer Description
|
||||||
|
* ------------ ---------- ----------- --------------------------
|
||||||
|
* Jun 06, 2014 #3141 dhladky creation
|
||||||
|
*
|
||||||
|
* </pre>
|
||||||
|
*
|
||||||
|
* @author dhladky
|
||||||
|
* @version 1.0
|
||||||
|
*/
|
||||||
|
public abstract class RemoteSOAPRegistryManager implements LifecycleManagerFactory,
|
||||||
|
QueryManagerFactory {
|
||||||
|
|
||||||
|
protected static final IUFStatusHandler statusHandler = UFStatus
|
||||||
|
.getHandler(RemoteSOAPRegistryManager.class);
|
||||||
|
|
||||||
|
/** SOAP service provider **/
|
||||||
|
protected RegistrySOAPServices rss;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* default constructor.
|
||||||
|
*/
|
||||||
|
public RemoteSOAPRegistryManager() {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constructor to conform to bean pattern.
|
||||||
|
*/
|
||||||
|
public RemoteSOAPRegistryManager(RegistrySOAPServices rss) {
|
||||||
|
setRss(rss);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get an implementation of LifeCycleManager that uses SOAP to submit
|
||||||
|
* requests to the registry.
|
||||||
|
*
|
||||||
|
* @return A SOAP implementation of LifeCycleManager.
|
||||||
|
*
|
||||||
|
* @see LifecycleManagerFactory
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public LifecycleManager getLifeCycleManager() {
|
||||||
|
// Retrieve a WebSevice client for the LifecycleManager.
|
||||||
|
LifecycleManager a = null;
|
||||||
|
try {
|
||||||
|
a = getRss().getLifecycleManagerServiceForHost(getRemoteHost());
|
||||||
|
} catch (Exception e) {
|
||||||
|
statusHandler.error("Can't find the Remote LifeCycleManager SOAP service!", e);
|
||||||
|
}
|
||||||
|
|
||||||
|
return a;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get an implementation of QueryManager that uses SOAP to submit requests
|
||||||
|
* to the registry.
|
||||||
|
*
|
||||||
|
* @return A SOAP implementation of QueryManager.
|
||||||
|
*
|
||||||
|
* @see QueryManagerFactory
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public QueryManager getQueryManager() {
|
||||||
|
|
||||||
|
QueryManager qm = null;
|
||||||
|
try {
|
||||||
|
qm = getRss().getQueryServiceForHost(getRemoteHost());
|
||||||
|
} catch (Exception e) {
|
||||||
|
statusHandler.error("Can't find the Remote QueryManager SOAP service!", e);
|
||||||
|
}
|
||||||
|
|
||||||
|
return qm;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the name of the remote host
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
protected abstract String getRemoteHost();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* get the registry SOAP service helper setup
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public RegistrySOAPServices getRss() {
|
||||||
|
return rss;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets the registry SOAP service helper
|
||||||
|
* @param rss
|
||||||
|
*/
|
||||||
|
public void setRss(RegistrySOAPServices rss) {
|
||||||
|
this.rss = rss;
|
||||||
|
}
|
||||||
|
}
|
Loading…
Add table
Reference in a new issue