public class LocalEjbReceiver extends org.jboss.ejb.client.EJBReceiver implements org.jboss.msc.service.Service<LocalEjbReceiver>, RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>
EJBReceiver
for local same-VM invocations. This handles all invocations on remote interfaces
within 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 receiverContext) |
protected void |
beforeCompletion(org.jboss.ejb.client.EJBReceiverContext context,
org.jboss.ejb.client.TransactionID transactionID) |
protected void |
disassociate(org.jboss.ejb.client.EJBReceiverContext receiverContext) |
protected boolean |
exists(String appName,
String moduleName,
String distinctName,
String beanName) |
org.jboss.msc.inject.Injector<RegistryCollector> |
getClusterRegistryCollectorInjector() |
org.jboss.msc.inject.Injector<DeploymentRepository> |
getDeploymentRepository() |
org.jboss.msc.inject.Injector<org.jboss.remoting3.Endpoint> |
getEndpointInjector() |
org.jboss.msc.inject.Injector<EJBRemoteConnectorService> |
getRemoteConnectorServiceInjector() |
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<org.jboss.as.network.ClientMapping>> cluster) |
void |
registryRemoved(Registry<String,List<org.jboss.as.network.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, sendRecover
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 receiverContext)
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)
start
in interface org.jboss.msc.service.Service<LocalEjbReceiver>
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.inject.Injector<DeploymentRepository> getDeploymentRepository()
public org.jboss.msc.inject.Injector<org.jboss.remoting3.Endpoint> getEndpointInjector()
public org.jboss.msc.inject.Injector<EJBRemoteConnectorService> getRemoteConnectorServiceInjector()
public void registryAdded(Registry<String,List<org.jboss.as.network.ClientMapping>> cluster)
registryAdded
in interface RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>
public void registryRemoved(Registry<String,List<org.jboss.as.network.ClientMapping>> registry)
registryRemoved
in interface RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>
public org.jboss.msc.inject.Injector<RegistryCollector> getClusterRegistryCollectorInjector()
protected void disassociate(org.jboss.ejb.client.EJBReceiverContext receiverContext)
disassociate
in class org.jboss.ejb.client.EJBReceiver
Copyright © 2018 JBoss by Red Hat. All rights reserved.