You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@etch.apache.org by sc...@apache.org on 2009/02/22 05:17:58 UTC
svn commit: r746631 [2/3] - in /incubator/etch/branches/name-service: ./
services/ services/ns/ services/ns/src/ services/ns/src/main/
services/ns/src/main/etch/ services/ns/src/main/java/
services/ns/src/main/java/etch/ services/ns/src/main/java/etch/...
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,170 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+import org.apache.etch.bindings.java.support.DeliveryService;
+import org.apache.etch.bindings.java.support.Pool;
+import org.apache.etch.bindings.java.support.ServerFactory;
+import org.apache.etch.bindings.java.msg.ValueFactory;
+import org.apache.etch.bindings.java.support.DefaultServerFactory;
+import org.apache.etch.util.core.io.Transport;
+import org.apache.etch.bindings.java.support.TransportFactory;
+import org.apache.etch.bindings.java.support.TransportHelper;
+import org.apache.etch.bindings.java.transport.DefaultDeliveryService;
+import org.apache.etch.bindings.java.transport.MailboxManager;
+import org.apache.etch.bindings.java.transport.PlainMailboxManager;
+import org.apache.etch.bindings.java.transport.TransportMessage;
+import org.apache.etch.util.Resources;
+import org.apache.etch.util.URL;
+
+/**
+ * Transport helper for NameService. All methods are static.
+ */
+abstract public class NameServiceHelper extends TransportHelper
+{
+
+ /**
+ * Constructs a new server session listener per specifications in uri and
+ * resources. This listener will accept requests from clients for new server
+ * sessions.
+ *
+ * @param uri contains specifications for the server session listener and
+ * for the server session transport stack.
+ *
+ * @param resources additional resources to aid in constructing new server
+ * sessions.
+ *
+ * @param implFactory factory used to construct a new instance implementing
+ * NameServiceServer. The new instance will receive and process messages from
+ * the client session.
+ *
+ * @return a server session listener.
+ *
+ * @throws Exception
+ */
+ public static ServerFactory newListener( final String uri,
+ Resources resources, final NameServiceServerFactory implFactory )
+ throws Exception
+ {
+ final Resources res = initResources( resources );
+ final URL u = new URL( uri );
+
+ final Transport<ServerFactory> listener = TransportFactory.getListener( uri, res );
+
+ return new DefaultServerFactory( listener, implFactory )
+ {
+ public void newServer( String uri, Resources resources,
+ TransportMessage transport ) throws Exception
+ {
+ ValueFactory vf = (ValueFactory) resources.get( Transport.VALUE_FACTORY );
+ MailboxManager x = new PlainMailboxManager( transport, u, res );
+ DeliveryService d = new DefaultDeliveryService( x, u, res );
+ RemoteNameServiceClient client = new RemoteNameServiceClient( d, vf );
+ NameServiceServer server = implFactory.newNameServiceServer( client );
+ Pool qp = (Pool) res.get( QUEUED_POOL );
+ Pool fp = (Pool) res.get( FREE_POOL );
+ new StubNameServiceServer( d, server, qp, fp );
+ client._start();
+ }
+
+ public ValueFactory newValueFactory()
+ {
+ return new ValueFactoryNameService( uri );
+ }
+
+ @Override
+ public String toString()
+ {
+ return "NameServiceHelper.ServerFactory/" + listener;
+ }
+ };
+ }
+
+ /**
+ * Factory used by
+ * {@link NameServiceHelper#newListener(String, Resources, NameServiceServerFactory)}
+ * to construct a new instance implementing {@link NameServiceServer}. The new
+ * instance will receive and process messages from the client session.
+ */
+ public interface NameServiceServerFactory
+ {
+ /**
+ * Constructs a new instance implementing NameServiceServer. The new
+ * instance will receive and process messages from the client session.
+ *
+ * @param client an instance of RemoteNameServiceClient which may be used to
+ * send messages to the client session.
+ * @return a new instance implementing NameServiceServer (typically
+ * ImplNameServiceServer).
+ * @throws Exception
+ */
+ public NameServiceServer newNameServiceServer( RemoteNameServiceClient client )
+ throws Exception;
+ }
+
+ /**
+ * Constructs a new client session per specifications in uri and resources.
+ *
+ * @param uri contains specifications for the client session transport
+ * stack.
+ *
+ * @param resources additional resources to aid in constructing new client
+ * sessions.
+ *
+ * @param implFactory factory used to construct a new instance implementing
+ * NameServiceClient. The new instance will receive and process messages from
+ * the server session.
+ *
+ * @return an instance of RemoteNameServiceServer initialized by uri and
+ * resources which may be used to send messages to the server session.
+ *
+ * @throws Exception
+ */
+ public static RemoteNameServiceServer newServer( String uri,
+ Resources resources, NameServiceClientFactory implFactory )
+ throws Exception
+ {
+ final Resources res = initResources( resources );
+
+ final ValueFactoryNameService vf = new ValueFactoryNameService( uri );
+ res.put( Transport.VALUE_FACTORY, vf );
+
+ URL u = new URL( uri );
+
+ TransportMessage m = TransportFactory.getTransport( uri, res );
+ MailboxManager r = new PlainMailboxManager( m, u, resources );
+ DeliveryService d = new DefaultDeliveryService( r, u, resources );
+ RemoteNameServiceServer server = new RemoteNameServiceServer( d, vf );
+ NameServiceClient client = implFactory.newNameServiceClient( server );
+ Pool qp = (Pool) res.get( QUEUED_POOL );
+ Pool fp = (Pool) res.get( FREE_POOL );
+ new StubNameServiceClient( d, client, qp, fp );
+
+ return server;
+ }
+
+ /**
+ * Factory used by
+ * {@link NameServiceHelper#newServer(String, Resources, NameServiceClientFactory)}
+ * to construct a new instance implementing {@link NameServiceClient}. The new
+ * instance will receive and process messages from the server session.
+ */
+ public interface NameServiceClientFactory
+ {
+ /**
+ * Constructs a new instance implementing NameServiceClient. The new
+ * instance will receive and process messages from the server session.
+ *
+ * @param server an instance of RemoteNameServiceServer which may be used to
+ * send messages to the server session.
+ * @return a new instance implementing NameServiceClient (typically
+ * ImplNameServiceClient).
+ * @throws Exception
+ */
+ public NameServiceClient newNameServiceClient( RemoteNameServiceServer server )
+ throws Exception;
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceHelper.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,265 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+
+
+/**
+ * The NameService provides translation from an abstract name for a service to a
+ * uri that may be used to contact the service. A given service may offer
+ * several different connection schemes, and a client may only support a subset
+ * of those. So, when a client wishes to connect to a service, it may query
+ * the NameService with both abstract name and desired schemes in order to find
+ * a suitable match.
+ *
+ * Some example queries:
+ *
+ * All services with servicename='Foo' and instancename='bar' and qualifier='tcp'
+ *
+ * sourceUri='Foo/bar/tcp'
+ *
+ * Same as the query above, but written out longhand:
+ *
+ * servicename='Foo' and instancename='bar' and qualifier='tcp'
+ *
+ * Fully qualified sourceUri:
+ *
+ * sourceUri='Foo/bar/tcp/1'
+ *
+ * Any instance of service Foo located in Austin, TX:
+ *
+ * servicename='Foo' and qualities.location='Austin, TX'
+ *
+ * Instances of service Foo with capacity >= 400:
+ *
+ * servicename='Foo' and qualities.capacity>=400
+ *
+ * Relative operations on qualities require that the quality be present and be
+ * comparable (with mixed types some type promotion is supported). But you might
+ * be surprised, qualities which are absent will give a negative comparison no
+ * matter which sense is used: both qualities.x > 50 and qualities.x < 50 are
+ * false whenever qualities.x is null. Consider this test: not qualities.x < 50.
+ * This is not the same as qualities.x >= 50. It is the same as qualities.x =
+ * null or qualities.x >= 50.
+ */
+@SuppressWarnings("unused")
+public interface NameServiceServer extends NameService
+{
+ /**
+ * Look up an entry by matching it against the sourceUri.
+ *
+ * @param source source uri
+ *
+ * @return entry matching the source uri. In the case of an
+ * absent instance name or qualifier, the implementation
+ * can decide which Entry to return.
+ */
+ public etch.services.ns.NameService.Entry lookup(
+ String source
+ )
+ ;
+ /**
+ * Looks up entries by matching them against the query string. Entries are
+ * returned in a stable and consistent order, increasing alphabetical by
+ * servicename, instancename, and scheme, and then increasing numerical by
+ * priority. If a scheme search term appears with a list, schemes are
+ * returned in the specified order (e.g., scheme='tls,tcp').
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ *
+ * @param offset offset in the list of matched items of the first item to
+ * return. This parameter and the count parameter are used to step through
+ * the result set when there are many results.
+ *
+ * @param count number of items to return.
+ *
+ * @return entries matching query. If you requested 10 items and 10 are
+ * returned, there could be more. To get the next batch, add results.length
+ * to offset and call find again:
+ *
+ * int i = 0;
+ * int n = 10;
+ * Entry[] results;
+ * while ((results = service.find( null, i, n )).length > 0)
+ * {
+ * for (Entry e: results)
+ * processEntry( e );
+ * if (results.length < n)
+ * break;
+ * i += results.length;
+ * }
+ */
+ public etch.services.ns.NameService.Entry[] find(
+ String query
+ , Integer offset
+ , Integer count
+ )
+ ;
+ /**
+ * Adds or updates the specified entry. The given parameters replace any
+ * existing values in an Entry whose key is sourceUri, whereas who and
+ * lastUpdate are set to the current user and current date / time,
+ * respectively.
+ *
+ * @param sourceUri the uri describing the service. The uri should be of
+ * the form "servicename/instancename/scheme[/priority]", where servicename
+ * is a valid fully qualified service name (e.g.,
+ * etch.services.ns.NameService"), instancename is a valid etch identifier
+ * (e.g, fred, alice01), scheme is a valid uri scheme (e.g., tcp, tls), and
+ * priority is an integer >= 1. If priority is omitted, it is defaulted to
+ * 1.
+ *
+ * @param qualities a map which may be used to describe additional features
+ * of the entry, such as purpose, licenses, capacity, location, owner,
+ * whatever. Query strings may test values of qualities using a variety of
+ * sql-like operators. Qualities may be null.
+ *
+ * @param targetUri the uri describing the contact information for the
+ * service.
+ *
+ * @param ttl the lifetime of the entry specified as seconds. 0 means
+ * forever, -1 means remove immediately when the connection to the
+ * NameService is dropped.
+ */
+ public void register(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ , Integer ttl
+ )
+ ;
+ /**
+ * Registers a number of entries all in one operation. Identical to calling
+ * register with each entry in turn.
+ *
+ * @param entries a sequence of Entry records with sourceUri, targetUri,
+ * qualities, and ttl as specified in register() above. Who and lastUpdate
+ * fields are ignored.
+ */
+ public void registerBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ ;
+ /**
+ * Removes the specified entry.
+ *
+ * @param sourceUri the uri describing the service.
+ */
+ public void unregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ ;
+ /**
+ * Adds a request for notification of changes to entries matching the query.
+ * The current value of all matching entries is delivered via entryChanged
+ * client message, as well as any updates or new entries.
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ */
+ public void subscribe(
+ String query
+ )
+ ;
+ /**
+ * Removes a request for notification of changes to entries matching the
+ * query.
+ *
+ * @param query a query previously passed to subscribe. The string must
+ * match exactly.
+ */
+ public void unsubscribe(
+ String query
+ )
+ ;
+ /**
+ * Removes all requests for notification of changes to entries. This
+ * operation is implicitly performed when the connection to the NameService
+ * is dropped.
+ */
+ public void unsubscribeAll(
+ )
+ ;
+ /**
+ * Tests whether the current user is authorized to lookup the source.
+ * @param source the complete specification api/instance/scheme.
+ */
+ public Boolean canLookup(
+ String source
+ )
+ ;
+ /**
+ * Tests whether the current user is authorized to run the query.
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ *
+ * @return true if the current user is authorized to run the query.
+ */
+ public Boolean canFind(
+ String query
+ )
+ ;
+ /**
+ * Tests whether the current user is authorized to register the service.
+ *
+ * @param sourceUri the uri describing the service.
+ *
+ * @param qualities a map which may be used to describe additional features
+ * of the entry.
+ *
+ * @param targetUri the actual uri of the service
+ *
+ * @return true if the current user is authorized to register the service.
+ */
+ public Boolean canRegister(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ )
+ ;
+ /**
+ * Tests whether the current user is authorized to unregister the service.
+ *
+ * @param sourceUri the uri describing the service.
+ *
+ * @param deleteEntry if true, the entire entry matching the sourceUri
+ * would be deleted. if false, only the target uri matching the sourceUri
+ * would be deleted, but the entry would be intact.
+ *
+ * @return true if the current user is authorized to register the service.
+ */
+ public Boolean canUnregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ ;
+ /**
+ * Tests whether the current user is authorized to register the entries.
+ * This is the same as:
+ *
+ * for (Entry entry: entries)
+ * if (!canRegister( entry.sourceUri, entry.qualities ))
+ * return false;
+ * return true;
+ *
+ * @param entries a sequence of Entry records with sourceUri, targetUri,
+ * qualities, and ttl as specified in register() above. Who and lastUpdate
+ * fields are ignored.
+ *
+ * @return true if the current user is authorized to register the entries.
+ * This is an all or nothing proposition.
+ */
+ public Boolean canRegisterBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ ;
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/NameServiceServer.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,50 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+
+/**
+ * Call to message translator for NameService.
+ */
+@SuppressWarnings("unused")
+public class RemoteNameService extends org.apache.etch.bindings.java.support.RemoteBase implements NameService
+{
+ /**
+ * Constructs the RemoteNameService.
+ *
+ * @param svc
+ * @param vf
+ */
+ public RemoteNameService( org.apache.etch.bindings.java.support.DeliveryService svc, org.apache.etch.bindings.java.msg.ValueFactory vf )
+ {
+ super( svc, vf );
+ }
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. Use this to invoke the asynchronous message
+ * implementations.
+ */
+ public final _Async _async = new _Async();
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. This is here for backwards compatibility only, use
+ * {@link #_async} instead.
+ * @deprecated
+ */
+ @Deprecated
+ public final _Async _inner = _async;
+
+ /**
+ * Asynchronous implementation of service methods.
+ */
+ public class _Async
+ {
+
+ // Mixin Methods
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameService.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,124 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+
+/**
+ * Call to message translator for NameServiceClient.
+ */
+@SuppressWarnings("unused")
+public final class RemoteNameServiceClient extends RemoteNameService implements NameServiceClient
+{
+ /**
+ * Constructs the RemoteNameServiceClient.
+ *
+ * @param svc
+ * @param vf
+ */
+ public RemoteNameServiceClient( org.apache.etch.bindings.java.support.DeliveryService svc, org.apache.etch.bindings.java.msg.ValueFactory vf )
+ {
+ super( svc, vf );
+ }
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. Use this to invoke the asynchronous message
+ * implementations.
+ */
+ public final _Async _async = new _Async();
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. This is here for backwards compatibility only, use
+ * {@link #_async} instead.
+ * @deprecated
+ */
+ @Deprecated
+ public final _Async _inner = _async;
+
+ public final void entryChanged(
+ String query
+ , etch.services.ns.NameService.Entry entry
+ )
+ {
+ _async._end_entryChanged( _async._begin_entryChanged(
+ query
+ , entry
+ ) );
+ }
+
+ /**
+ * Asynchronous implementation of service methods.
+ */
+ public final class _Async extends RemoteNameService._Async
+ {
+
+ /**
+ * Begins a call to entryChanged.
+ *
+ * Notifies the client of a change in an entry. The entry might have been
+ * created, updated, or removed.
+ *
+ * Note: while this might have normally been an event, we made it a call
+ * to slow down the processing of what might otherwise be a rather large
+ * change set.
+ *
+ * Note: when keeping track of entries, always keep the one with the latest
+ * lastUpdate.
+ *
+ * @param query the query which triggered the notification.
+ *
+ * @param entry the entry which has changed.
+ * @return mailbox used to retrieve the result using _end_entryChanged.
+ * @see RemoteNameServiceClient#entryChanged
+ * @see #_end_entryChanged
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_entryChanged(
+ String query
+ , etch.services.ns.NameService.Entry entry
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_entryChanged );
+ _msg.put( ValueFactoryNameService._mf_query, query );
+ _msg.put( ValueFactoryNameService._mf_entry, entry );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to entryChanged.
+ *
+ * Notifies the client of a change in an entry. The entry might have been
+ * created, updated, or removed.
+ *
+ * Note: while this might have normally been an event, we made it a call
+ * to slow down the processing of what might otherwise be a rather large
+ * change set.
+ *
+ * Note: when keeping track of entries, always keep the one with the latest
+ * lastUpdate.
+ *
+ * @param mb mailbox returned by _begin_entryChanged.
+ *
+ * @see RemoteNameServiceClient#entryChanged
+ * @see #_begin_entryChanged
+ */
+ public final void _end_entryChanged( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_entryChanged );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ // Mixin Methods
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceClient.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,885 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+
+/**
+ * Call to message translator for NameServiceServer.
+ */
+@SuppressWarnings("unused")
+public final class RemoteNameServiceServer extends RemoteNameService implements NameServiceServer
+{
+ /**
+ * Constructs the RemoteNameServiceServer.
+ *
+ * @param svc
+ * @param vf
+ */
+ public RemoteNameServiceServer( org.apache.etch.bindings.java.support.DeliveryService svc, org.apache.etch.bindings.java.msg.ValueFactory vf )
+ {
+ super( svc, vf );
+ }
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. Use this to invoke the asynchronous message
+ * implementations.
+ */
+ public final _Async _async = new _Async();
+
+ /**
+ * {@link _Async} class instance used to hide asynchronous message
+ * implementation. This is here for backwards compatibility only, use
+ * {@link #_async} instead.
+ * @deprecated
+ */
+ @Deprecated
+ public final _Async _inner = _async;
+
+ public final etch.services.ns.NameService.Entry lookup(
+ String source
+ )
+ {
+ return
+ _async._end_lookup( _async._begin_lookup(
+ source
+ ) );
+ }
+
+ public final etch.services.ns.NameService.Entry[] find(
+ String query
+ , Integer offset
+ , Integer count
+ )
+ {
+ return
+ _async._end_find( _async._begin_find(
+ query
+ , offset
+ , count
+ ) );
+ }
+
+ public final void register(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ , Integer ttl
+ )
+ {
+ _async._end_register( _async._begin_register(
+ sourceUri
+ , qualities
+ , targetUri
+ , ttl
+ ) );
+ }
+
+ public final void registerBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ {
+ _async._end_registerBulk( _async._begin_registerBulk(
+ entries
+ ) );
+ }
+
+ public final void unregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ {
+ _async._end_unregister( _async._begin_unregister(
+ sourceUri
+ , deleteEntry
+ ) );
+ }
+
+ public final void subscribe(
+ String query
+ )
+ {
+ _async._end_subscribe( _async._begin_subscribe(
+ query
+ ) );
+ }
+
+ public final void unsubscribe(
+ String query
+ )
+ {
+ _async._end_unsubscribe( _async._begin_unsubscribe(
+ query
+ ) );
+ }
+
+ public final void unsubscribeAll(
+ )
+ {
+ _async._end_unsubscribeAll( _async._begin_unsubscribeAll(
+ ) );
+ }
+
+ public final Boolean canLookup(
+ String source
+ )
+ {
+ return
+ _async._end_canLookup( _async._begin_canLookup(
+ source
+ ) );
+ }
+
+ public final Boolean canFind(
+ String query
+ )
+ {
+ return
+ _async._end_canFind( _async._begin_canFind(
+ query
+ ) );
+ }
+
+ public final Boolean canRegister(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ )
+ {
+ return
+ _async._end_canRegister( _async._begin_canRegister(
+ sourceUri
+ , qualities
+ , targetUri
+ ) );
+ }
+
+ public final Boolean canUnregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ {
+ return
+ _async._end_canUnregister( _async._begin_canUnregister(
+ sourceUri
+ , deleteEntry
+ ) );
+ }
+
+ public final Boolean canRegisterBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ {
+ return
+ _async._end_canRegisterBulk( _async._begin_canRegisterBulk(
+ entries
+ ) );
+ }
+
+ /**
+ * Asynchronous implementation of service methods.
+ */
+ public final class _Async extends RemoteNameService._Async
+ {
+
+ /**
+ * Begins a call to lookup.
+ *
+ * Look up an entry by matching it against the sourceUri.
+ *
+ * @param source source uri
+ *
+ * @return mailbox used to retrieve the result using _end_lookup.
+ * @see RemoteNameServiceServer#lookup
+ * @see #_end_lookup
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_lookup(
+ String source
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_lookup );
+ _msg.put( ValueFactoryNameService._mf_source, source );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to lookup.
+ *
+ * Look up an entry by matching it against the sourceUri.
+ *
+ * @param mb mailbox returned by _begin_lookup.
+ * @return entry matching the source uri. In the case of an
+ * absent instance name or qualifier, the implementation
+ * can decide which Entry to return.
+ *
+ * @see RemoteNameServiceServer#lookup
+ * @see #_begin_lookup
+ */
+ public final etch.services.ns.NameService.Entry _end_lookup( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (etch.services.ns.NameService.Entry)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_lookup );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to find.
+ *
+ * Looks up entries by matching them against the query string. Entries are
+ * returned in a stable and consistent order, increasing alphabetical by
+ * servicename, instancename, and scheme, and then increasing numerical by
+ * priority. If a scheme search term appears with a list, schemes are
+ * returned in the specified order (e.g., scheme='tls,tcp').
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ *
+ * @param offset offset in the list of matched items of the first item to
+ * return. This parameter and the count parameter are used to step through
+ * the result set when there are many results.
+ *
+ * @param count number of items to return.
+ *
+ * @return mailbox used to retrieve the result using _end_find.
+ * @see RemoteNameServiceServer#find
+ * @see #_end_find
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_find(
+ String query
+ , Integer offset
+ , Integer count
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_find );
+ _msg.put( ValueFactoryNameService._mf_query, query );
+ _msg.put( ValueFactoryNameService._mf_offset, offset );
+ _msg.put( ValueFactoryNameService._mf_count, count );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to find.
+ *
+ * Looks up entries by matching them against the query string. Entries are
+ * returned in a stable and consistent order, increasing alphabetical by
+ * servicename, instancename, and scheme, and then increasing numerical by
+ * priority. If a scheme search term appears with a list, schemes are
+ * returned in the specified order (e.g., scheme='tls,tcp').
+ *
+ * @param mb mailbox returned by _begin_find.
+ * @return entries matching query. If you requested 10 items and 10 are
+ * returned, there could be more. To get the next batch, add results.length
+ * to offset and call find again:
+ *
+ * int i = 0;
+ * int n = 10;
+ * Entry[] results;
+ * while ((results = service.find( null, i, n )).length > 0)
+ * {
+ * for (Entry e: results)
+ * processEntry( e );
+ * if (results.length < n)
+ * break;
+ * i += results.length;
+ * }
+ *
+ * @see RemoteNameServiceServer#find
+ * @see #_begin_find
+ */
+ public final etch.services.ns.NameService.Entry[] _end_find( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (etch.services.ns.NameService.Entry[])
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_find );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to register.
+ *
+ * Adds or updates the specified entry. The given parameters replace any
+ * existing values in an Entry whose key is sourceUri, whereas who and
+ * lastUpdate are set to the current user and current date / time,
+ * respectively.
+ *
+ * @param sourceUri the uri describing the service. The uri should be of
+ * the form "servicename/instancename/scheme[/priority]", where servicename
+ * is a valid fully qualified service name (e.g.,
+ * etch.services.ns.NameService"), instancename is a valid etch identifier
+ * (e.g, fred, alice01), scheme is a valid uri scheme (e.g., tcp, tls), and
+ * priority is an integer >= 1. If priority is omitted, it is defaulted to
+ * 1.
+ *
+ * @param qualities a map which may be used to describe additional features
+ * of the entry, such as purpose, licenses, capacity, location, owner,
+ * whatever. Query strings may test values of qualities using a variety of
+ * sql-like operators. Qualities may be null.
+ *
+ * @param targetUri the uri describing the contact information for the
+ * service.
+ *
+ * @param ttl the lifetime of the entry specified as seconds. 0 means
+ * forever, -1 means remove immediately when the connection to the
+ * NameService is dropped.
+ * @return mailbox used to retrieve the result using _end_register.
+ * @see RemoteNameServiceServer#register
+ * @see #_end_register
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_register(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ , Integer ttl
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_register );
+ _msg.put( ValueFactoryNameService._mf_sourceUri, sourceUri );
+ _msg.put( ValueFactoryNameService._mf_qualities, qualities );
+ _msg.put( ValueFactoryNameService._mf_targetUri, targetUri );
+ _msg.put( ValueFactoryNameService._mf_ttl, ttl );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to register.
+ *
+ * Adds or updates the specified entry. The given parameters replace any
+ * existing values in an Entry whose key is sourceUri, whereas who and
+ * lastUpdate are set to the current user and current date / time,
+ * respectively.
+ *
+ * @param mb mailbox returned by _begin_register.
+ *
+ * @see RemoteNameServiceServer#register
+ * @see #_begin_register
+ */
+ public final void _end_register( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_register );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to registerBulk.
+ *
+ * Registers a number of entries all in one operation. Identical to calling
+ * register with each entry in turn.
+ *
+ * @param entries a sequence of Entry records with sourceUri, targetUri,
+ * qualities, and ttl as specified in register() above. Who and lastUpdate
+ * fields are ignored.
+ * @return mailbox used to retrieve the result using _end_registerBulk.
+ * @see RemoteNameServiceServer#registerBulk
+ * @see #_end_registerBulk
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_registerBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_registerBulk );
+ _msg.put( ValueFactoryNameService._mf_entries, entries );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to registerBulk.
+ *
+ * Registers a number of entries all in one operation. Identical to calling
+ * register with each entry in turn.
+ *
+ * @param mb mailbox returned by _begin_registerBulk.
+ *
+ * @see RemoteNameServiceServer#registerBulk
+ * @see #_begin_registerBulk
+ */
+ public final void _end_registerBulk( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_registerBulk );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to unregister.
+ *
+ * Removes the specified entry.
+ *
+ * @param sourceUri the uri describing the service.
+ * @return mailbox used to retrieve the result using _end_unregister.
+ * @see RemoteNameServiceServer#unregister
+ * @see #_end_unregister
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_unregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_unregister );
+ _msg.put( ValueFactoryNameService._mf_sourceUri, sourceUri );
+ _msg.put( ValueFactoryNameService._mf_deleteEntry, deleteEntry );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to unregister.
+ *
+ * Removes the specified entry.
+ *
+ * @param mb mailbox returned by _begin_unregister.
+ *
+ * @see RemoteNameServiceServer#unregister
+ * @see #_begin_unregister
+ */
+ public final void _end_unregister( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_unregister );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to subscribe.
+ *
+ * Adds a request for notification of changes to entries matching the query.
+ * The current value of all matching entries is delivered via entryChanged
+ * client message, as well as any updates or new entries.
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ * @return mailbox used to retrieve the result using _end_subscribe.
+ * @see RemoteNameServiceServer#subscribe
+ * @see #_end_subscribe
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_subscribe(
+ String query
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_subscribe );
+ _msg.put( ValueFactoryNameService._mf_query, query );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to subscribe.
+ *
+ * Adds a request for notification of changes to entries matching the query.
+ * The current value of all matching entries is delivered via entryChanged
+ * client message, as well as any updates or new entries.
+ *
+ * @param mb mailbox returned by _begin_subscribe.
+ *
+ * @see RemoteNameServiceServer#subscribe
+ * @see #_begin_subscribe
+ */
+ public final void _end_subscribe( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_subscribe );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to unsubscribe.
+ *
+ * Removes a request for notification of changes to entries matching the
+ * query.
+ *
+ * @param query a query previously passed to subscribe. The string must
+ * match exactly.
+ * @return mailbox used to retrieve the result using _end_unsubscribe.
+ * @see RemoteNameServiceServer#unsubscribe
+ * @see #_end_unsubscribe
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_unsubscribe(
+ String query
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_unsubscribe );
+ _msg.put( ValueFactoryNameService._mf_query, query );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to unsubscribe.
+ *
+ * Removes a request for notification of changes to entries matching the
+ * query.
+ *
+ * @param mb mailbox returned by _begin_unsubscribe.
+ *
+ * @see RemoteNameServiceServer#unsubscribe
+ * @see #_begin_unsubscribe
+ */
+ public final void _end_unsubscribe( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_unsubscribe );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to unsubscribeAll.
+ *
+ * Removes all requests for notification of changes to entries. This
+ * operation is implicitly performed when the connection to the NameService
+ * is dropped.
+ * @return mailbox used to retrieve the result using _end_unsubscribeAll.
+ * @see RemoteNameServiceServer#unsubscribeAll
+ * @see #_end_unsubscribeAll
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_unsubscribeAll(
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_unsubscribeAll );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to unsubscribeAll.
+ *
+ * Removes all requests for notification of changes to entries. This
+ * operation is implicitly performed when the connection to the NameService
+ * is dropped.
+ * @param mb mailbox returned by _begin_unsubscribeAll.
+ *
+ * @see RemoteNameServiceServer#unsubscribeAll
+ * @see #_begin_unsubscribeAll
+ */
+ public final void _end_unsubscribeAll( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_unsubscribeAll );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to canLookup.
+ *
+ * Tests whether the current user is authorized to lookup the source.
+ * @param source the complete specification api/instance/scheme.
+ * @return mailbox used to retrieve the result using _end_canLookup.
+ * @see RemoteNameServiceServer#canLookup
+ * @see #_end_canLookup
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_canLookup(
+ String source
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_canLookup );
+ _msg.put( ValueFactoryNameService._mf_source, source );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to canLookup.
+ *
+ * Tests whether the current user is authorized to lookup the source.
+ * @param mb mailbox returned by _begin_canLookup.
+ *
+ * @see RemoteNameServiceServer#canLookup
+ * @see #_begin_canLookup
+ */
+ public final Boolean _end_canLookup( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (Boolean)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_canLookup );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to canFind.
+ *
+ * Tests whether the current user is authorized to run the query.
+ *
+ * @param query a sql-like query expression using the elements of the
+ * sourceUri, targetUri, and qualities. If query is null or the empty
+ * string, all entries are matched.
+ *
+ * @return mailbox used to retrieve the result using _end_canFind.
+ * @see RemoteNameServiceServer#canFind
+ * @see #_end_canFind
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_canFind(
+ String query
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_canFind );
+ _msg.put( ValueFactoryNameService._mf_query, query );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to canFind.
+ *
+ * Tests whether the current user is authorized to run the query.
+ *
+ * @param mb mailbox returned by _begin_canFind.
+ * @return true if the current user is authorized to run the query.
+ *
+ * @see RemoteNameServiceServer#canFind
+ * @see #_begin_canFind
+ */
+ public final Boolean _end_canFind( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (Boolean)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_canFind );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to canRegister.
+ *
+ * Tests whether the current user is authorized to register the service.
+ *
+ * @param sourceUri the uri describing the service.
+ *
+ * @param qualities a map which may be used to describe additional features
+ * of the entry.
+ *
+ * @param targetUri the actual uri of the service
+ *
+ * @return mailbox used to retrieve the result using _end_canRegister.
+ * @see RemoteNameServiceServer#canRegister
+ * @see #_end_canRegister
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_canRegister(
+ String sourceUri
+ , java.util.Map<?, ?> qualities
+ , String targetUri
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_canRegister );
+ _msg.put( ValueFactoryNameService._mf_sourceUri, sourceUri );
+ _msg.put( ValueFactoryNameService._mf_qualities, qualities );
+ _msg.put( ValueFactoryNameService._mf_targetUri, targetUri );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to canRegister.
+ *
+ * Tests whether the current user is authorized to register the service.
+ *
+ * @param mb mailbox returned by _begin_canRegister.
+ * @return true if the current user is authorized to register the service.
+ *
+ * @see RemoteNameServiceServer#canRegister
+ * @see #_begin_canRegister
+ */
+ public final Boolean _end_canRegister( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (Boolean)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_canRegister );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to canUnregister.
+ *
+ * Tests whether the current user is authorized to unregister the service.
+ *
+ * @param sourceUri the uri describing the service.
+ *
+ * @param deleteEntry if true, the entire entry matching the sourceUri
+ * would be deleted. if false, only the target uri matching the sourceUri
+ * would be deleted, but the entry would be intact.
+ *
+ * @return mailbox used to retrieve the result using _end_canUnregister.
+ * @see RemoteNameServiceServer#canUnregister
+ * @see #_end_canUnregister
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_canUnregister(
+ String sourceUri
+ , Boolean deleteEntry
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_canUnregister );
+ _msg.put( ValueFactoryNameService._mf_sourceUri, sourceUri );
+ _msg.put( ValueFactoryNameService._mf_deleteEntry, deleteEntry );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to canUnregister.
+ *
+ * Tests whether the current user is authorized to unregister the service.
+ *
+ * @param mb mailbox returned by _begin_canUnregister.
+ * @return true if the current user is authorized to register the service.
+ *
+ * @see RemoteNameServiceServer#canUnregister
+ * @see #_begin_canUnregister
+ */
+ public final Boolean _end_canUnregister( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (Boolean)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_canUnregister );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ /**
+ * Begins a call to canRegisterBulk.
+ *
+ * Tests whether the current user is authorized to register the entries.
+ * This is the same as:
+ *
+ * for (Entry entry: entries)
+ * if (!canRegister( entry.sourceUri, entry.qualities ))
+ * return false;
+ * return true;
+ *
+ * @param entries a sequence of Entry records with sourceUri, targetUri,
+ * qualities, and ttl as specified in register() above. Who and lastUpdate
+ * fields are ignored.
+ *
+ * @return mailbox used to retrieve the result using _end_canRegisterBulk.
+ * @see RemoteNameServiceServer#canRegisterBulk
+ * @see #_end_canRegisterBulk
+ */
+ public final org.apache.etch.bindings.java.support.Mailbox _begin_canRegisterBulk(
+ etch.services.ns.NameService.Entry[] entries
+ )
+ {
+ org.apache.etch.bindings.java.msg.Message _msg = _newMessage( ValueFactoryNameService._mt_etch_services_ns_NameService_canRegisterBulk );
+ _msg.put( ValueFactoryNameService._mf_entries, entries );
+ return _begincall( _msg );
+ }
+
+ /**
+ * Ends a call to canRegisterBulk.
+ *
+ * Tests whether the current user is authorized to register the entries.
+ * This is the same as:
+ *
+ * for (Entry entry: entries)
+ * if (!canRegister( entry.sourceUri, entry.qualities ))
+ * return false;
+ * return true;
+ *
+ * @param mb mailbox returned by _begin_canRegisterBulk.
+ * @return true if the current user is authorized to register the entries.
+ * This is an all or nothing proposition.
+ *
+ * @see RemoteNameServiceServer#canRegisterBulk
+ * @see #_begin_canRegisterBulk
+ */
+ public final Boolean _end_canRegisterBulk( org.apache.etch.bindings.java.support.Mailbox mb )
+ {
+ try
+ {
+ return
+ (Boolean)
+ _endcall( mb,
+ ValueFactoryNameService._mt_etch_services_ns_NameService__result_canRegisterBulk );
+ }
+ catch ( Exception e )
+ {
+ if (e instanceof RuntimeException) throw (RuntimeException) e;
+ throw new RuntimeException( "unexpected exception from peer: "+e, e );
+ }
+ }
+
+ // Mixin Methods
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/RemoteNameServiceServer.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,51 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+import org.apache.etch.util.core.Who;
+import org.apache.etch.bindings.java.msg.Message;
+import org.apache.etch.bindings.java.support.DeliveryService;
+import org.apache.etch.bindings.java.support.Pool;
+import org.apache.etch.bindings.java.support.StubHelper;
+import org.apache.etch.bindings.java.support._Etch_AuthException;
+import org.apache.etch.bindings.java.support.StubBase;
+import org.apache.etch.bindings.java.support.Pool.PoolRunnable;
+
+/**
+ * Message to call translator for NameService.
+ * @param <T> NameService or a subclass thereof.
+ */
+@SuppressWarnings("unused")
+public class StubNameService<T extends NameService> extends StubBase<T>
+{
+ /**
+ * Stub for NameService.
+ * @param svc the delivery service.
+ * @param obj the implementation of NameService responsive to requests.
+ * @param queued thread pool used to run AsyncMode.QUEUED methods.
+ * @param free thread pool used to run AsyncMode.FREE methods.
+ */
+ public StubNameService( DeliveryService svc, T obj, Pool queued, Pool free )
+ {
+ super( svc, obj, queued, free );
+ }
+
+ static
+ {
+ }
+
+ /**
+ * Method used to force static initialization.
+ */
+ public static void init()
+ {
+ // nothing to do.
+ }
+
+ static
+ {
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameService.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,69 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+import org.apache.etch.util.core.Who;
+import org.apache.etch.bindings.java.msg.Message;
+import org.apache.etch.bindings.java.support.DeliveryService;
+import org.apache.etch.bindings.java.support.Pool;
+import org.apache.etch.bindings.java.support.StubHelper;
+import org.apache.etch.bindings.java.support._Etch_AuthException;
+import org.apache.etch.bindings.java.support.Pool.PoolRunnable;
+
+/**
+ * Message to call translator for NameServiceClient.
+ */
+@SuppressWarnings("unused")
+public class StubNameServiceClient extends StubNameService<NameServiceClient>
+{
+ /**
+ * Stub for NameServiceClient.
+ * @param svc the delivery service.
+ * @param obj the implementation of NameServiceClient responsive to requests.
+ * @param queued thread pool used to run AsyncMode.QUEUED methods.
+ * @param free thread pool used to run AsyncMode.FREE methods.
+ */
+ public StubNameServiceClient( DeliveryService svc, NameServiceClient obj, Pool queued, Pool free )
+ {
+ super( svc, obj, queued, free );
+ }
+
+ static
+ {
+ }
+
+ /**
+ * Method used to force static initialization.
+ */
+ public static void init()
+ {
+ // nothing to do.
+ }
+
+ static
+ {
+ ValueFactoryNameService._mt_etch_services_ns_NameService_entryChanged.setStubHelper( new StubHelper<NameServiceClient>()
+ {
+ public final void run( DeliveryService _svc, NameServiceClient _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _obj.entryChanged(
+ (String) _msg.get( ValueFactoryNameService._mf_query )
+ , (etch.services.ns.NameService.Entry) _msg.get( ValueFactoryNameService._mf_entry )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceClient.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"
Added: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java
URL: http://svn.apache.org/viewvc/incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java?rev=746631&view=auto
==============================================================================
--- incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java (added)
+++ incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java Sun Feb 22 04:17:56 2009
@@ -0,0 +1,357 @@
+// This file automatically generated by:
+// Apache Etch 1.1.0-incubating (LOCAL-0) / java 1.1.0-incubating (LOCAL-0)
+// Sat Feb 21 22:11:51 CST 2009
+// This file is automatically created and should not be edited!
+
+package etch.services.ns;
+
+import org.apache.etch.util.core.Who;
+import org.apache.etch.bindings.java.msg.Message;
+import org.apache.etch.bindings.java.support.DeliveryService;
+import org.apache.etch.bindings.java.support.Pool;
+import org.apache.etch.bindings.java.support.StubHelper;
+import org.apache.etch.bindings.java.support._Etch_AuthException;
+import org.apache.etch.bindings.java.support.Pool.PoolRunnable;
+
+/**
+ * Message to call translator for NameServiceServer.
+ */
+@SuppressWarnings("unused")
+public class StubNameServiceServer extends StubNameService<NameServiceServer>
+{
+ /**
+ * Stub for NameServiceServer.
+ * @param svc the delivery service.
+ * @param obj the implementation of NameServiceServer responsive to requests.
+ * @param queued thread pool used to run AsyncMode.QUEUED methods.
+ * @param free thread pool used to run AsyncMode.FREE methods.
+ */
+ public StubNameServiceServer( DeliveryService svc, NameServiceServer obj, Pool queued, Pool free )
+ {
+ super( svc, obj, queued, free );
+ }
+
+ static
+ {
+ }
+
+ /**
+ * Method used to force static initialization.
+ */
+ public static void init()
+ {
+ // nothing to do.
+ }
+
+ static
+ {
+ ValueFactoryNameService._mt_etch_services_ns_NameService_lookup.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ String source = (String) _msg.get( ValueFactoryNameService._mf_source );
+ if (!_obj.canLookup(
+ source
+ ))
+ throw new _Etch_AuthException( "stub could not authorize lookup using canLookup" );
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.lookup(
+ source
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_find.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ String query = (String) _msg.get( ValueFactoryNameService._mf_query );
+ Integer offset = (Integer) _msg.get( ValueFactoryNameService._mf_offset );
+ Integer count = (Integer) _msg.get( ValueFactoryNameService._mf_count );
+ if (!_obj.canFind(
+ query
+ ))
+ throw new _Etch_AuthException( "stub could not authorize find using canFind" );
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.find(
+ query
+ , offset
+ , count
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_register.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ String sourceUri = (String) _msg.get( ValueFactoryNameService._mf_sourceUri );
+ java.util.Map<?, ?> qualities = (java.util.Map<?, ?>) _msg.get( ValueFactoryNameService._mf_qualities );
+ String targetUri = (String) _msg.get( ValueFactoryNameService._mf_targetUri );
+ Integer ttl = (Integer) _msg.get( ValueFactoryNameService._mf_ttl );
+ if (!_obj.canRegister(
+ sourceUri
+ , qualities
+ , targetUri
+ ))
+ throw new _Etch_AuthException( "stub could not authorize register using canRegister" );
+ _obj.register(
+ sourceUri
+ , qualities
+ , targetUri
+ , ttl
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_registerBulk.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ etch.services.ns.NameService.Entry[] entries = (etch.services.ns.NameService.Entry[]) _msg.get( ValueFactoryNameService._mf_entries );
+ if (!_obj.canRegisterBulk(
+ entries
+ ))
+ throw new _Etch_AuthException( "stub could not authorize registerBulk using canRegisterBulk" );
+ _obj.registerBulk(
+ entries
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_unregister.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ String sourceUri = (String) _msg.get( ValueFactoryNameService._mf_sourceUri );
+ Boolean deleteEntry = (Boolean) _msg.get( ValueFactoryNameService._mf_deleteEntry );
+ if (!_obj.canUnregister(
+ sourceUri
+ , deleteEntry
+ ))
+ throw new _Etch_AuthException( "stub could not authorize unregister using canUnregister" );
+ _obj.unregister(
+ sourceUri
+ , deleteEntry
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_subscribe.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ String query = (String) _msg.get( ValueFactoryNameService._mf_query );
+ if (!_obj.canFind(
+ query
+ ))
+ throw new _Etch_AuthException( "stub could not authorize subscribe using canFind" );
+ _obj.subscribe(
+ query
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_unsubscribe.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _obj.unsubscribe(
+ (String) _msg.get( ValueFactoryNameService._mf_query )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_unsubscribeAll.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _obj.unsubscribeAll(
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_canLookup.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.canLookup(
+ (String) _msg.get( ValueFactoryNameService._mf_source )
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_canFind.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.canFind(
+ (String) _msg.get( ValueFactoryNameService._mf_query )
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_canRegister.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.canRegister(
+ (String) _msg.get( ValueFactoryNameService._mf_sourceUri )
+ , (java.util.Map<?, ?>) _msg.get( ValueFactoryNameService._mf_qualities )
+ , (String) _msg.get( ValueFactoryNameService._mf_targetUri )
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_canUnregister.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.canUnregister(
+ (String) _msg.get( ValueFactoryNameService._mf_sourceUri )
+ , (Boolean) _msg.get( ValueFactoryNameService._mf_deleteEntry )
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ ValueFactoryNameService._mt_etch_services_ns_NameService_canRegisterBulk.setStubHelper( new StubHelper<NameServiceServer>()
+ {
+ public final void run( DeliveryService _svc, NameServiceServer _obj, Who _sender, Message _msg ) throws Exception
+ {
+ final Message _rmsg = _msg.reply();
+ try
+ {
+ _rmsg.put( ValueFactoryNameService._mf_result,
+ _obj.canRegisterBulk(
+ (etch.services.ns.NameService.Entry[]) _msg.get( ValueFactoryNameService._mf_entries )
+ )
+ );
+ }
+ catch ( Exception e )
+ {
+ sessionNotify( _obj, e );
+ _rmsg.put( ValueFactoryNameService._mf_result, e );
+ }
+ _svc.transportMessage( _sender, _rmsg );
+ }
+ } );
+ }
+}
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/etch/branches/name-service/services/ns/target/generated-sources/main/etch/java/etch/services/ns/StubNameServiceServer.java
------------------------------------------------------------------------------
svn:keywords = "Author Date Id Revision"