Java 类org.osgi.framework.InvalidSyntaxException 实例源码

项目：gemini.blueprint 文件：OsgiServiceDynamicInterceptorListenerTest.java

protected void setUp() throws Exception {
    listener = new SimpleTargetSourceLifecycleListener();

    refs = new ServiceReference[] { new MockServiceReference() };

    bundleContext = new MockBundleContext() {

        public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
            return refs;
        }
    };

    interceptor = new ServiceDynamicInterceptor(bundleContext, null, null, getClass().getClassLoader());
    interceptor.setListeners(new OsgiServiceLifecycleListener[] { listener });
    interceptor.setMandatoryService(false);
    interceptor.setProxy(new Object());
    interceptor.setServiceImporter(new Object());
    interceptor.setSticky(false);

    interceptor.setRetryTimeout(1);

    SimpleTargetSourceLifecycleListener.BIND = 0;
    SimpleTargetSourceLifecycleListener.UNBIND = 0;
}

项目：aries-jpa 文件：PersistenceProviderTracker.java

private static Filter createFilter(BundleContext context, PersistenceUnit punit) {
    String filter;
    if (punit.getPersistenceProviderClassName() != null) {
        filter = String.format("(&(objectClass=%s)(%s=%s))",
                               PersistenceProvider.class.getName(),
                               JAVAX_PERSISTENCE_PROVIDER,
                               punit.getPersistenceProviderClassName());
    } else {
        filter = String.format("(objectClass=%s)", PersistenceProvider.class.getName());
    }

    try {
        return context.createFilter(filter);
    } catch (InvalidSyntaxException e) {
        throw new IllegalArgumentException(e);
    }
}

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
public void testRegistersManagedEMF() throws InvalidSyntaxException, ConfigurationException {

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    verify(containerContext).registerService(eq(ManagedService.class),
            any(ManagedService.class), argThat(servicePropsMatcher(
                    SERVICE_PID, "org.apache.aries.jpa.test-props")));

    // No EMF created as incomplete
    verifyZeroInteractions(msReg, provider);

    emfb.close();
    verify(msReg).unregister();
}

项目：Core 文件：OSGiUtils.java

public static <E> List<E> getServices(BundleContext bundleContext, Class<E> serviceType, String filter)
        throws InvalidSyntaxException {
    List<E> services = null;
    final ServiceReference[] refs = bundleContext.getServiceReferences(serviceType.getName(), filter);
    if (refs != null) {
        services = new ArrayList<>(refs.length);
        if (refs != null && refs.length > 0) {
            for (ServiceReference ref : refs) {
                E service = (E) bundleContext.getService(ref);
                services.add(service);
            }
        }
    } else
        services = Collections.unmodifiableList(new ArrayList<E>());
    return services;
}

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
public void testPUWithJtaDSGetsCreatedAutomatically() throws InvalidSyntaxException, ConfigurationException {

    when(containerContext.getServiceReferences((String) null, 
            "(&(objectClass=javax.sql.DataSource)(osgi.jndi.service.name=testds))"))
        .thenReturn(new ServiceReference<?>[] {dsRef});

    when(punit.getJtaDataSourceName()).thenReturn(
            "osgi:service/javax.sql.DataSource/(osgi.jndi.service.name=testds)");

    when(provider.createContainerEntityManagerFactory(eq(punit), 
            any(Map.class))).thenReturn(emf);

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    verify(punit).setJtaDataSource(ds);
    verify(punitContext).registerService(eq(EntityManagerFactory.class),
            any(EntityManagerFactory.class), argThat(servicePropsMatcher(JPA_UNIT_NAME, "test-props")));

    emfb.close();
}

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
public void testPUWithNonJtaDSGetsCreatedAutomatically() throws InvalidSyntaxException, ConfigurationException {

    when(containerContext.getServiceReferences((String) null, 
            "(&(objectClass=javax.sql.DataSource)(osgi.jndi.service.name=testds))"))
    .thenReturn(new ServiceReference<?>[] {dsRef});

    when(punit.getTransactionType()).thenReturn(RESOURCE_LOCAL);

    when(punit.getNonJtaDataSourceName()).thenReturn(
            "osgi:service/javax.sql.DataSource/(osgi.jndi.service.name=testds)");

    when(provider.createContainerEntityManagerFactory(eq(punit), 
            any(Map.class))).thenReturn(emf);

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    verify(punit).setNonJtaDataSource(ds);
    verify(punitContext).registerService(eq(EntityManagerFactory.class),
            any(EntityManagerFactory.class), argThat(servicePropsMatcher(JPA_UNIT_NAME, "test-props")));

    emfb.close();
}

项目：neoscada 文件：AbstractDataSourceHandler.java

protected void setDataSource ( final String dataSourceId ) throws InvalidSyntaxException
{
    logger.debug ( "Set datasource request: {}", dataSourceId );

    try
    {
        this.trackerLock.lock ();

        if ( this.tracker != null )
        {
            this.tracker.close ();
            this.tracker = null;
        }

        if ( dataSourceId != null )
        {
            this.tracker = new SingleDataSourceTracker ( this.poolTracker, dataSourceId, this.serviceListener );
            this.tracker.open ();
        }
    }
    finally
    {
        this.trackerLock.unlock ();
    }
}

项目：gemini.blueprint 文件：NestedReferencesTest.java

protected void setUp() throws Exception {

        BundleContext bundleContext = new MockBundleContext() {
            // service reference already registered
            public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
                return new ServiceReference[0];
            }
        };

        appContext = new GenericApplicationContext();
        appContext.getBeanFactory().addBeanPostProcessor(new BundleContextAwareProcessor(bundleContext));
        appContext.setClassLoader(getClass().getClassLoader());

        XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(appContext);
        // reader.setEventListener(this.listener);
        reader.loadBeanDefinitions(new ClassPathResource("osgiReferenceNestedBeans.xml", getClass()));
        appContext.refresh();
    }

项目：neoscada 文件：AbstractExporter.java

public void init () throws InvalidSyntaxException
{
    final String filter = String.format ( "(%s=%s)", JaxWsExporter.EXPORT_ENABLED, true );
    synchronized ( this )
    {
        this.context.addServiceListener ( this, filter );
        final ServiceReference<?>[] refs = this.context.getServiceReferences ( (String)null, filter );
        if ( refs != null )
        {
            for ( final ServiceReference<?> ref : refs )
            {
                addService ( ref );
            }
        }
    }
}

项目：neoscada 文件：FilterUtil.java

protected static Filter createFilter ( final String operand, final Filter... filters ) throws InvalidSyntaxException
{
    final StringBuilder sb = new StringBuilder ();

    sb.append ( "(" );
    sb.append ( operand );

    for ( final Filter filter : filters )
    {
        sb.append ( filter.toString () );
    }

    sb.append ( ")" );

    return FrameworkUtil.createFilter ( sb.toString () );
}

项目：neoscada 文件：SingleDataSourceTracker.java

/**
 * Create a new single datasource tracker
 * 
 * @param poolTracker
 *            the pool tracker to use
 * @param dataSourceId
 *            the id of the datasource to track
 * @param listener
 *            the listener that gets notified (must not be <code>null</code>)
 * @throws InvalidSyntaxException
 */
public SingleDataSourceTracker ( final ObjectPoolTracker<DataSource> poolTracker, final String dataSourceId, final ServiceListener listener ) throws InvalidSyntaxException
{
    this.listener = listener;
    if ( listener == null )
    {
        throw new NullPointerException ( "'listener' must not be null" );
    }

    this.tracker = new SingleObjectPoolServiceTracker<DataSource> ( poolTracker, dataSourceId, new SingleObjectPoolServiceTracker.ServiceListener<DataSource> () {
        @Override
        public void serviceChange ( final DataSource service, final Dictionary<?, ?> properties )
        {
            SingleDataSourceTracker.this.setDataSource ( service );
        }
    } );
}

项目：gemini.blueprint 文件：OsgiServiceCollectionProxiesTest.java

protected void setUp() throws Exception {
    services = new LinkedHashMap();

    BundleContext ctx = new MockBundleContext() {

        public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
            return new ServiceReference[0];
        }

        public Object getService(ServiceReference reference) {
            Object service = services.get(reference);
            return (service == null ? new Object() : service);
        }

    };

    ClassLoader cl = getClass().getClassLoader();
    proxyCreator =
            new StaticServiceProxyCreator(new Class<?>[] { Cloneable.class }, cl, cl, ctx,
                    ImportContextClassLoaderEnum.UNMANAGED, false, false);
}

项目：neoscada 文件：ProxyDataSource.java

private void setSources ( final String str ) throws InvalidSyntaxException
{
    if ( this.tracker != null )
    {
        this.tracker.close ();
        this.tracker = null;
    }

    this.sourceIds = convertSources ( str );
    this.sources = new HashMap<DataSource, ProxyDataSource.SourceHandler> ( this.sourceIds.size () );

    if ( this.sourceIds.isEmpty () )
    {
        // nothing to do if we don't have any source
        return;
    }

    this.tracker = new MultiDataSourceTracker ( this.poolTracker, this.sourceIds, this );
    this.tracker.open ();
}

项目：gemini.blueprint 文件：MockBundleContext.java

public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
    // Some jiggery-pokery to get round the fact that we don't ever use the clazz
    if (clazz == null) {
        if (filter != null) {
            // flatten filter since the constants might be case insensitive
            String flattenFilter = filter.toLowerCase();
            int i = flattenFilter.indexOf(Constants.OBJECTCLASS.toLowerCase() + "=");
            if (i > 0) {
                clazz = filter.substring(i + Constants.OBJECTCLASS.length() + 1);
                clazz = clazz.substring(0, clazz.indexOf(")"));
            }
        } else {
            clazz = Object.class.getName();
           }
       }
    return new ServiceReference[] { new MockServiceReference(getBundle(), new String[] { clazz }) };
}

项目：gemini.blueprint 文件：AbstractOsgiCollectionTest.java

protected void setUp() throws Exception {
    services = new LinkedHashMap();

    context = new MockBundleContext() {

        public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
            return new ServiceReference[0];
        }

        public Object getService(ServiceReference reference) {
            Object service = services.get(reference);
            return (service == null ? new Object() : service);
        }
    };

    col = createCollection();
    col.setRequiredAtStartup(false);
    col.afterPropertiesSet();
}

项目：neoscada 文件：ProxyValueSource.java

public ProxyValueSource ( final BundleContext context, final String id, final ProxyHistoricalItem item, final int priority ) throws InvalidSyntaxException
{

    this.item = item;
    this.priority = priority;

    this.listener = new SingleServiceListener<HistoricalItem> () {

        @Override
        public void serviceChange ( final ServiceReference<HistoricalItem> reference, final HistoricalItem service )
        {
            setService ( service );
        }
    };

    this.tracker = new SingleServiceTracker<HistoricalItem> ( context, FilterUtil.createClassAndPidFilter ( HistoricalItem.class.getName (), id ), this.listener );
    this.tracker.open ();
}

项目：neoscada 文件：AverageDataSource.java

private void setSources ( final String str ) throws InvalidSyntaxException
{
    if ( this.tracker != null )
    {
        this.tracker.close ();
        this.tracker = null;
    }

    for ( final DataSourceHandler source : this.sources.values () )
    {
        source.dispose ();
    }
    this.sources.clear ();
    this.sourceIds = convertSources ( str );

    if ( this.sourceIds.isEmpty () )
    {
        // nothing to do if we don't have any source
        return;
    }

    this.tracker = new MultiDataSourceTracker ( this.poolTracker, this.sourceIds, this );
    this.tracker.open ();
}

项目：neoscada 文件：MovingAverageDataSource.java

public void update ( final Map<String, String> parameters ) throws InvalidSyntaxException
{
    if ( this.triggerFuture != null )
    {
        this.triggerFuture.cancel ( false );
        this.triggerFuture = null;
    }

    final ConfigurationDataHelper cfg = new ConfigurationDataHelper ( parameters );
    try
    {
        this.dataSourceId = cfg.getStringChecked ( "datasource.id", "'datasource.id' must be set" ); //$NON-NLS-1$
        this.trigger = cfg.getLongChecked ( "trigger", "'trigger' must be set" ); //$NON-NLS-1$
        this.range = cfg.getLongChecked ( "range", "'range' must be set" ); //$NON-NLS-1$
        this.nullrange = cfg.getLongChecked ( "nullRange", "'nullRange' must be set" ); //$NON-NLS-1$
        this.triggerOnly = cfg.getBoolean ( "triggerOnly", false ); //$NON-NLS-1$
    }
    catch ( final IllegalArgumentException e )
    {
        updateAverage ( new AverageValues () );
        throw e;
    }

    handleChange ();
}

项目：neoscada 文件：MovingAverageDataSource.java

private void updateDataSource () throws InvalidSyntaxException
{
    logger.debug ( "updateDataSource ()" );
    if ( this.dataSourceTracker != null )
    {
        this.dataSourceTracker.close ();
        this.dataSourceTracker = null;
    }
    if ( this.dataSourceId != null )
    {
        logger.debug ( "track datasource {}", this.dataSourceId );
        this.dataSourceTracker = new SingleDataSourceTracker ( this.poolTracker, this.dataSourceId, new ServiceListener () {
            @Override
            public void dataSourceChanged ( final DataSource dataSource )
            {
                setDataSource ( dataSource );
            }
        } );
        this.dataSourceTracker.open ();
    }
}

项目：neoscada 文件：HistoricalItemImpl.java

private void updateDataSource () throws InvalidSyntaxException
{
    logger.debug ( "updateDataSource ()" );
    if ( this.dataSourceTracker != null )
    {
        this.dataSourceTracker.close ();
        this.dataSourceTracker = null;
    }
    if ( this.dataSourceId != null )
    {
        logger.debug ( "track datasource " + this.dataSourceId );
        this.dataSourceTracker = new SingleDataSourceTracker ( this.poolTracker, this.dataSourceId, new ServiceListener () {
            @Override
            public void dataSourceChanged ( final DataSource dataSource )
            {
                setDataSource ( dataSource );
            }
        } );
        this.dataSourceTracker.open ();
    }
}

项目：gemini.blueprint 文件：OsgiDefaultsTests.java

protected void setUp() throws Exception {
    BundleContext bundleContext = new MockBundleContext() {
        // service reference already registered
        public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
            return new ServiceReference[] { new MockServiceReference(new String[] { Serializable.class.getName() }) };
        }
    };

    appContext = new GenericApplicationContext();
    appContext.getBeanFactory().addBeanPostProcessor(new BundleContextAwareProcessor(bundleContext));
    appContext.setClassLoader(getClass().getClassLoader());

    XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(appContext);
    reader.loadBeanDefinitions(new ClassPathResource("osgiDefaults.xml", getClass()));
    appContext.refresh();
}

项目：gemini.blueprint 文件：OsgiSingleReferenceParserWithInvalidFilesTest.java

protected void setUp() throws Exception {
    BundleContext bundleContext = new MockBundleContext() {
        // service reference already registered
        public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
            return new ServiceReference[0];
        }
    };

    appContext = new GenericApplicationContext();
    appContext.getBeanFactory().addBeanPostProcessor(new BundleContextAwareProcessor(bundleContext));
    appContext.setClassLoader(getClass().getClassLoader());
}

项目：aries-jpa 文件：DSFTracker.java

static Filter createFilter(BundleContext context, String driverClass, String puName) {
    if (driverClass == null) {
        throw new IllegalArgumentException("No javax.persistence.jdbc.driver supplied in persistence.xml");
    }
    String filter = String.format("(&(objectClass=%s)(%s=%s))",
                                  DataSourceFactory.class.getName(),
                                  DataSourceFactory.OSGI_JDBC_DRIVER_CLASS,
                                  driverClass);
    LOGGER.info("Tracking DataSourceFactory for punit " + puName + " with filter " + filter);
    try {
        return context.createFilter(filter);
    } catch (InvalidSyntaxException e) {
        throw new IllegalArgumentException(e);
    }
}

项目：aries-jpa 文件：DataSourceTracker.java

static Filter createFilter(BundleContext context, String dsName, String puName) {
    if (dsName == null) {
        throw new IllegalArgumentException("No DataSource supplied in persistence.xml");
    }
    String subFilter = getSubFilter(dsName);
    String filter = String.format("(&(objectClass=%s)%s)",
                                  DataSource.class.getName(),
                                  subFilter);
    LOGGER.info("Tracking DataSource for punit " + puName + " with filter " + filter);
    try {
        return context.createFilter(filter);
    } catch (InvalidSyntaxException e) {
        throw new IllegalArgumentException(e);
    }
}

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
public void testIncompleteEmfWithoutProps() throws InvalidSyntaxException, ConfigurationException {

    when(provider.createContainerEntityManagerFactory(eq(punit), 
            eq(singletonMap(PersistenceUnitTransactionType.class.getName(), JTA))))
        .thenReturn(emf);

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    assertEquals(ECLIPSE_PERSISTENCE_PROVIDER, emfb.getPersistenceProviderName());
    assertEquals(providerBundle, emfb.getPersistenceProviderBundle());

    try {
        emfb.createEntityManagerFactory(null);
        fail("Should throw an exception as incomplete");
    } catch (IllegalArgumentException iae) {
        // Expected
    }


    // No EMF created as incomplete
    verifyZeroInteractions(emf, emfReg, provider);

    emfb.close();

    verifyZeroInteractions(emf, emfReg, provider);
}

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
  public void testIncompleteEmfWithPropsGetsPassed() throws InvalidSyntaxException, ConfigurationException {

    Map<String, Object> providerProps = new HashMap<String, Object>();
    providerProps.put(PersistenceUnitTransactionType.class.getName(), JTA);
    providerProps.put("hibernate.hbm2ddl.auto", "create-drop");

    when(provider.createContainerEntityManagerFactory(eq(punit), 
            eq(providerProps))).thenReturn(emf);

    Map<String, Object> props = new Hashtable<String, Object>();
      props.put("hibernate.hbm2ddl.auto", "create-drop");
      props.put("javax.persistence.dataSource", ds);

      AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);
      emfb.createEntityManagerFactory(props);


      verify(punitContext).registerService(eq(EntityManagerFactory.class),
            any(EntityManagerFactory.class), and(argThat(servicePropsMatcher(JPA_UNIT_NAME, "test-props")),
                    argThat(servicePropsMatcher("hibernate.hbm2ddl.auto", "create-drop"))));

      emfb.close();
verify(emfReg).unregister();
verify(emf).close();
  }

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
  public void testPUWithDriverGetsCreatedAutomatically() throws InvalidSyntaxException, ConfigurationException {

    punitProperties.setProperty("javax.persistence.jdbc.driver", "org.h2.Driver");
    punitProperties.setProperty("javax.persistence.jdbc.url", JDBC_URL);
    punitProperties.setProperty("javax.persistence.jdbc.user", JDBC_USER);
    punitProperties.setProperty("javax.persistence.jdbc.password", JDBC_PASSWORD);

    when(containerContext.getServiceReferences((String) null, 
            "(&(objectClass=org.osgi.service.jdbc.DataSourceFactory)(osgi.jdbc.driver.class=org.h2.Driver))"))
        .thenReturn(new ServiceReference<?>[] {dsfRef});


    when(provider.createContainerEntityManagerFactory(eq(punit), 
            any(Map.class))).thenReturn(emf);

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    verify(punit).setJtaDataSource(ds);
    verify(punitContext).registerService(eq(EntityManagerFactory.class),
            any(EntityManagerFactory.class), argThat(servicePropsMatcher(JPA_UNIT_NAME, "test-props")));

    emfb.close();
verify(emfReg).unregister();
verify(emf).close();
  }

项目：aries-jpa 文件：PropsConfigurationTest.java

@Test
public void testLateBindingDriver() throws InvalidSyntaxException, ConfigurationException {


    when(containerContext.getServiceReferences((String) null, 
            "(&(objectClass=org.osgi.service.jdbc.DataSourceFactory)(osgi.jdbc.driver.class=org.h2.Driver))"))
    .thenReturn(new ServiceReference<?>[] {dsfRef});


    when(provider.createContainerEntityManagerFactory(eq(punit), 
            any(Map.class))).thenReturn(emf);

    AriesEntityManagerFactoryBuilder emfb = new AriesEntityManagerFactoryBuilder(
            containerContext, provider, providerBundle, punit);

    verifyZeroInteractions(provider);

    Map<String, Object> config = new HashMap<String, Object>();
    config.put("javax.persistence.jdbc.driver", "org.h2.Driver");
    config.put("javax.persistence.jdbc.url", JDBC_URL);
    config.put("javax.persistence.jdbc.user", JDBC_USER);
    config.put("javax.persistence.jdbc.password", JDBC_PASSWORD);

    emfb.createEntityManagerFactory(config);

    verify(punit).setJtaDataSource(ds);
    verify(punitContext).registerService(eq(EntityManagerFactory.class),
            any(EntityManagerFactory.class), argThat(servicePropsMatcher(JPA_UNIT_NAME, "test-props")));


    try {
        config.put("javax.persistence.jdbc.driver", "org.apache.derby.client.ClientDriver");
        emfb.createEntityManagerFactory(config);
        fail("Must throw an IllegalArgumentException on rebind");
    } catch (IllegalArgumentException ise) {
        // Expected
    }

    emfb.close();
}

项目：aries-jpa 文件：DataSourceTrackerTest.java

@Test
public void testCreateFilterSimple() throws InvalidSyntaxException {
    BundleContext context = mock(BundleContext.class);

    DataSourceTracker.createFilter(context, "tasklist", "test");

    verify(context, atLeastOnce()).createFilter(Mockito.eq("(&(objectClass=javax.sql.DataSource)(osgi.jndi.service.name=tasklist))"));
}

项目：aries-jpa 文件：ManagedEMFTest.java

@Test
  public void testEmfWithoutProps() throws InvalidSyntaxException, ConfigurationException {
    ManagedEMF emf = new ManagedEMF(builder, "test");
      emf.updated(null);
      Mockito.verifyZeroInteractions(builder);

      Hashtable<String, Object> props = new Hashtable<String, Object>();
emf.updated(props);
      verify(builder).createEntityManagerFactory(props);

      emf.updated(null);
      verify(builder).closeEMF();

  }

项目：aries-jpa 文件：ManagedEMFTest.java

@Test
public void testEmfWithProps() throws InvalidSyntaxException, ConfigurationException {
    ManagedEMF emf = new ManagedEMF(builder, "test");

    Dictionary<String, Object> props = new Hashtable<String, Object>();
    props.put("hibernate.hbm2ddl.auto", "create-drop");
    emf.updated(props);

    verify(builder).createEntityManagerFactory(Collections.<String, Object>singletonMap(
            "hibernate.hbm2ddl.auto", "create-drop"));
}

项目：neoscada 文件：ObjectPoolTracker.java

public ObjectPoolTracker ( final BundleContext context, final String poolClass ) throws InvalidSyntaxException
{
    final Map<String, String> parameters = new HashMap<String, String> ();
    parameters.put ( ObjectPool.OBJECT_POOL_CLASS, poolClass );
    final Filter filter = FilterUtil.createAndFilter ( ObjectPool.class.getName (), parameters );

    this.poolTracker = new ServiceTracker<ObjectPool<S>, ObjectPool<S>> ( context, filter, new ServiceTrackerCustomizer<ObjectPool<S>, ObjectPool<S>> () {

        @Override
        public void removedService ( final ServiceReference<ObjectPool<S>> reference, final ObjectPool<S> service )
        {
            context.ungetService ( reference );
            ObjectPoolTracker.this.removePool ( service );
        }

        @Override
        public void modifiedService ( final ServiceReference<ObjectPool<S>> reference, final ObjectPool<S> service )
        {
            ObjectPoolTracker.this.modifyPool ( service, reference );
        }

        @Override
        public ObjectPool<S> addingService ( final ServiceReference<ObjectPool<S>> reference )
        {
            final ObjectPool<S> o = context.getService ( reference );
            ObjectPoolTracker.this.addPool ( o, reference );
            return o;
        }
    } );
}

项目：neoscada 文件：FilterUtil.java

protected static Filter createFilter ( final String operand, final Map<String, String> parameters ) throws InvalidSyntaxException
{
    final StringBuilder sb = new StringBuilder ();

    sb.append ( "(" );
    sb.append ( operand );

    for ( final Map.Entry<String, String> entry : parameters.entrySet () )
    {
        addPair ( sb, entry.getKey (), entry.getValue () );
    }
    sb.append ( ")" );

    return FrameworkUtil.createFilter ( sb.toString () );
}

项目：hashsdn-controller 文件：WaitingServiceTracker.java

/**
 * Creates an instance.
 *
 * @param serviceInterface
 *            the service interface
 * @param context
 *            the BundleContext
 * @param filter
 *            the OSGi service filter
 * @return new WaitingServiceTracker instance
 */
public static <T> WaitingServiceTracker<T> create(@Nonnull final Class<T> serviceInterface,
        @Nonnull final BundleContext context, @Nonnull final String filter) {
    String newFilter = String.format("(&(%s=%s)%s)", Constants.OBJECTCLASS, serviceInterface.getName(), filter);
    try {
        ServiceTracker<T, ?> tracker = new ServiceTracker<>(context, context.createFilter(newFilter), null);
        tracker.open();
        return new WaitingServiceTracker<>(serviceInterface, tracker);
    } catch (final InvalidSyntaxException e) {
        throw new IllegalArgumentException(String.format("Invalid OSGi filter %s", newFilter), e);
    }
}

项目：gemini.blueprint 文件：OsgiServiceNamespaceHandlerTest.java

protected void setUp() throws Exception {

        services.clear();

        RegistrationListener.BIND_CALLS = 0;
        RegistrationListener.UNBIND_CALLS = 0;

        CustomRegistrationListener.REG_CALLS = 0;
        CustomRegistrationListener.UNREG_CALLS = 0;

        registration = new MockServiceRegistration();

        bundleContext = new MockBundleContext() {

            public ServiceReference[] getServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
                return new ServiceReference[] { new MockServiceReference(new String[] { Cloneable.class.getName() }) };
            }

            public ServiceRegistration registerService(String[] clazzes, Object service, Dictionary properties) {
                services.add(service);
                return registration;
            }
        };

        appContext = new GenericApplicationContext();
        appContext.getBeanFactory().addBeanPostProcessor(new BundleContextAwareProcessor(bundleContext));

        XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(appContext);
        // reader.setEventListener(this.listener);
        reader.loadBeanDefinitions(new ClassPathResource("osgiServiceNamespaceHandlerTests.xml", getClass()));
        appContext.refresh();
    }

项目：neoscada 文件：MapperHandlerFactoryImpl.java

public MapperHandlerFactoryImpl ( final BundleContext context, final ObjectPoolTracker<MasterItem> poolTracker, final ObjectPoolTracker<ValueMapper> mapperPoolTracker, final int defaultPriority ) throws InvalidSyntaxException
{
    super ( context );
    this.poolTracker = poolTracker;
    this.mapperPoolTracker = mapperPoolTracker;
    this.defaultPriority = defaultPriority;
}

项目：neoscada 文件：FilterUtil.java

public static Filter createSimpleOr ( final String attribute, final Set<String> values ) throws InvalidSyntaxException
{
    final StringBuilder sb = new StringBuilder ();

    sb.append ( "(|" );

    for ( final String value : values )
    {
        addPair ( sb, attribute, value );
    }

    sb.append ( ")" );

    return FrameworkUtil.createFilter ( sb.toString () );
}

项目：gemini.blueprint 文件：MockBundleContext.java

public void addServiceListener(ServiceListener listener) {
    try {
        addServiceListener(listener, null);
    } catch (InvalidSyntaxException ex) {
        throw new IllegalStateException("exception should not occur");
    }
}

项目：neoscada 文件：SumSourceFactory.java

public SumSourceFactory ( final BundleContext context, final Executor executor ) throws InvalidSyntaxException
{
    super ( context );
    this.executor = executor;

    this.objectPool = new ObjectPoolImpl<DataSource> ();
    this.poolRegistration = ObjectPoolHelper.registerObjectPool ( context, this.objectPool, DataSource.class );

    this.poolTracker = new ObjectPoolTracker<DataSource> ( context, DataSource.class );
    this.poolTracker.open ();
}

项目：neoscada 文件：AbstractServiceImpl.java

public AbstractServiceImpl ( final BundleContext context, final Executor executor ) throws InvalidSyntaxException
{
    this.executor = executor;
    this.authorizationHelper = new TrackingAuthorizationImplementation ( context );
    this.authorizationTracker = new TrackingAuthorizationTracker ( context );

    this.authenticationImplemenation = new TrackingAuthenticationImplementation ( context );

    this.auditLogTracker = new TrackingAuditLogImplementation ( context );

    setAuthorizationImplementation ( this.authorizationHelper );
    setAuthenticationImplementation ( this.authenticationImplemenation );
    setAuditLogService ( this.auditLogTracker );
}