public class LocalEjbReceiver extends org.jboss.ejb.client.EJBReceiver implements org.jboss.msc.service.Service<LocalEjbReceiver>, RegistryCollector.Listener<String,List<ClientMapping>>
EJBReceiver
for local same-VM invocations. This handles all invocations on remote interfaces
withing the server JVM.Modifier and Type | Field and Description |
---|---|
static org.jboss.msc.service.ServiceName |
BY_REFERENCE_SERVICE_NAME |
static org.jboss.msc.service.ServiceName |
BY_VALUE_SERVICE_NAME |
static org.jboss.msc.service.ServiceName |
DEFAULT_LOCAL_EJB_RECEIVER_SERVICE_NAME |
Constructor and Description |
---|
LocalEjbReceiver(String nodeName,
boolean allowPassByReference) |
Modifier and Type | Method and Description |
---|---|
protected void |
associate(org.jboss.ejb.client.EJBReceiverContext context) |
protected void |
beforeCompletion(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID) |
protected boolean |
exists(String appName,
String moduleName,
String distinctName,
String beanName) |
org.jboss.msc.inject.Injector<RegistryCollector> |
getClusterRegistryCollectorInjector() |
org.jboss.msc.value.InjectedValue<DeploymentRepository> |
getDeploymentRepository() |
LocalEjbReceiver |
getValue() |
protected <T> org.jboss.ejb.client.StatefulEJBLocator<T> |
openSession(org.jboss.ejb.client.EJBReceiverContext context,
Class<T> viewType,
String appName,
String moduleName,
String distinctName,
String beanName) |
protected void |
processInvocation(org.jboss.ejb.client.EJBClientInvocationContext invocation,
org.jboss.ejb.client.EJBReceiverInvocationContext receiverContext) |
void |
registryAdded(Registry<String,List<ClientMapping>> registry) |
void |
registryRemoved(Registry<String,List<ClientMapping>> registry) |
protected void |
sendCommit(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID,
boolean onePhase) |
protected void |
sendForget(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID) |
protected int |
sendPrepare(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID) |
protected void |
sendRollback(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID) |
void |
start(org.jboss.msc.service.StartContext context) |
void |
stop(org.jboss.msc.service.StopContext context) |
cancelInvocation, deregisterModule, getNodeName, registerModule
public static final org.jboss.msc.service.ServiceName DEFAULT_LOCAL_EJB_RECEIVER_SERVICE_NAME
public static final org.jboss.msc.service.ServiceName BY_VALUE_SERVICE_NAME
public static final org.jboss.msc.service.ServiceName BY_REFERENCE_SERVICE_NAME
public LocalEjbReceiver(String nodeName, boolean allowPassByReference)
protected void associate(org.jboss.ejb.client.EJBReceiverContext context)
associate
in class org.jboss.ejb.client.EJBReceiver
protected void processInvocation(org.jboss.ejb.client.EJBClientInvocationContext invocation, org.jboss.ejb.client.EJBReceiverInvocationContext receiverContext) throws Exception
processInvocation
in class org.jboss.ejb.client.EJBReceiver
Exception
protected <T> org.jboss.ejb.client.StatefulEJBLocator<T> openSession(org.jboss.ejb.client.EJBReceiverContext context, Class<T> viewType, String appName, String moduleName, String distinctName, String beanName) throws IllegalArgumentException
openSession
in class org.jboss.ejb.client.EJBReceiver
IllegalArgumentException
protected boolean exists(String appName, String moduleName, String distinctName, String beanName)
exists
in class org.jboss.ejb.client.EJBReceiver
protected int sendPrepare(org.jboss.ejb.client.EJBReceiverContext context, org.jboss.ejb.client.TransactionID transactionID) throws XAException
sendPrepare
in class org.jboss.ejb.client.EJBReceiver
XAException
protected void sendCommit(org.jboss.ejb.client.EJBReceiverContext context, org.jboss.ejb.client.TransactionID transactionID, boolean onePhase) throws XAException
sendCommit
in class org.jboss.ejb.client.EJBReceiver
XAException
protected void sendRollback(org.jboss.ejb.client.EJBReceiverContext context, org.jboss.ejb.client.TransactionID transactionID) throws XAException
sendRollback
in class org.jboss.ejb.client.EJBReceiver
XAException
protected void sendForget(org.jboss.ejb.client.EJBReceiverContext context, org.jboss.ejb.client.TransactionID transactionID) throws XAException
sendForget
in class org.jboss.ejb.client.EJBReceiver
XAException
protected void beforeCompletion(org.jboss.ejb.client.EJBReceiverContext context, org.jboss.ejb.client.TransactionID transactionID)
beforeCompletion
in class org.jboss.ejb.client.EJBReceiver
public void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<LocalEjbReceiver>
org.jboss.msc.service.StartException
public void stop(org.jboss.msc.service.StopContext context)
stop
in interface org.jboss.msc.service.Service<LocalEjbReceiver>
public LocalEjbReceiver getValue() throws IllegalStateException, IllegalArgumentException
getValue
in interface org.jboss.msc.value.Value<LocalEjbReceiver>
IllegalStateException
IllegalArgumentException
public org.jboss.msc.value.InjectedValue<DeploymentRepository> getDeploymentRepository()
public void registryAdded(Registry<String,List<ClientMapping>> registry)
registryAdded
in interface RegistryCollector.Listener<String,List<ClientMapping>>
public void registryRemoved(Registry<String,List<ClientMapping>> registry)
registryRemoved
in interface RegistryCollector.Listener<String,List<ClientMapping>>
public org.jboss.msc.inject.Injector<RegistryCollector> getClusterRegistryCollectorInjector()
Copyright © 2012 JBoss, a division of Red Hat, Inc.. All Rights Reserved.