Examples of org.osgi.framework.ServiceRegistration.unregister()

Class org.osgi.framework.ServiceRegistration

Examples of org.osgi.framework.ServiceRegistration.unregister()

org.osgi.framework.ServiceRegistration.unregister()
Unregisters a service. Remove a {@code ServiceRegistration} object fromthe Framework service registry. All {@code ServiceReference} objectsassociated with this {@code ServiceRegistration} object can no longer beused to interact with the service once unregistration is complete.
The following steps are required to unregister a service:
1. The service is removed from the Framework service registry so that it can no longer be obtained.
2. A service event of type {@link ServiceEvent#UNREGISTERING} is firedso that bundles using this service can release their use of the service. Once delivery of the service event is complete, the {@code ServiceReference} objects for the service may no longer be used toget a service object for the service.
3. For each bundle whose use count for this service is greater than zero:
  - The bundle's use count for this service is set to zero.
  - If the service was registered with a {@link ServiceFactory} object,the {@code ServiceFactory.ungetService} method is called to release theservice object for the bundle.
@throws IllegalStateException If this {@code ServiceRegistration} objecthas already been unregistered. @see BundleContext#ungetService(ServiceReference) @see ServiceFactory#ungetService(Bundle,ServiceRegistration,Object)

            this.getJobManager().addJob(TOPIC, null);
            assertTrue("No event received in the given time.", cb.block(5));
            cb.reset();
            assertFalse("Unexpected event received in the given time.", cb.block(5));
        } finally {
            reg.unregister();
        }
    }


    @Test(timeout = DEFAULT_TEST_TIMEOUT)
    public void testManyJobs() throws Exception {

View Full Code Here

            }
            assertEquals("Finished count", COUNT, count.get());
            assertEquals("Finished count", COUNT, this.getJobManager().getStatistics().getNumberOfFinishedJobs());
        } finally {
            reg1.unregister();
            reg2.unregister();
        }
    }


    /**
     * Test canceling a job

View Full Code Here

                for(final Job j : col) {
                    jobManager.removeJobById(j.getId());
                }
            }
        } finally {
            jcReg.unregister();
        }
   }


    /**
     * Test get a job

View Full Code Here


            cb2.block(); // and continue job


            jobManager.removeJobById(j.getId());
        } finally {
            jcReg.unregister();
        }
    }


    /**
     * Reschedule test.

View Full Code Here

            assertFalse("Unexpected event received in the given time.", cb.block(5));
            assertEquals("Unexpected number of retries", 3, retryCountList.size());


            jobManager.removeJobById(job.getId());
        } finally {
            jcReg.unregister();
        }
    }


    /**
     * Notifications.

View Full Code Here

            }
            jcReg.unregister();
            eh1Reg.unregister();
            eh2Reg.unregister();
            eh3Reg.unregister();
            eh4Reg.unregister();
        }
    }


    /**
     * Test sending of jobs with and without a processor

View Full Code Here

            // now remove jobs
            for(final Job j : jobManager.findJobs(JobManager.QueryType.ALL, TOPIC + "2", -1, (Map<String, Object>[])null)) {
                jobManager.removeJobById(j.getId());
            }
        } finally {
            eh1.unregister();
        }
    }
}

View Full Code Here


            while ( counter.get() == 0 ) {
                this.sleep(1000);
            }
        } finally {
            ehReg.unregister();
        }
    }


    @Test(timeout = DEFAULT_TEST_TIMEOUT)
    public void testPeriodicTimedJob() throws Exception {

View Full Code Here

            this.sleep(2000);
            if ( counter.get() != current && counter.get() != current + 1 ) {
                fail("Events are still sent");
            }
        } finally {
            ehReg.unregister();
        }
    }
}

View Full Code Here

            assertEquals(map, finishedEvents.get(0).getProperty("map"));


            jobManager.removeJobById(jobId);
        } finally {
            jcReg.unregister();
            ehReg.unregister();
        }
    }


    @Test(timeout = DEFAULT_TEST_TIMEOUT)
    public void testFailedClassloading() throws Exception {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.