Examples of com.sun.sgs.app.ManagedObject

com.sun.sgs.app.ManagedObject
A marker interface implemented by shared, persistent objects managed by {@link DataManager}. Classes that implement {@code ManagedObject} must alsoimplement {@link Serializable}, as should any non-managed objects they refer to. Any instances of {@code ManagedObject} that a managed object refers todirectly, or indirectly through non-managed objects, need to be referred to through instances of {@link ManagedReference}.
Classes that implement {@code ManagedObject} should not provide {@code writeReplace} or {@code readRestore} methods to designate replacementobjects during serialization. Object replacement would interfere with the object identity maintained by the {@code DataManager}, and is not permitted.
Classes that implement {@code ManagedObject} can provide {@code readObject}and {@code writeObject} methods to customize their serialization behavior,but the {@code writeObject} methods should not perform calls to methods thatrequire a current transaction. @see DataManager @see ManagedReference @see Serializable

                DataServiceMXBean.class);
        
        // Test that consumer level can be changed
        txnScheduler.runTask(new TestAbstractKernelRunnable() {
    public void run() {
                    ManagedObject dummy = new DummyManagedObject();
                    serverNode.getDataService().setBinding("dummy", dummy);
    }}, taskOwner);
        assertEquals(0, dataProxy.getSetBindingCalls());
        
        proxy.setConsumerLevel(consName, ProfileLevel.MAX);
        assertEquals(ProfileLevel.MAX, proxy.getConsumerLevel(consName));
        
        txnScheduler.runTask(new TestAbstractKernelRunnable() {
    public void run() {
                    ManagedObject dummy = new DummyManagedObject();
                    serverNode.getDataService().setBinding("dummy", dummy);
    }}, taskOwner);
        assertTrue(dataProxy.getSetBindingCalls() > 0);
    }

View Full Code Here


    /** Obtains the object associated with the specified internal name. */
    ManagedObject getBinding(String internalName, boolean forUpdate) {
  long id = store.getBinding(txn, internalName);
  assert id >= 0 : "Object ID must not be negative";
  ManagedObject result;
  if (forUpdate) {
      result = (ManagedObject) getReference(id).getForUpdate(false);
  } else {
      result = (ManagedObject) getReference(id).get(false);
  }

View Full Code Here

    /** Adds a new managed reference to this table. */
    void add(ManagedReferenceImpl<?> ref) {
  assert !oids.containsKey(ref.oid)
      : "Found existing reference for oid:" + ref.oid;
  oids.put(ref.oid, ref);
  ManagedObject object = ref.getObject();
  if (object != null) {
      assert !objects.containsKey(object)
    : "Found existing reference for object with oid:" + ref.oid;
      objects.put(object, ref);
  }

View Full Code Here

    /** Removes a managed reference from this table. */
    void remove(ManagedReferenceImpl<?> ref) {
  Object existing = oids.remove(ref.oid);
  assert existing == ref
      : "Found duplicate reference for oid:" + ref.oid;
  ManagedObject object = ref.getObject();
  if (object != null) {
      existing = objects.remove(object);
      assert existing == ref
    : "Found duplicate reference for oid:" + ref.oid;
  }

View Full Code Here

  testSetBindingNotSerializable(false);
    }
    private void testSetBindingNotSerializable(final boolean app)
        throws Exception
    {
  final ManagedObject mo = new ManagedObject() { };
        txnScheduler.runTask(new InitialTestRunnable() {
            public void run() throws Exception {
                super.run();
                try {
                    setBinding(app, service, "dummy", mo);

View Full Code Here

    @Test 
    public void testRemoveObjectNotSerializable() throws Exception {
        txnScheduler.runTask(new InitialTestRunnable() {
            public void run() throws Exception {
                super.run();
                ManagedObject mo = new ManagedObject() { };
                try {
                    service.removeObject(mo);
                    fail("Expected IllegalArgumentException");
                } catch (IllegalArgumentException e) {
                    System.err.println(e);

View Full Code Here

    @Test 
    public void testMarkForUpdateNotSerializable() throws Exception {
        txnScheduler.runTask(new InitialTestRunnable() {
            public void run() throws Exception {
                super.run();
                ManagedObject mo = new ManagedObject() { };
                try {
                    service.markForUpdate(mo);
                    fail("Expected IllegalArgumentException");
                } catch (IllegalArgumentException e) {
                    System.err.println(e);

View Full Code Here


    @Test 
    public void testCreateReferenceNotSerializable() throws Exception {
        txnScheduler.runTask(new TestAbstractKernelRunnable() {
            public void run() {
                ManagedObject mo = new ManagedObject() { };
                try {
                    service.createReference(mo);
                    fail("Expected IllegalArgumentException");
                } catch (IllegalArgumentException e) {
                    System.err.println(e);

View Full Code Here


    @Test 
    public void testGetObjectIdNotSerializable() throws Exception {
        txnScheduler.runTask(new TestAbstractKernelRunnable() {
            public void run() {
                ManagedObject mo = new ManagedObject() { };
                try {
                    service.getObjectId(mo);
                    fail("Expected IllegalArgumentException");
                } catch (IllegalArgumentException e) {
                    System.err.println(e);

View Full Code Here

         * 
         * @return the {@code AppListener} for the application
         */
        @SuppressWarnings("unchecked")
        private AppListener getAppListener() {
            ManagedObject obj = dataService.getServiceBinding(
                    StandardProperties.APP_LISTENER);
            return (obj instanceof AppListener) ?
                (AppListener) obj :
                ((ManagedSerializable<AppListener>) obj).get();
        }

View Full Code Here

0 1 2 3 4 5

TOP

Related Classes of com.sun.sgs.app.ManagedObject

com.sun.sgs.impl.service.data.Context

com.sun.sgs.impl.service.data.DataServiceImpl

com.sun.sgs.impl.service.data.ManagedReferenceImpl

com.sun.sgs.impl.service.data.ReferenceTable

com.sun.sgs.impl.service.session.ClientSessionHandler$LoginTask

com.sun.sgs.impl.service.session.ClientSessionImpl

com.sun.sgs.impl.util.BindingKeyedMapImpl

com.sun.sgs.impl.util.BindingKeyedMapImpl$AbstractIterator

com.sun.sgs.impl.util.BindingKeyedMapImpl$KeyValuePair

com.sun.sgs.impl.util.WrappedSerializable

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.