Examples of net.jini.space.JavaSpace05.take()

net.jini.space.JavaSpace05.take()
This method provides an overload of the {@link JavaSpace#take JavaSpace.take} method that attempts toremove, optionally under a {@link Transaction}, and return one or more entries from the space. Each {@link Entry}taken will match one or more elements of the passed {@link Collection} of templates, and all of the taken entries willbe visible to the passed Transaction. If there are initially no matches in the space that are visible to the passed Transaction, an invocation of this method will block for up to a specified timeout for one or more matches to appear.
The effect on the space of an invocation of this method successfully taking an Entry will be the same as if the Entry had been taken using the singleton version of this method and passing txn as the Transaction.
The tmpls parameter must be a Collection of Entry instances to be used as templates. All of the entries taken must match one or more of these templates. The tmpls parameter may contain null values and may contain duplicates. An Entry is said to be available to an invocation of this method if the Entry could have been returned by an invocation of the singleton take method using txn.
If the method succeeds, a non-null Collection will be returned. The Collection will contain a copy of each Entry that was taken. If no entries were taken, the Collection will be empty. Each Entry taken will be represented by a distinct Entry instance in the returned Collection, even if some of the entries are equivalent to others taken by the operation. There will be no null elements in the returned Collection.
If one or more of the entries taken cannot be unmarshalled in the client, an {@link UnusableEntriesException} isthrown. The exception's {@link UnusableEntriesException#getEntries UnusableEntriesException.getEntries} method will return aCollection with a copy of each Entry that could be unmarshalled. The {@link UnusableEntriesException#getUnusableEntryExceptions UnusableEntriesException.getUnusableEntryExceptions} methodwill return a Collection with an {@link UnusableEntryException} for each Entry thatcould not be unmarshalled. Every Entry taken by the invocation will either be represented in the Collection returned by getEntries or in the Collection returned by getUnusableEntryExceptions.
If there is at least one matching Entry available in the space, an invocation of this method must take at least one Entry. If more than one matching Entry is available, the invocation may take additional entries. It must not take more than maxEntries, but an implementation may chose to take fewer entries from the space than the maximum available or the maximum allowed by maxEntries. If for whatever reason, an invocation of this method takes fewer entries than the maximum number of available matching entries, how an implementation selects which entries should be taken by the invocation and which are left in the space is unspecified. How consumption of entries is arbitrated between conflicting queries is also unspecified.
If there are initially no matching entries in the space, an invocation of this method should block for up to timeout milliseconds for a match to appear. If one or more matches become available before timeout expires, one or more of the newly available entries should be taken and the method should return without further blocking. If for some reason the invocation can't block for the full timeout and no entries have been taken, the invocation must fail with a {@link RemoteException} or {@link TransactionException} asappropriate.
If an invocation of this method removes (or locks) more than one Entry, the order in which the removal (or locking) occurs is undefined, and different observers may see the removal or locking of the entries in different orders.
If a TransactionException, {@link SecurityException}, {@link IllegalArgumentException}, or {@link NullPointerException} is thrown, no entries willhave been taken. If a RemoteException is thrown, up to maxEntries may have been taken by this operation.
@param tmpls a {@link Collection} of {@link Entry}instances, each representing a template. All of the entries taken by an invocation of this method will match one or more elements of tmpls @param txn the {@link Transaction} this operation should beperformed under, may be null @param timeout if there are initially no availablematches in the space, the maximum number of milliseconds to block waiting for a match to become available @param maxEntries the maximum number of entries that may betaken by this method @return a Collection that contains a copy of eachEntry taken from the space by this method. The space will not keep a reference to this Collection. May be immutable @throws UnusableEntriesException if one or more of theentries taken can't be unmarshalled in the client @throws TransactionException if txn isnon-null and is not usable by the space. @throws RemoteException if a communication error occurs @throws IllegalArgumentException if any non-nullelement of tmpls is not an instance of Entry, if tmpls is empty, if timeout is negative, or if maxEntries is non-positive @throws NullPointerException if tmpls is null

         * and entries 2 and 3 only once.
         */
        SimpleEntry result = (SimpleEntry) space05.take(sampleEntry1, null,
                                                        checkTime);
        result = (SimpleEntry) space05.take(sampleEntry1, null, checkTime);
        result = (SimpleEntry) space05.take(sampleEntry1, null, checkTime);
        if (result == null) {
            throw new TestException("performed 2-nd and 3-rd write "
                    + "operation for the same " + sampleEntry1
                    + " with " + leaseTime1 + " lease time and "
                    + leaseTime2 + " lease time and all or some "

View Full Code Here

                    + "operation for the same " + sampleEntry1
                    + " with " + leaseTime1 + " lease time and "
                    + leaseTime2 + " lease time and all or some "
                    + "of the entries can not be taken");
        }
        result = (SimpleEntry) space05.take(sampleEntry2, null, checkTime);
        if (result == null) {
            throw new TestException(sampleEntry2 + " with " + leaseTime1
                                    + " lease time"
                                    + " is not available in the space.");
        }

View Full Code Here

        if (result == null) {
            throw new TestException(sampleEntry2 + " with " + leaseTime1
                                    + " lease time"
                                    + " is not available in the space.");
        }
        result = (SimpleEntry) space05.take(sampleEntry3, null, checkTime);
        if (result == null) {
            throw new TestException(sampleEntry3 + " with " + leaseTime2
                                    + " lease time"
                                    + " is not available in the space.");
        }

View Full Code Here

        txn = getTransaction();
        templates.add((SimpleEntry) sampleEntry1.clone());
        templates.add("Not an antry");
        JavaSpace05 space05 = (JavaSpace05) space;
        try {
            space05.take(templates, txn, instantTime, MAX_ENTRIES);
            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when templates contain not an instance "
                                    + "of Entry element");
        } catch (IllegalArgumentException e) {}

View Full Code Here

                                    + "of Entry element");
        } catch (IllegalArgumentException e) {}


        templates.clear();
        try {
            space05.take(templates, txn, instantTime, MAX_ENTRIES);
            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when templates is empty");
        } catch (IllegalArgumentException e) {}


        templates.add((SimpleEntry) sampleEntry1.clone());

View Full Code Here

                                    + "when templates is empty");
        } catch (IllegalArgumentException e) {}


        templates.add((SimpleEntry) sampleEntry1.clone());
        try {
            space05.take(templates, txn, -1, MAX_ENTRIES);
            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when timout is negative (-1)");
        } catch (IllegalArgumentException e) {}


        try {

View Full Code Here

            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when timout is negative (-1)");
        } catch (IllegalArgumentException e) {}


        try {
            space05.take(templates, txn, instantTime, 0);
            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when maxEntries is non-positive (0)");
        } catch (IllegalArgumentException e) {}


        try {

View Full Code Here

            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when maxEntries is non-positive (0)");
        } catch (IllegalArgumentException e) {}


        try {
            space05.take(templates, txn, instantTime, -1);
            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when maxEntries is non-positive (-1)");
        } catch (IllegalArgumentException e) {}


        try {

View Full Code Here

            throw new TestException("IllegalArgumentException is not thrown "
                                    + "when maxEntries is non-positive (-1)");
        } catch (IllegalArgumentException e) {}


        try {
            space05.take(null, txn, instantTime, MAX_ENTRIES);
            throw new TestException("NullPointerException is not thrown "
                                    + "when templates is null");
        } catch (NullPointerException e) {}


        txn.commit();

View Full Code Here


        txn.commit();


        // transaction txn is not null and is not usable by the space
        try {
            space05.take(templates, txn, instantTime, MAX_ENTRIES);
            throw new TestException("TransactionException is not thrown "
                                    + "when taking from the space with "
                                    + "transaction which is not null "
                                    + "and is not usable by the space");
        } catch (TransactionException e) {}

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.