org.mule.api.registry.MuleRegistry.lookupObjects()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(112)

本文整理了Java中org.mule.api.registry.MuleRegistry.lookupObjects()方法的一些代码示例，展示了MuleRegistry.lookupObjects()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MuleRegistry.lookupObjects()方法的具体详情如下：
包路径：org.mule.api.registry.MuleRegistry
类名称：MuleRegistry
方法名：lookupObjects

MuleRegistry.lookupObjects介绍

暂无

代码示例

代码示例来源：origin: org.mule.munit/munit-runner

  1. private List<MunitFlow> lookupFlows(Class munitClass) {
  2.   return new ArrayList<MunitFlow>(muleContext.getRegistry()
  3.       .lookupObjects(munitClass));
  4. }

代码示例来源：origin: org.mule/mule-core

  1. @Override
  2. public void initialise() throws InitialisationException
  3. {
  4.   this.connectorOperationProviders = muleContext.getRegistry().lookupObjects(ConnectorOperationProvider.class);
  5. }

代码示例来源：origin: org.mule.modules/mule-module-db

  1. public void init(MuleContext muleContext)
  2.   {
  3.     Collection<DataSourceDecorator> connectionFactoryDecorators = muleContext.getRegistry().lookupObjects(DataSourceDecorator.class);
  4.     for (DataSourceDecorator connectionFactoryDecorator : connectionFactoryDecorators)
  5.     {
  6.       decorators.addFirst(connectionFactoryDecorator);
  7.     }
  8.   }
  9. }

代码示例来源：origin: org.mule.munit/munit-runner

  1. private Collection<MunitTestFlow> lookupTests() {
  2.     return new ArrayList<MunitTestFlow>(muleContext.getRegistry()
  3.         .lookupObjects(MunitTestFlow.class));
  4.   }
  5. }

代码示例来源：origin: org.mule.munit/munit-runner

  1. private List<MunitFlow> lookupFlows(Class<? extends MunitFlow> munitClass)
  2.   {
  3.     return new ArrayList<MunitFlow>(muleContext.getRegistry()
  4.                         .lookupObjects(munitClass));
  5.   }
  6. }

代码示例来源：origin: org.mule/mule-core

  1. /**
  2.  * Lazyly fetches and keeps all the registered {@link org.mule.api.util.StreamCloser}
  3.  * instances from the registry. Because there're not too many of them, this is
  4.  * the most efficient option to avoid accessing the registry continuosly.
  5.  * If we get to a situation in which we have many of them, considering using a
  6.  * {@link java.util.Map} guarded by a {@link java.util.concurrent.locks.ReadWriteLock}
  7.  *
  8.  * @return all {@link org.mule.api.util.StreamCloser} instances in the registry
  9.  * @throws Exception
  10.  */
  11. private Collection<StreamCloser> getAllStreamClosers() throws Exception
  12. {
  13.   if (allStreamClosers == null)
  14.   {
  15.     allStreamClosers = muleContext.getRegistry().lookupObjects(StreamCloser.class);
  16.   }
  17.   return allStreamClosers;
  18. }

代码示例来源：origin: org.mule.modules/mule-module-annotations

  1. public MessageProcessorAnnotationParser getRouterParser(Annotation annotation, Class aClass, Member member)
  2. {
  3.   Collection<MessageProcessorAnnotationParser> parsers = muleContext.getRegistry().lookupObjects(MessageProcessorAnnotationParser.class);
  4.   for (MessageProcessorAnnotationParser parser : parsers)
  5.   {
  6.     if (parser.supports(annotation, aClass, member))
  7.     {
  8.       return parser;
  9.     }
  10.   }
  11.   return null;
  12. }

代码示例来源：origin: org.mule.modules/mule-module-annotations

  1. public EndpointAnnotationParser getEndpointParser(Annotation annotation, Class aClass, Member member)
  2. {
  3.   Collection<EndpointAnnotationParser> parsers = muleContext.getRegistry().lookupObjects(EndpointAnnotationParser.class);
  4.   for (EndpointAnnotationParser parser : parsers)
  5.   {
  6.     if (parser.supports(annotation, aClass, member))
  7.     {
  8.       return parser;
  9.     }
  10.   }
  11.   return null;
  12. }

代码示例来源：origin: org.mule.modules/mule-module-annotations

  1. public ExpressionAnnotationParser getExpressionParser(Annotation annotation)
  2. {
  3.   Collection<ExpressionAnnotationParser> parsers = muleContext.getRegistry().lookupObjects(ExpressionAnnotationParser.class);
  4.   for (ExpressionAnnotationParser parser : parsers)
  5.   {
  6.     if (parser.supports(annotation))
  7.     {
  8.       return parser;
  9.     }
  10.   }
  11.   return null;
  12. }

代码示例来源：origin: org.mule.modules/mule-module-db

  1. private DbConfigResolver getDefaultConfigResolver()
  2. {
  3.   Collection<DbConfigResolver> dbConfigResolvers = registry.lookupObjects(DbConfigResolver.class);
  4.   if (dbConfigResolvers.isEmpty())
  5.   {
  6.     throw new UnresolvableDbConfigException("There is no database config defined");
  7.   }
  8.   if (dbConfigResolvers.size() > 1)
  9.   {
  10.     StringBuilder stringBuilder = new StringBuilder();
  11.     for (DbConfigResolver dbConfigResolver : dbConfigResolvers)
  12.     {
  13.       if (stringBuilder.length() != 0)
  14.       {
  15.         stringBuilder.append(", ");
  16.       }
  17.       stringBuilder.append(dbConfigResolver.resolve(null).getName());
  18.     }
  19.     throw new UnresolvableDbConfigException("Database config must be explicitly defined using 'config-ref' attribute there are multiple database configs defined: " + stringBuilder);
  20.   }
  21.   return dbConfigResolvers.iterator().next();
  22. }

代码示例来源：origin: org.mule.modules/mule-module-annotations

  1. public Object convertProperty(Class type, String property)
  2. {
  3.   String prop = parsePlaceholderValues(property);
  4.   Collection c = muleContext.getRegistry().lookupObjects(PropertyConverter.class);
  5.   for (Iterator iterator = c.iterator(); iterator.hasNext();)
  6.   {
  7.     PropertyConverter converter = (PropertyConverter) iterator.next();
  8.     if (converter.getType().equals(type))
  9.     {
  10.       return converter.convert(prop, muleContext);
  11.     }
  12.   }
  13.   throw new IllegalArgumentException(AnnotationsMessages.noPropertyConverterForType(type).getMessage());
  14. }

代码示例来源：origin: org.mule/mule-core

  1. Collection connectors = muleContext.getRegistry().lookupObjects(Connector.class);
  2. for (Iterator iterator = connectors.iterator(); iterator.hasNext();)

代码示例来源：origin: org.mule/mule-core

  1. Collection connectors = muleContext.getRegistry().lookupObjects(Connector.class);
  2. for (Iterator iterator = connectors.iterator(); iterator.hasNext();)

代码示例来源：origin: org.mule/mule-core

  1. Collection<Agent> agents = context.getRegistry().lookupObjects(Agent.class);
  2. if (agents.size() == 0)

代码示例来源：origin: org.mule.modules/mule-module-launcher

  1. @Override
  2.   protected void doFooter(MuleContext context)
  3.   {
  4.     // Mule Agents
  5.     if (!body.isEmpty())
  6.     {
  7.       footer.add(" ");
  8.     }
  9.     //List agents
  10.     Collection<Agent> agents = context.getRegistry().lookupObjects(Agent.class);
  11.     if (agents.size() == 0)
  12.     {
  13.       footer.add(CoreMessages.agentsRunning().getMessage() + " "
  14.           + CoreMessages.none().getMessage());
  15.     }
  16.     else
  17.     {
  18.       footer.add(CoreMessages.agentsRunning().getMessage());
  19.       for (Agent agent : agents)
  20.       {
  21.         footer.add("  " + agent.getDescription());
  22.       }
  23.     }
  24.   }
  25. }

代码示例来源：origin: org.mule/mule-core

  1. @Override
  2.   protected void doFooter(MuleContext context)
  3.   {
  4.     // Mule Agents
  5.     if (!body.isEmpty())
  6.     {
  7.       footer.add(" ");
  8.     }
  9.     //List agents
  10.     Collection<Agent> agents = context.getRegistry().lookupObjects(Agent.class);
  11.     if (agents.size() == 0)
  12.     {
  13.       footer.add(CoreMessages.agentsRunning().getMessage() + " "
  14.           + CoreMessages.none().getMessage());
  15.     }
  16.     else
  17.     {
  18.       footer.add(CoreMessages.agentsRunning().getMessage());
  19.       for (Agent agent : agents)
  20.       {
  21.         footer.add("  " + agent.getDescription());
  22.       }
  23.     }
  24.   }
  25. }

代码示例来源：origin: org.mule.modules/mule-module-http

  1. @Override
  2. public void initialise() throws InitialisationException
  3. {
  4.   Collection<TcpServerSocketProperties> tcpServerSocketPropertiesBeans = muleContext.getRegistry().lookupObjects(TcpServerSocketProperties.class);
  5.   TcpServerSocketProperties tcpServerSocketProperties = new DefaultTcpServerSocketProperties();
  6.   if (tcpServerSocketPropertiesBeans.size() == 1)
  7.   {
  8.     tcpServerSocketProperties = Iterables.getOnlyElement(tcpServerSocketPropertiesBeans);
  9.   }
  10.   else if (tcpServerSocketPropertiesBeans.size() > 1)
  11.   {
  12.     throw new InitialisationException(CoreMessages.createStaticMessage("Only one global TCP server socket properties bean should be defined in the config"), this);
  13.   }
  14.   String threadNamePrefix = ThreadNameHelper.getPrefix(muleContext) + LISTENER_THREAD_NAME_PREFIX;
  15.   try
  16.   {
  17.     httpServerManager = new GrizzlyServerManager(threadNamePrefix, httpListenerRegistry, tcpServerSocketProperties);
  18.   }
  19.   catch (IOException e)
  20.   {
  21.     throw new InitialisationException(e, this);
  22.   }
  23. }

代码示例来源：origin: org.mule/mule-core

  1. private void startPipelineMessageSources() throws LifecycleException
  2. {
  3.   for (Pipeline pipeline : this.getRegistry().lookupObjects(Pipeline.class))
  4.   {
  5.     if (pipeline.getLifecycleState().isStarted())
  6.     {
  7.       MessageSource messageSource = pipeline.getMessageSource();
  8.       startMessageSource(messageSource);
  9.     }
  10.   }
  11. }

代码示例来源：origin: org.mule.modules/mule-module-annotations

  1. @Override
  2. public void initialise() throws InitialisationException
  3. {
  4.   super.initialise();
  5.   if (AnnotationUtils.methodHasParamAnnotations(transformMethod))
  6.   {
  7.     try
  8.     {
  9.       paramTransformer = ExpressionAnnotationsHelper.getTransformerForMethodWithAnnotations(transformMethod, muleContext);
  10.     }
  11.     catch (TransformerException e)
  12.     {
  13.       throw new InitialisationException(e, this);
  14.     }
  15.   }
  16.   resolvers = muleContext.getRegistry().lookupObjects(TransformerArgumentResolver.class);
  17. }

代码示例来源：origin: org.mule/mule-core

  1. private void startServicesMessageSources() throws LifecycleException
  2. {
  3.   for (Service service : this.getRegistry().lookupObjects(Service.class))
  4.   {
  5.     if (service.isStarted() || service.isPaused())
  6.     {
  7.       MessageSource messageSource = service.getMessageSource();
  8.       startMessageSource(messageSource);
  9.       if (service.isPaused() && messageSource instanceof Pausable)
  10.       {
  11.         try
  12.         {
  13.           ((Pausable) messageSource).pause();
  14.         }
  15.         catch (Exception e)
  16.         {
  17.           exceptionListener.handleException(e);
  18.         }
  19.       }
  20.     }
  21.   }
  22. }

内容来源于网络，如有侵权，请联系作者删除！

MuleRegistry

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com