TorqueBox 3.1.2

org.torquebox.messaging
Class MessageProcessorGroup

java.lang.Object
  extended by org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
      extended by org.torquebox.messaging.MessageProcessorGroup
All Implemented Interfaces:
org.jboss.msc.service.Service<org.projectodd.polyglot.messaging.BaseMessageProcessorGroup>, org.jboss.msc.value.Value<org.projectodd.polyglot.messaging.BaseMessageProcessorGroup>, org.projectodd.polyglot.core.StartState, org.projectodd.polyglot.messaging.MessageProcessorGroupMBean
Direct Known Subclasses:
RemoteMessageProcessorGroup

public class MessageProcessorGroup
extends org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
implements MessageProcessorGroupMBean


Field Summary
 
Fields inherited from class org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
connection, destination, destinationName, log, running, startAsynchronously
 
Fields inherited from interface org.jboss.msc.service.Service
NULL, NULL_VALUE
 
Constructor Summary
MessageProcessorGroup(org.jboss.msc.service.ServiceRegistry registry, org.jboss.msc.service.ServiceName baseServiceName, String destinationName)
           
 
Method Summary
 ComponentResolver getComponentResolver()
           
 org.jboss.msc.inject.Injector<ComponentResolver> getComponentResolverInjector()
           
 RubyRuntimePool getRubyRuntimePool()
           
 org.jboss.msc.inject.Injector<RubyRuntimePool> getRuntimePoolInjector()
           
 
Methods inherited from class org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
createConsumer, createSession, getBaseServiceName, getClientID, getConcurrency, getConnection, getConnectionFactoryInjector, getDestination, getDestinationInjector, getDestinationName, getMessageProcessorClass, getMessageSelector, getName, getServiceRegistry, getStatus, getTransactionManager, getTransactionManagerInjector, getValue, hasStartedAtLeastOnce, installMessageProcessors, instantiateProcessor, isDurable, isStarted, isStoppedAfterDeploy, isSynchronous, isXAEnabled, setClientID, setConcurrency, setConnection, setDurable, setMessageSelector, setName, setStartAsynchronously, setStoppedAfterDeploy, setSynchronous, setXAEnabled, start, start, startConnection, startConsumer, stop, stop, stopConsumer, updateConcurrency
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.projectodd.polyglot.messaging.MessageProcessorGroupMBean
getClientID, getConcurrency, getDestination, getDestinationName, getMessageSelector, getName, getStatus, isDurable, isSynchronous, isXAEnabled, start, stop, updateConcurrency
 

Constructor Detail

MessageProcessorGroup

public MessageProcessorGroup(org.jboss.msc.service.ServiceRegistry registry,
                             org.jboss.msc.service.ServiceName baseServiceName,
                             String destinationName)
Method Detail

getRuntimePoolInjector

public org.jboss.msc.inject.Injector<RubyRuntimePool> getRuntimePoolInjector()

getComponentResolverInjector

public org.jboss.msc.inject.Injector<ComponentResolver> getComponentResolverInjector()

getRubyRuntimePool

public RubyRuntimePool getRubyRuntimePool()

getComponentResolver

public ComponentResolver getComponentResolver()

TorqueBox 3.1.2

Copyright © 2015 JBoss by Red Hat. All Rights Reserved.