Greetings
When trying to add a document to a collection I get an exception about
XML:DB org.xmldb.api.base.XMLDBException 1 Collection Cannot Store
[java] org.xmldb.api.base.XMLDBException: Collection Cannot Store
[java] at
org.apache.xindice.core.FaultCodes.createXMLDBException(FaultCodes.java:239)
[java] at
org.apache.xindice.client.xmldb.CollectionImpl.storeResource(CollectionImpl.java:518)
This is urent has anybody come accross that before ?
I've attached the stub file and the idl.
Env.
JDK 1.4.1
Xindice-1.0
openorb-1.3.0
Best Regards.
JC.
==================================================================
[EMAIL PROTECTED]
=================================================================
/*
* The Apache Software License, Version 1.1
*
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution,
* if any, must include the following acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Xindice" and "Apache Software Foundation" must
* not be used to endorse or promote products derived from this
* software without prior written permission. For written
* permission, please contact [EMAIL PROTECTED]
*
* 5. Products derived from this software may not be called "Apache",
* nor may "Apache" appear in their name, without prior written
* permission of the Apache Software Foundation.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation and was
* originally based on software copyright (c) 1999-2001, The dbXML
* Group, L.L.C., http://www.dbxmlgroup.com. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* $Id: Xindice.idl,v 1.1.1.1 2001/12/06 19:33:51 bradford Exp $
*/
#ifndef XINDICE_IDL
#define XINDICE_IDL
module org {
module apache {
module xindice {
module client {
module corba {
module db {
// Content Encoding Timestamping *********************************
typedef long long Timestamp;
const Timestamp STAMP_TEXT = -1; // Non-Compressed
// Global Type Definitions ***************************************
typedef string Name;
typedef sequence<Name> Names;
typedef string Value;
typedef sequence<octet> Buffer;
struct NamedVal {
Name nam;
Value val;
};
typedef sequence<NamedVal> NamedVals;
struct EncodedBuffer {
Timestamp stamp; // Last modified for Symbol Table
Buffer sym; // Compressed Symbol Table (if any)
Buffer buf; // Text or Compressed Buffer (if stamp != -1)
};
typedef Buffer Key;
typedef Buffer Data;
exception APIException {
long faultCode;
string faultMessage;
string exceptionMessage;
};
interface FaultCodes {
// Categories
const long GEN = 0; // General
const long OBJ = 100; // XMLObjects
const long COL = 200; // Collections
const long IDX = 300; // Indexes
const long TRX = 400; // Transactions
const long DBE = 500; // Database Engine
const long QRY = 600; // Queries
const long SEC = 700; // Security
const long URI = 800; // URI
const long JAVA = 2000; // Java
// General errors 0 series
const long GEN_UNKNOWN = 0;
const long GEN_GENERAL_ERROR = 40;
const long GEN_CRITICAL_ERROR = 70;
const long GEN_FATAL_ERROR = 90;
// XMLObject invocation errors 100 series
const long OBJ_OBJECT_NOT_FOUND = 100;
const long OBJ_METHOD_NOT_FOUND = 101;
const long OBJ_NULL_RESULT = 140;
const long OBJ_INVALID_RESULT = 141;
const long OBJ_DUPLICATE_OBJECT = 142;
const long OBJ_RUNTIME_EXCEPTION = 170;
const long OBJ_CLASS_FORMAT_ERROR = 171;
const long OBJ_INVALID_CONTEXT = 172;
const long OBJ_CANNOT_CREATE = 173;
// Collection-related errors 200 series
const long COL_COLLECTION_NOT_FOUND = 200;
const long COL_DOCUMENT_NOT_FOUND = 201;
const long COL_DUPLICATE_COLLECTION = 240;
const long COL_NULL_RESULT = 241;
const long COL_NO_FILER = 242;
const long COL_NO_INDEXMANAGER = 242;
const long COL_DOCUMENT_MALFORMED = 243;
const long COL_CANNOT_STORE = 244;
const long COL_CANNOT_RETRIEVE = 245;
const long COL_COLLECTION_READ_ONLY = 246;
const long COL_COLLECTION_CLOSED = 247;
const long COL_CANNOT_CREATE = 270;
const long COL_CANNOT_DROP = 271;
// Index-related errors 300 series
const long IDX_VALUE_NOT_FOUND = 300;
const long IDX_INDEX_NOT_FOUND = 301;
const long IDX_MATCHES_NOT_FOUND = 340;
const long IDX_DUPLICATE_INDEX = 341;
const long IDX_NOT_SUPPORTED = 370;
const long IDX_STYLE_NOT_FOUND = 371;
const long IDX_CORRUPTED = 372;
const long IDX_CANNOT_CREATE = 373;
// Transaction-related errors 400 series
const long TRX_DOC_LOCKED = 400;
const long TRX_NO_CONTEXT = 440;
const long TRX_NOT_ACTIVE = 441;
const long TRX_NOT_SUPPORTED = 470;
// Database-related errors 500 series
const long DBE_NO_PARENT = 500;
const long DBE_CANNOT_DROP = 570;
const long DBE_CANNOT_CREATE = 571;
// Query-related errors 600 series
const long QRY_NULL_RESULT = 600;
const long QRY_COMPILATION_ERROR = 640;
const long QRY_PROCESSING_ERROR = 641;
const long QRY_NOT_SUPPORTED = 670;
const long QRY_STYLE_NOT_FOUND = 671;
// Security-related errors 700 series
const long SEC_INVALID_USER = 770;
const long SEC_INVALID_GROUP = 771;
const long SEC_INVALID_ACCESS = 772;
const long SEC_INVALID_CREDENTIALS = 773;
// URI Mapper errors 800 series
const long URI_EMPTY = 800;
const long URI_NULL = 801;
const long URI_PARSE_ERROR = 820;
// Java errors 2000 series
const long JAVA_RUNTIME_ERROR = 2070;
};
interface ServantManagement {
void remove();
};
interface DocumentSet : ServantManagement {
boolean hasMoreDocuments() raises (APIException);
EncodedBuffer getNextDocument(in Timestamp stamp) raises (APIException);
};
interface CollectionManager;
interface DatabaseManager;
interface Collection : ServantManagement {
string getName() raises (APIException);
string getCanonicalName() raises (APIException);
CollectionManager getCollectionManager() raises (APIException);
Collection getParentCollection() raises (APIException);
Names listCollections() raises (APIException);
Collection getCollection(in Name path) raises (APIException);
string insertDocument(in Name nam, in EncodedBuffer doc)
raises (APIException);
void removeDocument(in string id) raises (APIException);
EncodedBuffer getDocument(in string id, in Timestamp stamp) raises (APIException);
void setDocument(in string id, in EncodedBuffer doc) raises (APIException);
DocumentSet getDocuments() raises (APIException);
Names listDocuments() raises (APIException);
long getDocumentCount() raises (APIException);
string createNewOID() raises (APIException);
EncodedBuffer queryCollection(in string style, in Value query, in NamedVals namespaces, in Timestamp stamp) raises (APIException);
EncodedBuffer queryDocument(in string style, in Value query, in NamedVals namespaces, in string id, in Timestamp stamp) raises (APIException);
EncodedBuffer invokeXMLObject(in string uri) raises (APIException);
};
interface CollectionManager : ServantManagement {
string getName() raises (APIException);
string getCanonicalName() raises (APIException);
Collection createCollection(in Name path, in EncodedBuffer config)
raises (APIException);
void dropCollection(in Name path) raises (APIException);
Names listIndexers() raises (APIException);
void createIndexer(in EncodedBuffer config) raises (APIException);
void dropIndexer(in Name nam) raises (APIException);
Names listXMLObjects() raises (APIException);
void createXMLObject(in EncodedBuffer config) raises (APIException);
void dropXMLObject(in Name nam) raises (APIException);
};
interface Database : ServantManagement {
string getName() raises (APIException);
DatabaseManager getDatabaseManager() raises (APIException);
Names listCollections() raises (APIException);
Collection getCollection(in Name path) raises (APIException);
};
interface DatabaseManager : ServantManagement {
string getName() raises (APIException);
oneway void shutdown();
};
}; // db
}; // corba
}; // client
}; // xindice
}; // apache
}; // org
#endif // XINDICE_IDL
package org.apache.xindice.client.corba.db;
/**
* Interface definition : Collection
*
* @author OpenORB Compiler
*/
public class _CollectionStub extends org.omg.CORBA.portable.ObjectImpl
implements Collection
{
static final String[] _ids_list =
{
"IDL:org/apache/xindice/client/corba/db/Collection:1.0",
"IDL:org/apache/xindice/client/corba/db/ServantManagement:1.0"
};
public String[] _ids()
{
return _ids_list;
}
private final static Class _opsClass = org.apache.xindice.client.corba.db.CollectionOperations.class;
/**
* Operation getName
*/
public String getName()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getName",true);
_input = this._invoke(_output);
String _arg_ret = _input.read_string();
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getName",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getName();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getCanonicalName
*/
public String getCanonicalName()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getCanonicalName",true);
_input = this._invoke(_output);
String _arg_ret = _input.read_string();
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getCanonicalName",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getCanonicalName();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getCollectionManager
*/
public org.apache.xindice.client.corba.db.CollectionManager getCollectionManager()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getCollectionManager",true);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.CollectionManager _arg_ret = org.apache.xindice.client.corba.db.CollectionManagerHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getCollectionManager",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getCollectionManager();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getParentCollection
*/
public org.apache.xindice.client.corba.db.Collection getParentCollection()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getParentCollection",true);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.Collection _arg_ret = org.apache.xindice.client.corba.db.CollectionHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getParentCollection",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getParentCollection();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation listCollections
*/
public String[] listCollections()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("listCollections",true);
_input = this._invoke(_output);
String[] _arg_ret = org.apache.xindice.client.corba.db.NamesHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("listCollections",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.listCollections();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getCollection
*/
public org.apache.xindice.client.corba.db.Collection getCollection(String path)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getCollection",true);
org.apache.xindice.client.corba.db.NameHelper.write(_output,path);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.Collection _arg_ret = org.apache.xindice.client.corba.db.CollectionHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getCollection",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getCollection( path);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation insertDocument
*/
public String insertDocument(String nam, org.apache.xindice.client.corba.db.EncodedBuffer doc)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("insertDocument",true);
org.apache.xindice.client.corba.db.NameHelper.write(_output,nam);
org.apache.xindice.client.corba.db.EncodedBufferHelper.write(_output,doc);
_input = this._invoke(_output);
String _arg_ret = _input.read_string();
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("insertDocument",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.insertDocument( nam, doc);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation removeDocument
*/
public void removeDocument(String id)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("removeDocument",true);
_output.write_string(id);
_input = this._invoke(_output);
return;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("removeDocument",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
_self.removeDocument( id);
return;
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getDocument
*/
public org.apache.xindice.client.corba.db.EncodedBuffer getDocument(String id, long stamp)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getDocument",true);
_output.write_string(id);
org.apache.xindice.client.corba.db.TimestampHelper.write(_output,stamp);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.EncodedBuffer _arg_ret = org.apache.xindice.client.corba.db.EncodedBufferHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getDocument",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getDocument( id, stamp);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation setDocument
*/
public void setDocument(String id, org.apache.xindice.client.corba.db.EncodedBuffer doc)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("setDocument",true);
_output.write_string(id);
org.apache.xindice.client.corba.db.EncodedBufferHelper.write(_output,doc);
_input = this._invoke(_output);
return;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("setDocument",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
_self.setDocument( id, doc);
return;
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getDocuments
*/
public org.apache.xindice.client.corba.db.DocumentSet getDocuments()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getDocuments",true);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.DocumentSet _arg_ret = org.apache.xindice.client.corba.db.DocumentSetHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getDocuments",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getDocuments();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation listDocuments
*/
public String[] listDocuments()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("listDocuments",true);
_input = this._invoke(_output);
String[] _arg_ret = org.apache.xindice.client.corba.db.NamesHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("listDocuments",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.listDocuments();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation getDocumentCount
*/
public int getDocumentCount()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("getDocumentCount",true);
_input = this._invoke(_output);
int _arg_ret = _input.read_long();
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getDocumentCount",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.getDocumentCount();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation createNewOID
*/
public String createNewOID()
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("createNewOID",true);
_input = this._invoke(_output);
String _arg_ret = _input.read_string();
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("createNewOID",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.createNewOID();
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation queryCollection
*/
public org.apache.xindice.client.corba.db.EncodedBuffer queryCollection(String style, String query, org.apache.xindice.client.corba.db.NamedVal[] namespaces, long stamp)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("queryCollection",true);
_output.write_string(style);
org.apache.xindice.client.corba.db.ValueHelper.write(_output,query);
org.apache.xindice.client.corba.db.NamedValsHelper.write(_output,namespaces);
org.apache.xindice.client.corba.db.TimestampHelper.write(_output,stamp);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.EncodedBuffer _arg_ret = org.apache.xindice.client.corba.db.EncodedBufferHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("queryCollection",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.queryCollection( style, query, namespaces, stamp);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation queryDocument
*/
public org.apache.xindice.client.corba.db.EncodedBuffer queryDocument(String style, String query, org.apache.xindice.client.corba.db.NamedVal[] namespaces, String id, long stamp)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("queryDocument",true);
_output.write_string(style);
org.apache.xindice.client.corba.db.ValueHelper.write(_output,query);
org.apache.xindice.client.corba.db.NamedValsHelper.write(_output,namespaces);
_output.write_string(id);
org.apache.xindice.client.corba.db.TimestampHelper.write(_output,stamp);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.EncodedBuffer _arg_ret = org.apache.xindice.client.corba.db.EncodedBufferHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("queryDocument",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.queryDocument( style, query, namespaces, id, stamp);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation invokeXMLObject
*/
public org.apache.xindice.client.corba.db.EncodedBuffer invokeXMLObject(String uri)
throws org.apache.xindice.client.corba.db.APIException
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("invokeXMLObject",true);
_output.write_string(uri);
_input = this._invoke(_output);
org.apache.xindice.client.corba.db.EncodedBuffer _arg_ret = org.apache.xindice.client.corba.db.EncodedBufferHelper.read(_input);
return _arg_ret;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
if (_exception_id.equals(org.apache.xindice.client.corba.db.APIExceptionHelper.id()))
{
throw org.apache.xindice.client.corba.db.APIExceptionHelper.read(_exception.getInputStream());
}
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("invokeXMLObject",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.CollectionOperations _self = (org.apache.xindice.client.corba.db.CollectionOperations) _so.servant;
try
{
return _self.invokeXMLObject( uri);
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
/**
* Operation remove
*/
public void remove()
{
while(true)
{
if (!this._is_local())
{
org.omg.CORBA.portable.InputStream _input = null;
try
{
org.omg.CORBA.portable.OutputStream _output = this._request("remove",true);
_input = this._invoke(_output);
return;
}
catch(org.omg.CORBA.portable.RemarshalException _exception)
{
continue;
}
catch(org.omg.CORBA.portable.ApplicationException _exception)
{
String _exception_id = _exception.getId();
throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
}
finally
{
this._releaseReply(_input);
}
}
else
{
org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("remove",_opsClass);
if (_so == null)
continue;
org.apache.xindice.client.corba.db.ServantManagementOperations _self = (org.apache.xindice.client.corba.db.ServantManagementOperations) _so.servant;
try
{
_self.remove();
return;
}
finally
{
_servant_postinvoke(_so);
}
}
}
}
}
