TorqueBox 3.1.2

org.torquebox.messaging
Class RemoteMessageProcessorGroup

java.lang.Object
  extended by org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
      extended by org.torquebox.messaging.MessageProcessorGroup
          extended by org.torquebox.messaging.RemoteMessageProcessorGroup
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

public class RemoteMessageProcessorGroup
extends MessageProcessorGroup


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
RemoteMessageProcessorGroup(org.jboss.msc.service.ServiceRegistry registry, org.jboss.msc.service.ServiceName baseServiceName, String destinationName, String remoteHost, String username, String password)
           
 
Method Summary
 void start(org.jboss.msc.service.StartContext context)
           
protected  void startConnection(org.jboss.msc.service.StartContext context)
          Prepares a remote connection Lookups connection factory, obtains the destination, creates a connection and starts the connection.
 void stop(org.jboss.msc.service.StopContext context)
           
 
Methods inherited from class org.torquebox.messaging.MessageProcessorGroup
getComponentResolver, getComponentResolverInjector, getRubyRuntimePool, 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, startConsumer, 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

RemoteMessageProcessorGroup

public RemoteMessageProcessorGroup(org.jboss.msc.service.ServiceRegistry registry,
                                   org.jboss.msc.service.ServiceName baseServiceName,
                                   String destinationName,
                                   String remoteHost,
                                   String username,
                                   String password)
Method Detail

start

public void start(org.jboss.msc.service.StartContext context)
           throws org.jboss.msc.service.StartException
Specified by:
start in interface org.jboss.msc.service.Service<org.projectodd.polyglot.messaging.BaseMessageProcessorGroup>
Overrides:
start in class org.projectodd.polyglot.messaging.BaseMessageProcessorGroup
Throws:
org.jboss.msc.service.StartException

stop

public void stop(org.jboss.msc.service.StopContext context)
Specified by:
stop in interface org.jboss.msc.service.Service<org.projectodd.polyglot.messaging.BaseMessageProcessorGroup>
Overrides:
stop in class org.projectodd.polyglot.messaging.BaseMessageProcessorGroup

startConnection

protected void startConnection(org.jboss.msc.service.StartContext context)
Prepares a remote connection Lookups connection factory, obtains the destination, creates a connection and starts the connection.

Overrides:
startConnection in class org.projectodd.polyglot.messaging.BaseMessageProcessorGroup

TorqueBox 3.1.2

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